proxy 137 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = value; proxy 140 daemons/controld/controld_execd_state.c if (pcmk__str_eq(node_name, proxy->node_name, pcmk__str_casei)) { proxy 151 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = NULL; proxy 157 daemons/controld/controld_execd_state.c while (g_hash_table_iter_next(&gIter, NULL, (gpointer *) &proxy)) { proxy 158 daemons/controld/controld_execd_state.c if (proxy->source proxy 159 daemons/controld/controld_execd_state.c && pcmk__str_eq(node_name, proxy->node_name, pcmk__str_casei)) { proxy 160 daemons/controld/controld_execd_state.c return proxy; proxy 170 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = NULL; proxy 174 daemons/controld/controld_execd_state.c while ((proxy = find_connected_proxy_by_node(node_name)) != NULL) { proxy 178 daemons/controld/controld_execd_state.c if (proxy->source) { proxy 179 daemons/controld/controld_execd_state.c mainloop_del_ipc_client(proxy->source); proxy 422 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = remote_proxy_new(lrmd, &proxy_callbacks, node_name, proxy 424 daemons/controld/controld_execd_state.c return proxy; proxy 436 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 439 daemons/controld/controld_execd_state.c if (!proxy) { proxy 443 daemons/controld/controld_execd_state.c lrm_state = lrm_state_find(proxy->node_name); proxy 445 daemons/controld/controld_execd_state.c crm_trace("Sending event to %.8s on %s", proxy->session_id, proxy->node_name); proxy 446 daemons/controld/controld_execd_state.c remote_proxy_relay_event(proxy, msg); proxy 496 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 502 daemons/controld/controld_execd_state.c proxy = crmd_remote_proxy_new(lrmd, lrm_state->node_name, session, channel); proxy 504 daemons/controld/controld_execd_state.c if (proxy != NULL) { proxy 546 daemons/controld/controld_execd_state.c } else if (pcmk__str_eq(op, LRMD_IPC_OP_REQUEST, pcmk__str_casei) && proxy && proxy->is_local) { proxy 593 daemons/controld/controld_execd_state.c remote_proxy_relay_response(proxy, op_reply, msg_id); proxy 82 include/crm/lrmd_internal.h void remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg); proxy 83 include/crm/lrmd_internal.h void remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, proxy 70 lib/lrmd/proxy_common.c remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg) proxy 77 lib/lrmd/proxy_common.c crm_xml_add(event, PCMK__XA_LRMD_IPC_SESSION, proxy->session_id); proxy 83 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(proxy->lrm, event); proxy 88 lib/lrmd/proxy_common.c remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id) proxy 95 lib/lrmd/proxy_common.c crm_xml_add(response, PCMK__XA_LRMD_IPC_SESSION, proxy->session_id); proxy 101 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(proxy->lrm, response); proxy 106 lib/lrmd/proxy_common.c remote_proxy_end_session(remote_proxy_t *proxy) proxy 108 lib/lrmd/proxy_common.c if (proxy == NULL) { proxy 111 lib/lrmd/proxy_common.c crm_trace("ending session ID %s", proxy->session_id); proxy 113 lib/lrmd/proxy_common.c if (proxy->source) { proxy 114 lib/lrmd/proxy_common.c mainloop_del_ipc_client(proxy->source); proxy 121 lib/lrmd/proxy_common.c remote_proxy_t *proxy = data; proxy 123 lib/lrmd/proxy_common.c crm_trace("freed proxy session ID %s", proxy->session_id); proxy 124 lib/lrmd/proxy_common.c free(proxy->node_name); proxy 125 lib/lrmd/proxy_common.c free(proxy->session_id); proxy 126 lib/lrmd/proxy_common.c free(proxy); proxy 135 lib/lrmd/proxy_common.c remote_proxy_t *proxy = userdata; proxy 143 lib/lrmd/proxy_common.c flags = crm_ipc_buffer_flags(proxy->ipc); proxy 145 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 146 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, xml, proxy->last_request_id); proxy 147 lib/lrmd/proxy_common.c proxy->last_request_id = 0; proxy 150 lib/lrmd/proxy_common.c crm_trace("Passing event back to %.8s on %s: %.200s", proxy->session_id, proxy->node_name, buffer); proxy 151 lib/lrmd/proxy_common.c remote_proxy_relay_event(proxy, xml); proxy 161 lib/lrmd/proxy_common.c remote_proxy_t *proxy = userdata; proxy 163 lib/lrmd/proxy_common.c crm_trace("destroying %p", proxy); proxy 165 lib/lrmd/proxy_common.c proxy->source = NULL; proxy 166 lib/lrmd/proxy_common.c proxy->ipc = NULL; proxy 168 lib/lrmd/proxy_common.c if(proxy->lrm) { proxy 169 lib/lrmd/proxy_common.c remote_proxy_notify_destroy(proxy->lrm, proxy->session_id); proxy 170 lib/lrmd/proxy_common.c proxy->lrm = NULL; proxy 173 lib/lrmd/proxy_common.c g_hash_table_remove(proxy_table, proxy->session_id); proxy 180 lib/lrmd/proxy_common.c remote_proxy_t *proxy = NULL; proxy 188 lib/lrmd/proxy_common.c proxy = pcmk__assert_alloc(1, sizeof(remote_proxy_t)); proxy 190 lib/lrmd/proxy_common.c proxy->node_name = strdup(node_name); proxy 191 lib/lrmd/proxy_common.c proxy->session_id = strdup(session_id); proxy 192 lib/lrmd/proxy_common.c proxy->lrm = lrmd; proxy 197 lib/lrmd/proxy_common.c proxy->is_local = TRUE; proxy 200 lib/lrmd/proxy_common.c proxy->source = mainloop_add_ipc_client(channel, G_PRIORITY_LOW, 0, proxy, proxy_callbacks); proxy 201 lib/lrmd/proxy_common.c proxy->ipc = mainloop_get_ipc_client(proxy->source); proxy 202 lib/lrmd/proxy_common.c if (proxy->source == NULL) { proxy 203 lib/lrmd/proxy_common.c remote_proxy_free(proxy); proxy 211 lib/lrmd/proxy_common.c g_hash_table_insert(proxy_table, proxy->session_id, proxy); proxy 213 lib/lrmd/proxy_common.c return proxy; proxy 221 lib/lrmd/proxy_common.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 235 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); proxy 248 lib/lrmd/proxy_common.c if (proxy == NULL) { proxy 255 lib/lrmd/proxy_common.c CRM_CHECK(proxy->is_local == FALSE, proxy 256 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); return); proxy 258 lib/lrmd/proxy_common.c if (!crm_ipc_connected(proxy->ipc)) { proxy 259 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); proxy 262 lib/lrmd/proxy_common.c proxy->last_request_id = 0; proxy 284 lib/lrmd/proxy_common.c pcmk__xe_add_node(request, proxy->node_name, 0); proxy 287 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); proxy 293 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); proxy 299 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, op_reply, msg_id); proxy 304 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 305 lib/lrmd/proxy_common.c proxy->last_request_id = msg_id; proxy 314 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 316 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); proxy 319 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); proxy 322 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 326 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, op_reply, msg_id);