ipc 32 include/crm/common/attrd_internal.h int pcmk__node_attr_request(crm_ipc_t * ipc, char command, const char *host, ipc 38 include/crm/common/attrd_internal.h int pcmk__node_attr_request_clear(crm_ipc_t *ipc, const char *host, ipc 118 include/crm/common/internal.h int pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 51 include/crm/lrmd_internal.h crm_ipc_t *ipc; ipc 35 lib/cib/cib_native.c crm_ipc_t *ipc; ipc 75 lib/cib/cib_native.c native->ipc = NULL; ipc 148 lib/cib/cib_native.c native->ipc = NULL; ipc 188 lib/cib/cib_native.c native->ipc = crm_ipc_new(channel, 0); ipc 190 lib/cib/cib_native.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 191 lib/cib/cib_native.c *async_fd = crm_ipc_get_fd(native->ipc); ipc 193 lib/cib/cib_native.c } else if (native->ipc) { ipc 201 lib/cib/cib_native.c native->ipc = mainloop_get_ipc_client(native->source); ipc 204 lib/cib/cib_native.c if (rc != pcmk_ok || native->ipc == NULL || crm_ipc_connected(native->ipc) == FALSE) { ipc 218 lib/cib/cib_native.c if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply) > 0) { ipc 269 lib/cib/cib_native.c native->ipc = NULL; ipc 271 lib/cib/cib_native.c } else if (native->ipc) { ipc 273 lib/cib/cib_native.c crm_ipc_t *ipc = native->ipc; ipc 275 lib/cib/cib_native.c native->ipc = NULL; ipc 276 lib/cib/cib_native.c crm_ipc_close(ipc); ipc 277 lib/cib/cib_native.c crm_ipc_destroy(ipc); ipc 361 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, cib->call_timeout * 1000, &op_reply); ipc 443 lib/cib/cib_native.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 479 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, ipc 52 lib/common/attrd_client.c send_attrd_op(crm_ipc_t *ipc, xmlNode *attrd_op) ipc 61 lib/common/attrd_client.c if (ipc == NULL && local_ipc == NULL) { ipc 67 lib/common/attrd_client.c if (ipc == NULL) { ipc 68 lib/common/attrd_client.c ipc = local_ipc; ipc 74 lib/common/attrd_client.c connected = crm_ipc_connect(ipc); ipc 78 lib/common/attrd_client.c rc = crm_ipc_send(ipc, attrd_op, flags, 0, NULL); ipc 83 lib/common/attrd_client.c if (ipc != local_ipc) { ipc 94 lib/common/attrd_client.c crm_ipc_close(ipc); ipc 133 lib/common/attrd_client.c pcmk__node_attr_request(crm_ipc_t *ipc, char command, const char *host, ipc 209 lib/common/attrd_client.c rc = send_attrd_op(ipc, update); ipc 239 lib/common/attrd_client.c pcmk__node_attr_request_clear(crm_ipc_t *ipc, const char *host, ipc 257 lib/common/attrd_client.c rc = send_attrd_op(ipc, clear_op); ipc 199 lib/common/crmcommon_private.h crm_ipc_t *ipc; // IPC connection ipc 102 lib/common/ipc_client.c (*api)->ipc = crm_ipc_new(pcmk_ipc_name(*api, false), ipc 104 lib/common/ipc_client.c if ((*api)->ipc == NULL) { ipc 182 lib/common/ipc_client.c api->ipc = NULL; ipc 210 lib/common/ipc_client.c if (api->ipc != NULL) { ipc 284 lib/common/ipc_client.c return (api != NULL) && crm_ipc_connected(api->ipc); ipc 401 lib/common/ipc_client.c pollfd.fd = crm_ipc_get_fd(api->ipc); ipc 428 lib/common/ipc_client.c while (crm_ipc_ready(api->ipc) > 0) { ipc 429 lib/common/ipc_client.c if (crm_ipc_read(api->ipc) > 0) { ipc 430 lib/common/ipc_client.c dispatch_ipc_data(crm_ipc_buffer(api->ipc), api); ipc 446 lib/common/ipc_client.c rc = pcmk__add_mainloop_ipc(api->ipc, G_PRIORITY_DEFAULT, api, ipc 465 lib/common/ipc_client.c if (!crm_ipc_connect(api->ipc)) { ipc 467 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 493 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 494 lib/common/ipc_client.c api->ipc = crm_ipc_new(pcmk_ipc_name(api, false), ipc 496 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 502 lib/common/ipc_client.c if (crm_ipc_connected(api->ipc)) { ipc 525 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 545 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL)) { ipc 555 lib/common/ipc_client.c api->ipc = NULL; ipc 565 lib/common/ipc_client.c crm_ipc_t *ipc = api->ipc; ipc 568 lib/common/ipc_client.c api->ipc = NULL; ipc 573 lib/common/ipc_client.c crm_ipc_destroy(ipc); ipc 622 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) { ipc 636 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); ipc 651 lib/common/ipc_client.c rc = crm_ipc_read(api->ipc); ipc 661 lib/common/ipc_client.c rc = dispatch_ipc_data(crm_ipc_buffer(api->ipc), api); ipc 783 lib/common/ipc_client.c qb_ipcc_connection_t *ipc; ipc 855 lib/common/ipc_client.c client->ipc = qb_ipcc_connect(client->server_name, client->buf_size); ipc 857 lib/common/ipc_client.c if (client->ipc == NULL) { ipc 880 lib/common/ipc_client.c if ((rv = pcmk__crm_ipc_is_authentic_process(client->ipc, client->pfd.fd, cl_uid, cl_gid, ipc 905 lib/common/ipc_client.c qb_ipcc_context_set(client->ipc, client); ipc 907 lib/common/ipc_client.c client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc); ipc 920 lib/common/ipc_client.c if (client->ipc) { ipc 921 lib/common/ipc_client.c qb_ipcc_connection_t *ipc = client->ipc; ipc 923 lib/common/ipc_client.c client->ipc = NULL; ipc 924 lib/common/ipc_client.c qb_ipcc_disconnect(ipc); ipc 933 lib/common/ipc_client.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { ipc 960 lib/common/ipc_client.c if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) { ipc 978 lib/common/ipc_client.c } else if (client->ipc == NULL) { ipc 987 lib/common/ipc_client.c rc = qb_ipcc_is_connected(client->ipc); ipc 1071 lib/common/ipc_client.c CRM_ASSERT(client->ipc != NULL); ipc 1075 lib/common/ipc_client.c client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer, ipc 1155 lib/common/ipc_client.c *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000); ipc 1237 lib/common/ipc_client.c qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout); ipc 1292 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv(client->ipc, iov, 2); ipc 1320 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, ipc 727 lib/common/mainloop.c crm_ipc_t *ipc; ipc 755 lib/common/mainloop.c if (client->ipc) { ipc 760 lib/common/mainloop.c read_rc = crm_ipc_read(client->ipc); ipc 766 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); ipc 791 lib/common/mainloop.c if (client->ipc && crm_ipc_connected(client->ipc) == FALSE) { ipc 849 lib/common/mainloop.c if (client->ipc) { ipc 850 lib/common/mainloop.c crm_ipc_close(client->ipc); ipc 860 lib/common/mainloop.c if (client->ipc) { ipc 861 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; ipc 863 lib/common/mainloop.c client->ipc = NULL; ipc 864 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 894 lib/common/mainloop.c pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 898 lib/common/mainloop.c CRM_CHECK((ipc != NULL) && (callbacks != NULL), return EINVAL); ipc 900 lib/common/mainloop.c if (!crm_ipc_connect(ipc)) { ipc 902 lib/common/mainloop.c crm_debug("Connection to %s failed: %d", crm_ipc_name(ipc), errno); ipc 905 lib/common/mainloop.c *source = mainloop_add_fd(crm_ipc_name(ipc), priority, crm_ipc_get_fd(ipc), ipc 910 lib/common/mainloop.c crm_ipc_close(ipc); ipc 913 lib/common/mainloop.c (*source)->ipc = ipc; ipc 939 lib/common/mainloop.c crm_ipc_t *ipc = crm_ipc_new(name, max_size); ipc 941 lib/common/mainloop.c int rc = pcmk__add_mainloop_ipc(ipc, priority, userdata, callbacks, ipc 949 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 970 lib/common/mainloop.c return client->ipc; ipc 35 lib/fencing/st_client.c crm_ipc_t *ipc; ipc 280 lib/fencing/st_client.c native->ipc = NULL; ipc 834 lib/fencing/st_client.c native->ipc = NULL; ipc 836 lib/fencing/st_client.c } else if (native->ipc) { ipc 838 lib/fencing/st_client.c crm_ipc_t *ipc = native->ipc; ipc 840 lib/fencing/st_client.c native->ipc = NULL; ipc 841 lib/fencing/st_client.c crm_ipc_close(ipc); ipc 842 lib/fencing/st_client.c crm_ipc_destroy(ipc); ipc 1093 lib/fencing/st_client.c native->ipc = crm_ipc_new("stonith-ng", 0); ipc 1095 lib/fencing/st_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 1096 lib/fencing/st_client.c *stonith_fd = crm_ipc_get_fd(native->ipc); ipc 1097 lib/fencing/st_client.c } else if (native->ipc) { ipc 1098 lib/fencing/st_client.c crm_ipc_close(native->ipc); ipc 1099 lib/fencing/st_client.c crm_ipc_destroy(native->ipc); ipc 1100 lib/fencing/st_client.c native->ipc = NULL; ipc 1107 lib/fencing/st_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1110 lib/fencing/st_client.c if (native->ipc == NULL) { ipc 1119 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); ipc 1180 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, -1, NULL); ipc 1557 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, ipc 1610 lib/fencing/st_client.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 1630 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { ipc 1632 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 1633 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 1638 lib/fencing/st_client.c if (crm_ipc_connected(private->ipc) == FALSE) { ipc 76 lib/lrmd/lrmd_client.c crm_ipc_t *ipc; ipc 453 lib/lrmd/lrmd_client.c return crm_ipc_ready(native->ipc); ipc 490 lib/lrmd/lrmd_client.c while (crm_ipc_ready(private->ipc)) { ipc 491 lib/lrmd/lrmd_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 492 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 550 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 762 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); ipc 786 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); ipc 816 lib/lrmd/lrmd_client.c return crm_ipc_connected(native->ipc); ipc 1031 lib/lrmd/lrmd_client.c native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0); ipc 1032 lib/lrmd/lrmd_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 1033 lib/lrmd/lrmd_client.c *fd = crm_ipc_get_fd(native->ipc); ipc 1034 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1040 lib/lrmd/lrmd_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1043 lib/lrmd/lrmd_client.c if (native->ipc == NULL) { ipc 1598 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1600 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1602 lib/lrmd/lrmd_client.c crm_ipc_t *ipc = native->ipc; ipc 1604 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1605 lib/lrmd/lrmd_client.c crm_ipc_close(ipc); ipc 1606 lib/lrmd/lrmd_client.c crm_ipc_destroy(ipc); ipc 132 lib/lrmd/proxy_common.c flags = crm_ipc_buffer_flags(proxy->ipc); ipc 155 lib/lrmd/proxy_common.c proxy->ipc = NULL; ipc 190 lib/lrmd/proxy_common.c proxy->ipc = mainloop_get_ipc_client(proxy->source); ipc 243 lib/lrmd/proxy_common.c if (crm_ipc_connected(proxy->ipc) == FALSE) { ipc 268 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); ipc 274 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 285 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 295 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 297 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); ipc 300 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 303 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 295 tools/attrd_updater.c crm_ipc_t *ipc; ipc 311 tools/attrd_updater.c ipc = crm_ipc_new(T_ATTRD, 0); ipc 312 tools/attrd_updater.c if (!crm_ipc_connect(ipc)) { ipc 316 tools/attrd_updater.c rc = crm_ipc_send(ipc, query, crm_ipc_client_response, 0, reply); ipc 320 tools/attrd_updater.c crm_ipc_close(ipc); ipc 322 tools/attrd_updater.c crm_ipc_destroy(ipc);