proxy 163 crmd/lrm_state.c remote_proxy_t *proxy = value; proxy 166 crmd/lrm_state.c if (safe_str_eq(node_name, proxy->node_name)) { proxy 306 crmd/lrm_state.c remote_proxy_t *proxy = NULL; proxy 312 crmd/lrm_state.c while (g_hash_table_iter_next(&gIter, NULL, (gpointer *) &proxy)) { proxy 313 crmd/lrm_state.c if (proxy->source proxy 314 crmd/lrm_state.c && safe_str_eq(node_name, proxy->node_name)) { proxy 315 crmd/lrm_state.c return proxy; proxy 325 crmd/lrm_state.c remote_proxy_t *proxy = NULL; proxy 329 crmd/lrm_state.c while ((proxy = find_connected_proxy_by_node(node_name)) != NULL) { proxy 333 crmd/lrm_state.c if (proxy->source) { proxy 334 crmd/lrm_state.c mainloop_del_ipc_client(proxy->source); proxy 421 crmd/lrm_state.c remote_proxy_t *proxy = remote_proxy_new(lrmd, &proxy_callbacks, node_name, proxy 423 crmd/lrm_state.c return proxy; proxy 435 crmd/lrm_state.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 438 crmd/lrm_state.c if (!proxy) { proxy 442 crmd/lrm_state.c lrm_state = lrm_state_find(proxy->node_name); proxy 444 crmd/lrm_state.c crm_trace("Sending event to %.8s on %s", proxy->session_id, proxy->node_name); proxy 445 crmd/lrm_state.c remote_proxy_relay_event(proxy, msg); proxy 496 crmd/lrm_state.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 502 crmd/lrm_state.c proxy = crmd_remote_proxy_new(lrmd, lrm_state->node_name, session, channel); proxy 503 crmd/lrm_state.c if (proxy != NULL) { proxy 534 crmd/lrm_state.c } else if (safe_str_eq(op, LRMD_IPC_OP_REQUEST) && proxy && proxy->is_local) { proxy 559 crmd/lrm_state.c remote_proxy_relay_response(proxy, op_reply, msg_id); proxy 388 include/crm_internal.h void remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg); proxy 389 include/crm_internal.h void remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id); proxy 78 lib/lrmd/proxy_common.c remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg) proxy 83 lib/lrmd/proxy_common.c crm_xml_add(event, F_LRMD_IPC_SESSION, proxy->session_id); proxy 86 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(proxy->lrm, event); proxy 91 lib/lrmd/proxy_common.c remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id) proxy 96 lib/lrmd/proxy_common.c crm_xml_add(response, F_LRMD_IPC_SESSION, proxy->session_id); proxy 99 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(proxy->lrm, response); proxy 104 lib/lrmd/proxy_common.c remote_proxy_end_session(remote_proxy_t *proxy) proxy 106 lib/lrmd/proxy_common.c if (proxy == NULL) { proxy 109 lib/lrmd/proxy_common.c crm_trace("ending session ID %s", proxy->session_id); proxy 111 lib/lrmd/proxy_common.c if (proxy->source) { proxy 112 lib/lrmd/proxy_common.c mainloop_del_ipc_client(proxy->source); proxy 119 lib/lrmd/proxy_common.c remote_proxy_t *proxy = data; proxy 121 lib/lrmd/proxy_common.c crm_trace("freed proxy session ID %s", proxy->session_id); proxy 122 lib/lrmd/proxy_common.c free(proxy->node_name); proxy 123 lib/lrmd/proxy_common.c free(proxy->session_id); proxy 124 lib/lrmd/proxy_common.c free(proxy); proxy 133 lib/lrmd/proxy_common.c remote_proxy_t *proxy = userdata; proxy 141 lib/lrmd/proxy_common.c flags = crm_ipc_buffer_flags(proxy->ipc); proxy 143 lib/lrmd/proxy_common.c crm_trace("Passing response back to %.8s on %s: %.200s - request id: %d", proxy->session_id, proxy->node_name, buffer, proxy->last_request_id); proxy 144 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, xml, proxy->last_request_id); proxy 145 lib/lrmd/proxy_common.c proxy->last_request_id = 0; proxy 148 lib/lrmd/proxy_common.c crm_trace("Passing event back to %.8s on %s: %.200s", proxy->session_id, proxy->node_name, buffer); proxy 149 lib/lrmd/proxy_common.c remote_proxy_relay_event(proxy, xml); proxy 159 lib/lrmd/proxy_common.c remote_proxy_t *proxy = userdata; proxy 161 lib/lrmd/proxy_common.c crm_trace("destroying %p", proxy); proxy 163 lib/lrmd/proxy_common.c proxy->source = NULL; proxy 164 lib/lrmd/proxy_common.c proxy->ipc = NULL; proxy 166 lib/lrmd/proxy_common.c if(proxy->lrm) { proxy 167 lib/lrmd/proxy_common.c remote_proxy_notify_destroy(proxy->lrm, proxy->session_id); proxy 168 lib/lrmd/proxy_common.c proxy->lrm = NULL; proxy 171 lib/lrmd/proxy_common.c g_hash_table_remove(proxy_table, proxy->session_id); proxy 178 lib/lrmd/proxy_common.c remote_proxy_t *proxy = NULL; proxy 186 lib/lrmd/proxy_common.c proxy = calloc(1, sizeof(remote_proxy_t)); proxy 188 lib/lrmd/proxy_common.c proxy->node_name = strdup(node_name); proxy 189 lib/lrmd/proxy_common.c proxy->session_id = strdup(session_id); proxy 190 lib/lrmd/proxy_common.c proxy->lrm = lrmd; proxy 195 lib/lrmd/proxy_common.c proxy->is_local = TRUE; proxy 198 lib/lrmd/proxy_common.c proxy->source = mainloop_add_ipc_client(channel, G_PRIORITY_LOW, 0, proxy, proxy_callbacks); proxy 199 lib/lrmd/proxy_common.c proxy->ipc = mainloop_get_ipc_client(proxy->source); proxy 200 lib/lrmd/proxy_common.c if (proxy->source == NULL) { proxy 201 lib/lrmd/proxy_common.c remote_proxy_free(proxy); proxy 209 lib/lrmd/proxy_common.c g_hash_table_insert(proxy_table, proxy->session_id, proxy); proxy 211 lib/lrmd/proxy_common.c return proxy; proxy 219 lib/lrmd/proxy_common.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 233 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); proxy 242 lib/lrmd/proxy_common.c if (proxy == NULL) { proxy 249 lib/lrmd/proxy_common.c CRM_CHECK(proxy->is_local == FALSE, proxy 250 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); return); proxy 252 lib/lrmd/proxy_common.c if (crm_ipc_connected(proxy->ipc) == FALSE) { proxy 253 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); proxy 256 lib/lrmd/proxy_common.c proxy->last_request_id = 0; proxy 271 lib/lrmd/proxy_common.c crm_xml_add(request, F_ATTRD_HOST, proxy->node_name); proxy 274 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); proxy 280 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); proxy 286 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, op_reply, msg_id); proxy 291 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 292 lib/lrmd/proxy_common.c proxy->last_request_id = msg_id; proxy 301 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 303 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); proxy 306 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); proxy 309 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 313 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, op_reply, msg_id);