ipcs 184 attrd/attrd_common.c attrd_init_ipc(qb_ipcs_service_t **ipcs, qb_ipcs_msg_process_fn dispatch_fn) ipcs 196 attrd/attrd_common.c attrd_ipc_server_init(ipcs, &ipc_callbacks); ipcs 23 attrd/attrd_common.h void attrd_init_ipc(qb_ipcs_service_t **ipcs, ipcs 638 attrd/legacy.c qb_ipcs_service_t *ipcs = NULL; ipcs 703 attrd/legacy.c attrd_init_ipc(&ipcs, attrd_ipc_dispatch); ipcs 731 attrd/legacy.c c = qb_ipcs_connection_first_get(ipcs); ipcs 735 attrd/legacy.c c = qb_ipcs_connection_next_get(ipcs, last); ipcs 743 attrd/legacy.c qb_ipcs_destroy(ipcs); ipcs 331 attrd/main.c qb_ipcs_service_t *ipcs = NULL; ipcs 383 attrd/main.c attrd_init_ipc(&ipcs, attrd_ipc_dispatch); ipcs 392 attrd/main.c if (ipcs) { ipcs 393 attrd/main.c crm_client_disconnect_all(ipcs); ipcs 394 attrd/main.c qb_ipcs_destroy(ipcs); ipcs 428 cib/callbacks.c if (client_obj->ipcs) { ipcs 90 cib/notify.c if (client->ipcs == NULL && client->remote == NULL) { ipcs 51 crmd/control.c qb_ipcs_service_t *ipcs = NULL; ipcs 295 crmd/control.c if(ipcs) { ipcs 297 crmd/control.c mainloop_del_ipc_server(ipcs); ipcs 298 crmd/control.c ipcs = NULL; ipcs 308 crmd/control.c if (pe_subsystem && pe_subsystem->client && pe_subsystem->client->ipcs) { ipcs 310 crmd/control.c qb_ipcs_disconnect(pe_subsystem->client->ipcs); ipcs 798 crmd/control.c mainloop_del_ipc_server(ipcs); ipcs = NULL; ipcs 866 crmd/control.c ipcs = crmd_ipc_server_init(&crmd_callbacks); ipcs 867 crmd/control.c if (ipcs == NULL) { ipcs 588 crmd/messages.c qb_ipcs_disconnect(curr_client->ipcs); ipcs 62 fencing/main.c qb_ipcs_service_t *ipcs = NULL; ipcs 328 fencing/main.c if (client->ipcs == NULL) { ipcs 1175 fencing/main.c if (ipcs) { ipcs 1176 fencing/main.c qb_ipcs_destroy(ipcs); ipcs 1535 fencing/main.c stonith_ipc_server_init(&ipcs, &ipc_callbacks); ipcs 94 include/crm/common/ipcs.h qb_ipcs_connection_t *ipcs; /* IPC */ ipcs 323 include/crm_internal.h attrd_ipc_server_init(qb_ipcs_service_t **ipcs, struct qb_ipcs_service_handlers *cb); ipcs 325 include/crm_internal.h stonith_ipc_server_init(qb_ipcs_service_t **ipcs, struct qb_ipcs_service_handlers *cb); ipcs 348 lib/common/ipc.c client->ipcs = c; ipcs 373 lib/common/ipc.c if (c->ipcs) { ipcs 375 lib/common/ipc.c c, c->ipcs, crm_hash_table_size(client_connections) - 1); ipcs 376 lib/common/ipc.c g_hash_table_remove(client_connections, c->ipcs); ipcs 539 lib/common/ipc.c crm_trace("Timer active for %p - %d", c->ipcs, c->event_timer); ipcs 548 lib/common/ipc.c rc = qb_ipcs_event_sendv(c->ipcs, event, 2); ipcs 557 lib/common/ipc.c header->qb.id, c->ipcs, c->pid, (long long) rc); ipcs 560 lib/common/ipc.c header->qb.id, c->ipcs, c->pid, (long long) rc, ipcs 573 lib/common/ipc.c sent, queue_len, c->ipcs, c->pid, ipcs 587 lib/common/ipc.c CRM_XS " %p", c->pid, queue_len, c->ipcs); ipcs 590 lib/common/ipc.c CRM_XS " %p", c->pid, queue_len, c->ipcs); ipcs 592 lib/common/ipc.c qb_ipcs_disconnect(c->ipcs); ipcs 709 lib/common/ipc.c crm_trace("Sending the original to %p[%d]", c->ipcs, c->pid); ipcs 715 lib/common/ipc.c crm_trace("Sending a copy to %p[%d]", c->ipcs, c->pid); ipcs 730 lib/common/ipc.c rc = qb_ipcs_response_sendv(c->ipcs, iov, 2); ipcs 733 lib/common/ipc.c header->qb.id, c->ipcs, c->pid, header->qb.size, pcmk_strerror(rc), rc); ipcs 737 lib/common/ipc.c header->qb.id, (long long) rc, c->ipcs, c->pid); ipcs 754 lib/common/ipc.c crm_trace("Client %p disconnected", c->ipcs); ipcs 779 lib/common/ipc.c c->ipcs, c->pid, pcmk_strerror(rc), rc); ipcs 1212 lib/common/utils.c attrd_ipc_server_init(qb_ipcs_service_t **ipcs, struct qb_ipcs_service_handlers *cb) ipcs 1214 lib/common/utils.c *ipcs = mainloop_add_ipc_server(T_ATTRD, QB_IPC_NATIVE, cb); ipcs 1216 lib/common/utils.c if (*ipcs == NULL) { ipcs 1224 lib/common/utils.c stonith_ipc_server_init(qb_ipcs_service_t **ipcs, struct qb_ipcs_service_handlers *cb) ipcs 1226 lib/common/utils.c *ipcs = mainloop_add_ipc_server("stonith-ng", QB_IPC_NATIVE, cb); ipcs 1228 lib/common/utils.c if (*ipcs == NULL) { ipcs 209 lrmd/ipc_proxy.c qb_ipcs_disconnect(ipc_client->ipcs); ipcs 231 lrmd/ipc_proxy.c qb_ipcs_disconnect(client->ipcs); ipcs 416 lrmd/ipc_proxy.c qb_ipcs_disconnect(ipc_client->ipcs); ipcs 43 lrmd/main.c static qb_ipcs_service_t *ipcs = NULL; ipcs 247 lrmd/main.c if (client->ipcs == NULL) { ipcs 286 lrmd/main.c if (ipcs) { ipcs 287 lrmd/main.c mainloop_del_ipc_server(ipcs); ipcs 614 lrmd/main.c ipcs = mainloop_add_ipc_server(CRM_SYSTEM_LRMD, QB_IPC_SHM, &lrmd_ipc_callbacks); ipcs 615 lrmd/main.c if (ipcs == NULL) { ipcs 919 mcp/pacemaker.c qb_ipcs_service_t *ipcs = NULL; ipcs 1085 mcp/pacemaker.c ipcs = mainloop_add_ipc_server(CRM_SYSTEM_MCP, QB_IPC_NATIVE, &mcp_ipc_callbacks); ipcs 1086 mcp/pacemaker.c if (ipcs == NULL) { ipcs 1143 mcp/pacemaker.c if (ipcs) { ipcs 1145 mcp/pacemaker.c mainloop_del_ipc_server(ipcs); ipcs 1146 mcp/pacemaker.c ipcs = NULL; ipcs 42 pengine/main.c qb_ipcs_service_t *ipcs = NULL; ipcs 174 pengine/main.c ipcs = mainloop_add_ipc_server(CRM_SYSTEM_PENGINE, QB_IPC_SHM, &ipc_callbacks); ipcs 175 pengine/main.c if (ipcs == NULL) { ipcs 193 pengine/main.c mainloop_del_ipc_server(ipcs);