ipc 1088 daemons/pacemakerd/pacemakerd.c request_shutdown(crm_ipc_t *ipc) ipc 1104 daemons/pacemakerd/pacemakerd.c rc = crm_ipc_send(ipc, request, crm_ipc_client_response, 0, &reply); ipc 1127 daemons/pacemakerd/pacemakerd.c if (!crm_ipc_connected(ipc)) { ipc 1136 daemons/pacemakerd/pacemakerd.c crm_ipc_close(ipc); ipc 1137 daemons/pacemakerd/pacemakerd.c crm_ipc_destroy(ipc); 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 153 include/crm/common/internal.h int pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 43 include/crm/lrmd_internal.h crm_ipc_t *ipc; ipc 35 lib/cib/cib_native.c crm_ipc_t *ipc; ipc 66 lib/cib/cib_native.c native->ipc = NULL; ipc 139 lib/cib/cib_native.c native->ipc = NULL; ipc 179 lib/cib/cib_native.c native->ipc = crm_ipc_new(channel, 0); ipc 181 lib/cib/cib_native.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 182 lib/cib/cib_native.c *async_fd = crm_ipc_get_fd(native->ipc); ipc 184 lib/cib/cib_native.c } else if (native->ipc) { ipc 192 lib/cib/cib_native.c native->ipc = mainloop_get_ipc_client(native->source); ipc 195 lib/cib/cib_native.c if (rc != pcmk_ok || native->ipc == NULL || crm_ipc_connected(native->ipc) == FALSE) { ipc 209 lib/cib/cib_native.c if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply) > 0) { ipc 257 lib/cib/cib_native.c native->ipc = NULL; ipc 259 lib/cib/cib_native.c } else if (native->ipc) { ipc 261 lib/cib/cib_native.c crm_ipc_t *ipc = native->ipc; ipc 263 lib/cib/cib_native.c native->ipc = NULL; ipc 264 lib/cib/cib_native.c crm_ipc_close(ipc); ipc 265 lib/cib/cib_native.c crm_ipc_destroy(ipc); ipc 349 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, cib->call_timeout * 1000, &op_reply); ipc 431 lib/cib/cib_native.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 467 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, ipc 54 lib/common/attrd_client.c send_attrd_op(crm_ipc_t *ipc, xmlNode *attrd_op) ipc 63 lib/common/attrd_client.c if (ipc == NULL && local_ipc == NULL) { ipc 69 lib/common/attrd_client.c if (ipc == NULL) { ipc 70 lib/common/attrd_client.c ipc = local_ipc; ipc 76 lib/common/attrd_client.c connected = crm_ipc_connect(ipc); ipc 80 lib/common/attrd_client.c rc = crm_ipc_send(ipc, attrd_op, flags, 0, NULL); ipc 85 lib/common/attrd_client.c if (ipc != local_ipc) { ipc 96 lib/common/attrd_client.c crm_ipc_close(ipc); ipc 135 lib/common/attrd_client.c pcmk__node_attr_request(crm_ipc_t *ipc, char command, const char *host, ipc 211 lib/common/attrd_client.c rc = send_attrd_op(ipc, update); ipc 241 lib/common/attrd_client.c pcmk__node_attr_request_clear(crm_ipc_t *ipc, const char *host, ipc 259 lib/common/attrd_client.c rc = send_attrd_op(ipc, clear_op); ipc 236 lib/common/crmcommon_private.h crm_ipc_t *ipc; // IPC connection ipc 101 lib/common/ipc_client.c (*api)->ipc = crm_ipc_new(pcmk_ipc_name(*api, false), ipc 103 lib/common/ipc_client.c if ((*api)->ipc == NULL) { ipc 181 lib/common/ipc_client.c api->ipc = NULL; ipc 209 lib/common/ipc_client.c if (api->ipc != NULL) { ipc 283 lib/common/ipc_client.c return (api != NULL) && crm_ipc_connected(api->ipc); ipc 369 lib/common/ipc_client.c pollfd.fd = crm_ipc_get_fd(api->ipc); ipc 396 lib/common/ipc_client.c while (crm_ipc_ready(api->ipc) > 0) { ipc 397 lib/common/ipc_client.c if (crm_ipc_read(api->ipc) > 0) { ipc 398 lib/common/ipc_client.c dispatch_ipc_data(crm_ipc_buffer(api->ipc), 0, api); ipc 414 lib/common/ipc_client.c rc = pcmk__add_mainloop_ipc(api->ipc, G_PRIORITY_DEFAULT, api, ipc 433 lib/common/ipc_client.c if (!crm_ipc_connect(api->ipc)) { ipc 435 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 461 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 462 lib/common/ipc_client.c api->ipc = crm_ipc_new(pcmk_ipc_name(api, false), ipc 464 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 470 lib/common/ipc_client.c if (crm_ipc_connected(api->ipc)) { ipc 493 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 513 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL)) { ipc 523 lib/common/ipc_client.c api->ipc = NULL; ipc 533 lib/common/ipc_client.c crm_ipc_t *ipc = api->ipc; ipc 536 lib/common/ipc_client.c api->ipc = NULL; ipc 541 lib/common/ipc_client.c crm_ipc_destroy(ipc); ipc 590 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) { ipc 604 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); ipc 728 lib/common/ipc_client.c qb_ipcc_connection_t *ipc; ipc 798 lib/common/ipc_client.c client->ipc = qb_ipcc_connect(client->name, client->buf_size); ipc 800 lib/common/ipc_client.c if (client->ipc == NULL) { ipc 842 lib/common/ipc_client.c qb_ipcc_context_set(client->ipc, client); ipc 845 lib/common/ipc_client.c client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc); ipc 860 lib/common/ipc_client.c if (client->ipc) { ipc 861 lib/common/ipc_client.c qb_ipcc_connection_t *ipc = client->ipc; ipc 863 lib/common/ipc_client.c client->ipc = NULL; ipc 864 lib/common/ipc_client.c qb_ipcc_disconnect(ipc); ipc 873 lib/common/ipc_client.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { ipc 897 lib/common/ipc_client.c if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) { ipc 915 lib/common/ipc_client.c } else if (client->ipc == NULL) { ipc 924 lib/common/ipc_client.c rc = qb_ipcc_is_connected(client->ipc); ipc 1008 lib/common/ipc_client.c CRM_ASSERT(client->ipc != NULL); ipc 1012 lib/common/ipc_client.c client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer, ipc 1085 lib/common/ipc_client.c *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000); ipc 1167 lib/common/ipc_client.c qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout); ipc 1222 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv(client->ipc, iov, 2); ipc 1250 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, ipc 702 lib/common/mainloop.c crm_ipc_t *ipc; ipc 720 lib/common/mainloop.c if (client->ipc) { ipc 725 lib/common/mainloop.c rc = crm_ipc_read(client->ipc); ipc 731 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); ipc 753 lib/common/mainloop.c if (client->ipc && crm_ipc_connected(client->ipc) == FALSE) { ipc 811 lib/common/mainloop.c if (client->ipc) { ipc 812 lib/common/mainloop.c crm_ipc_close(client->ipc); ipc 822 lib/common/mainloop.c if (client->ipc) { ipc 823 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; ipc 825 lib/common/mainloop.c client->ipc = NULL; ipc 826 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 856 lib/common/mainloop.c pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 860 lib/common/mainloop.c CRM_CHECK((ipc != NULL) && (callbacks != NULL), return EINVAL); ipc 862 lib/common/mainloop.c if (!crm_ipc_connect(ipc)) { ipc 865 lib/common/mainloop.c *source = mainloop_add_fd(crm_ipc_name(ipc), priority, crm_ipc_get_fd(ipc), ipc 870 lib/common/mainloop.c crm_ipc_close(ipc); ipc 873 lib/common/mainloop.c (*source)->ipc = ipc; ipc 883 lib/common/mainloop.c crm_ipc_t *ipc = crm_ipc_new(name, max_size); ipc 885 lib/common/mainloop.c int rc = pcmk__add_mainloop_ipc(ipc, priority, userdata, callbacks, ipc 893 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 909 lib/common/mainloop.c return client->ipc; ipc 65 lib/fencing/st_client.c crm_ipc_t *ipc; ipc 261 lib/fencing/st_client.c native->ipc = NULL; ipc 1257 lib/fencing/st_client.c native->ipc = NULL; ipc 1259 lib/fencing/st_client.c } else if (native->ipc) { ipc 1261 lib/fencing/st_client.c crm_ipc_t *ipc = native->ipc; ipc 1263 lib/fencing/st_client.c native->ipc = NULL; ipc 1264 lib/fencing/st_client.c crm_ipc_close(ipc); ipc 1265 lib/fencing/st_client.c crm_ipc_destroy(ipc); ipc 1484 lib/fencing/st_client.c native->ipc = crm_ipc_new("stonith-ng", 0); ipc 1486 lib/fencing/st_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 1487 lib/fencing/st_client.c *stonith_fd = crm_ipc_get_fd(native->ipc); ipc 1488 lib/fencing/st_client.c } else if (native->ipc) { ipc 1489 lib/fencing/st_client.c crm_ipc_close(native->ipc); ipc 1490 lib/fencing/st_client.c crm_ipc_destroy(native->ipc); ipc 1491 lib/fencing/st_client.c native->ipc = NULL; ipc 1498 lib/fencing/st_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1501 lib/fencing/st_client.c if (native->ipc == NULL) { ipc 1510 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); ipc 1574 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, -1, NULL); ipc 1897 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, ipc 1948 lib/fencing/st_client.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 1968 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { ipc 1970 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 1971 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 1976 lib/fencing/st_client.c if (crm_ipc_connected(private->ipc) == FALSE) { ipc 75 lib/lrmd/lrmd_client.c crm_ipc_t *ipc; ipc 440 lib/lrmd/lrmd_client.c return crm_ipc_ready(native->ipc); ipc 477 lib/lrmd/lrmd_client.c while (crm_ipc_ready(private->ipc)) { ipc 478 lib/lrmd/lrmd_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 479 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 536 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 760 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); ipc 782 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); ipc 809 lib/lrmd/lrmd_client.c return crm_ipc_connected(native->ipc); ipc 1022 lib/lrmd/lrmd_client.c native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0); ipc 1023 lib/lrmd/lrmd_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 1024 lib/lrmd/lrmd_client.c *fd = crm_ipc_get_fd(native->ipc); ipc 1025 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1031 lib/lrmd/lrmd_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1034 lib/lrmd/lrmd_client.c if (native->ipc == NULL) { ipc 1418 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1420 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1422 lib/lrmd/lrmd_client.c crm_ipc_t *ipc = native->ipc; ipc 1424 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1425 lib/lrmd/lrmd_client.c crm_ipc_close(ipc); ipc 1426 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 266 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); ipc 272 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 283 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 293 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 295 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); ipc 298 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 301 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 297 tools/attrd_updater.c crm_ipc_t *ipc; ipc 313 tools/attrd_updater.c ipc = crm_ipc_new(T_ATTRD, 0); ipc 314 tools/attrd_updater.c if (crm_ipc_connect(ipc) == FALSE) { ipc 318 tools/attrd_updater.c rc = crm_ipc_send(ipc, query, crm_ipc_client_response, 0, reply); ipc 322 tools/attrd_updater.c crm_ipc_close(ipc); ipc 324 tools/attrd_updater.c crm_ipc_destroy(ipc);