proxy 149 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = value; proxy 152 daemons/controld/controld_execd_state.c if (pcmk__str_eq(node_name, proxy->node_name, pcmk__str_casei)) { proxy 292 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = NULL; proxy 298 daemons/controld/controld_execd_state.c while (g_hash_table_iter_next(&gIter, NULL, (gpointer *) &proxy)) { proxy 299 daemons/controld/controld_execd_state.c if (proxy->source proxy 300 daemons/controld/controld_execd_state.c && pcmk__str_eq(node_name, proxy->node_name, pcmk__str_casei)) { proxy 301 daemons/controld/controld_execd_state.c return proxy; proxy 311 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = NULL; proxy 315 daemons/controld/controld_execd_state.c while ((proxy = find_connected_proxy_by_node(node_name)) != NULL) { proxy 319 daemons/controld/controld_execd_state.c if (proxy->source) { proxy 320 daemons/controld/controld_execd_state.c mainloop_del_ipc_client(proxy->source); proxy 407 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = remote_proxy_new(lrmd, &proxy_callbacks, node_name, proxy 409 daemons/controld/controld_execd_state.c return proxy; proxy 421 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 424 daemons/controld/controld_execd_state.c if (!proxy) { proxy 428 daemons/controld/controld_execd_state.c lrm_state = lrm_state_find(proxy->node_name); proxy 430 daemons/controld/controld_execd_state.c crm_trace("Sending event to %.8s on %s", proxy->session_id, proxy->node_name); proxy 431 daemons/controld/controld_execd_state.c remote_proxy_relay_event(proxy, msg); proxy 480 daemons/controld/controld_execd_state.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 486 daemons/controld/controld_execd_state.c proxy = crmd_remote_proxy_new(lrmd, lrm_state->node_name, session, channel); proxy 488 daemons/controld/controld_execd_state.c if (proxy != NULL) { proxy 522 daemons/controld/controld_execd_state.c } else if (pcmk__str_eq(op, LRMD_IPC_OP_REQUEST, pcmk__str_casei) && proxy && proxy->is_local) { proxy 562 daemons/controld/controld_execd_state.c remote_proxy_relay_response(proxy, op_reply, msg_id); proxy 65 include/crm/lrmd_internal.h void remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg); proxy 66 include/crm/lrmd_internal.h void remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, proxy 69 lib/lrmd/proxy_common.c remote_proxy_relay_event(remote_proxy_t *proxy, xmlNode *msg) proxy 74 lib/lrmd/proxy_common.c crm_xml_add(event, F_LRMD_IPC_SESSION, proxy->session_id); proxy 77 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(proxy->lrm, event); proxy 82 lib/lrmd/proxy_common.c remote_proxy_relay_response(remote_proxy_t *proxy, xmlNode *msg, int msg_id) proxy 87 lib/lrmd/proxy_common.c crm_xml_add(response, F_LRMD_IPC_SESSION, proxy->session_id); proxy 90 lib/lrmd/proxy_common.c lrmd_internal_proxy_send(proxy->lrm, response); proxy 95 lib/lrmd/proxy_common.c remote_proxy_end_session(remote_proxy_t *proxy) proxy 97 lib/lrmd/proxy_common.c if (proxy == NULL) { proxy 100 lib/lrmd/proxy_common.c crm_trace("ending session ID %s", proxy->session_id); proxy 102 lib/lrmd/proxy_common.c if (proxy->source) { proxy 103 lib/lrmd/proxy_common.c mainloop_del_ipc_client(proxy->source); proxy 110 lib/lrmd/proxy_common.c remote_proxy_t *proxy = data; proxy 112 lib/lrmd/proxy_common.c crm_trace("freed proxy session ID %s", proxy->session_id); proxy 113 lib/lrmd/proxy_common.c free(proxy->node_name); proxy 114 lib/lrmd/proxy_common.c free(proxy->session_id); proxy 115 lib/lrmd/proxy_common.c free(proxy); proxy 124 lib/lrmd/proxy_common.c remote_proxy_t *proxy = userdata; proxy 132 lib/lrmd/proxy_common.c flags = crm_ipc_buffer_flags(proxy->ipc); proxy 134 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 135 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, xml, proxy->last_request_id); proxy 136 lib/lrmd/proxy_common.c proxy->last_request_id = 0; proxy 139 lib/lrmd/proxy_common.c crm_trace("Passing event back to %.8s on %s: %.200s", proxy->session_id, proxy->node_name, buffer); proxy 140 lib/lrmd/proxy_common.c remote_proxy_relay_event(proxy, xml); proxy 150 lib/lrmd/proxy_common.c remote_proxy_t *proxy = userdata; proxy 152 lib/lrmd/proxy_common.c crm_trace("destroying %p", proxy); proxy 154 lib/lrmd/proxy_common.c proxy->source = NULL; proxy 155 lib/lrmd/proxy_common.c proxy->ipc = NULL; proxy 157 lib/lrmd/proxy_common.c if(proxy->lrm) { proxy 158 lib/lrmd/proxy_common.c remote_proxy_notify_destroy(proxy->lrm, proxy->session_id); proxy 159 lib/lrmd/proxy_common.c proxy->lrm = NULL; proxy 162 lib/lrmd/proxy_common.c g_hash_table_remove(proxy_table, proxy->session_id); proxy 169 lib/lrmd/proxy_common.c remote_proxy_t *proxy = NULL; proxy 177 lib/lrmd/proxy_common.c proxy = calloc(1, sizeof(remote_proxy_t)); proxy 179 lib/lrmd/proxy_common.c proxy->node_name = strdup(node_name); proxy 180 lib/lrmd/proxy_common.c proxy->session_id = strdup(session_id); proxy 181 lib/lrmd/proxy_common.c proxy->lrm = lrmd; proxy 186 lib/lrmd/proxy_common.c proxy->is_local = TRUE; proxy 189 lib/lrmd/proxy_common.c proxy->source = mainloop_add_ipc_client(channel, G_PRIORITY_LOW, 0, proxy, proxy_callbacks); proxy 190 lib/lrmd/proxy_common.c proxy->ipc = mainloop_get_ipc_client(proxy->source); proxy 191 lib/lrmd/proxy_common.c if (proxy->source == NULL) { proxy 192 lib/lrmd/proxy_common.c remote_proxy_free(proxy); proxy 200 lib/lrmd/proxy_common.c g_hash_table_insert(proxy_table, proxy->session_id, proxy); proxy 202 lib/lrmd/proxy_common.c return proxy; proxy 210 lib/lrmd/proxy_common.c remote_proxy_t *proxy = g_hash_table_lookup(proxy_table, session); proxy 224 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); proxy 233 lib/lrmd/proxy_common.c if (proxy == NULL) { proxy 240 lib/lrmd/proxy_common.c CRM_CHECK(proxy->is_local == FALSE, proxy 241 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); return); proxy 243 lib/lrmd/proxy_common.c if (crm_ipc_connected(proxy->ipc) == FALSE) { proxy 244 lib/lrmd/proxy_common.c remote_proxy_end_session(proxy); proxy 247 lib/lrmd/proxy_common.c proxy->last_request_id = 0; proxy 263 lib/lrmd/proxy_common.c crm_xml_add(request, PCMK__XA_ATTR_NODE_NAME, proxy->node_name); proxy 266 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); proxy 272 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); proxy 278 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, op_reply, msg_id); proxy 283 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 284 lib/lrmd/proxy_common.c proxy->last_request_id = msg_id; proxy 293 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 295 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); proxy 298 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); proxy 301 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); proxy 305 lib/lrmd/proxy_common.c remote_proxy_relay_response(proxy, op_reply, msg_id);