proxy 138 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = value; proxy 141 daemons/controld/controld_execd_state.c if (pcmk__str_eq(node_name, proxy->node_name, pcmk__str_casei)) { proxy 152 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = NULL; proxy 158 daemons/controld/controld_execd_state.c while (g_hash_table_iter_next(&gIter, NULL, (gpointer *) &proxy)) { proxy 159 daemons/controld/controld_execd_state.c if (proxy->source proxy 160 daemons/controld/controld_execd_state.c && pcmk__str_eq(node_name, proxy->node_name, pcmk__str_casei)) { proxy 161 daemons/controld/controld_execd_state.c return proxy; proxy 171 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = NULL; proxy 175 daemons/controld/controld_execd_state.c while ((proxy = find_connected_proxy_by_node(node_name)) != NULL) { proxy 179 daemons/controld/controld_execd_state.c if (proxy->source) { proxy 180 daemons/controld/controld_execd_state.c mainloop_del_ipc_client(proxy->source); proxy 423 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = remote_proxy_new(lrmd, &proxy_callbacks, node_name, proxy 425 daemons/controld/controld_execd_state.c return proxy; proxy 437 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 440 daemons/controld/controld_execd_state.c if (!proxy) { proxy 444 daemons/controld/controld_execd_state.c lrm_state = lrm_state_find(proxy->node_name); proxy 446 daemons/controld/controld_execd_state.c crm_trace("Sending event to %.8s on %s", proxy->session_id, proxy->node_name); proxy 447 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 543 daemons/controld/controld_execd_state.c } else if (pcmk__str_eq(op, LRMD_IPC_OP_REQUEST, pcmk__str_casei) && proxy && proxy->is_local) { proxy 581 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 75 lib/lrmd/proxy_common.c crm_xml_add(event, F_LRMD_IPC_SESSION, proxy->session_id); proxy 78 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(proxy->lrm, event); proxy 83 lib/lrmd/proxy_common.c remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id) proxy 88 lib/lrmd/proxy_common.c crm_xml_add(response, F_LRMD_IPC_SESSION, proxy->session_id); proxy 91 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(proxy->lrm, response); proxy 96 lib/lrmd/proxy_common.c remote_proxy_end_session(remote_proxy_t *proxy) proxy 98 lib/lrmd/proxy_common.c if (proxy == NULL) { proxy 101 lib/lrmd/proxy_common.c crm_trace("ending session ID %s", proxy->session_id); proxy 103 lib/lrmd/proxy_common.c if (proxy->source) { proxy 104 lib/lrmd/proxy_common.c mainloop_del_ipc_client(proxy->source); proxy 111 lib/lrmd/proxy_common.c remote_proxy_t *proxy = data; proxy 113 lib/lrmd/proxy_common.c crm_trace("freed proxy session ID %s", proxy->session_id); proxy 114 lib/lrmd/proxy_common.c free(proxy->node_name); proxy 115 lib/lrmd/proxy_common.c free(proxy->session_id); proxy 116 lib/lrmd/proxy_common.c free(proxy); proxy 125 lib/lrmd/proxy_common.c remote_proxy_t *proxy = userdata; proxy 133 lib/lrmd/proxy_common.c flags = crm_ipc_buffer_flags(proxy->ipc); proxy 135 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 136 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, xml, proxy->last_request_id); proxy 137 lib/lrmd/proxy_common.c proxy->last_request_id = 0; proxy 140 lib/lrmd/proxy_common.c crm_trace("Passing event back to %.8s on %s: %.200s", proxy->session_id, proxy->node_name, buffer); proxy 141 lib/lrmd/proxy_common.c remote_proxy_relay_event(proxy, xml); proxy 151 lib/lrmd/proxy_common.c remote_proxy_t *proxy = userdata; proxy 153 lib/lrmd/proxy_common.c crm_trace("destroying %p", proxy); proxy 155 lib/lrmd/proxy_common.c proxy->source = NULL; proxy 156 lib/lrmd/proxy_common.c proxy->ipc = NULL; proxy 158 lib/lrmd/proxy_common.c if(proxy->lrm) { proxy 159 lib/lrmd/proxy_common.c remote_proxy_notify_destroy(proxy->lrm, proxy->session_id); proxy 160 lib/lrmd/proxy_common.c proxy->lrm = NULL; proxy 163 lib/lrmd/proxy_common.c g_hash_table_remove(proxy_table, proxy->session_id); proxy 170 lib/lrmd/proxy_common.c remote_proxy_t *proxy = NULL; proxy 178 lib/lrmd/proxy_common.c proxy = calloc(1, sizeof(remote_proxy_t)); proxy 180 lib/lrmd/proxy_common.c proxy->node_name = strdup(node_name); proxy 181 lib/lrmd/proxy_common.c proxy->session_id = strdup(session_id); proxy 182 lib/lrmd/proxy_common.c proxy->lrm = lrmd; proxy 187 lib/lrmd/proxy_common.c proxy->is_local = TRUE; proxy 190 lib/lrmd/proxy_common.c proxy->source = mainloop_add_ipc_client(channel, G_PRIORITY_LOW, 0, proxy, proxy_callbacks); proxy 191 lib/lrmd/proxy_common.c proxy->ipc = mainloop_get_ipc_client(proxy->source); proxy 192 lib/lrmd/proxy_common.c if (proxy->source == NULL) { proxy 193 lib/lrmd/proxy_common.c remote_proxy_free(proxy); proxy 201 lib/lrmd/proxy_common.c g_hash_table_insert(proxy_table, proxy->session_id, proxy); proxy 203 lib/lrmd/proxy_common.c return proxy; proxy 211 lib/lrmd/proxy_common.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 225 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); proxy 234 lib/lrmd/proxy_common.c if (proxy == NULL) { proxy 241 lib/lrmd/proxy_common.c CRM_CHECK(proxy->is_local == FALSE, proxy 242 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); return); proxy 244 lib/lrmd/proxy_common.c if (!crm_ipc_connected(proxy->ipc)) { proxy 245 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); proxy 248 lib/lrmd/proxy_common.c proxy->last_request_id = 0; proxy 266 lib/lrmd/proxy_common.c pcmk__xe_add_node(request, proxy->node_name, 0); proxy 269 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); proxy 275 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); proxy 281 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, op_reply, msg_id); proxy 286 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 287 lib/lrmd/proxy_common.c proxy->last_request_id = msg_id; proxy 296 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 298 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); proxy 301 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); proxy 304 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 308 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, op_reply, msg_id);