ipc 57 include/crm/common/internal.h int pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 99 include/crm/common/ipc_internal.h int pcmk__connect_generic_ipc(crm_ipc_t *ipc); ipc 100 include/crm/common/ipc_internal.h int pcmk__ipc_fd(crm_ipc_t *ipc, int *fd); ipc 60 include/crm/lrmd_internal.h crm_ipc_t *ipc; ipc 35 lib/cib/cib_native.c crm_ipc_t *ipc; ipc 84 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, cib->call_timeout * 1000, &op_reply); ipc 165 lib/cib/cib_native.c if (!crm_ipc_connected(native->ipc)) { ipc 226 lib/cib/cib_native.c native->ipc = NULL; ipc 247 lib/cib/cib_native.c native->ipc = NULL; ipc 249 lib/cib/cib_native.c } else if (native->ipc) { ipc 251 lib/cib/cib_native.c crm_ipc_t *ipc = native->ipc; ipc 253 lib/cib/cib_native.c native->ipc = NULL; ipc 254 lib/cib/cib_native.c crm_ipc_close(ipc); ipc 255 lib/cib/cib_native.c crm_ipc_destroy(ipc); ipc 300 lib/cib/cib_native.c native->ipc = crm_ipc_new(channel, 0); ipc 301 lib/cib/cib_native.c if (native->ipc != NULL) { ipc 302 lib/cib/cib_native.c rc = pcmk__connect_generic_ipc(native->ipc); ipc 304 lib/cib/cib_native.c rc = pcmk__ipc_fd(native->ipc, async_fd); ipc 317 lib/cib/cib_native.c native->ipc = mainloop_get_ipc_client(native->source); ipc 320 lib/cib/cib_native.c if (rc != pcmk_ok || native->ipc == NULL || !crm_ipc_connected(native->ipc)) { ipc 333 lib/cib/cib_native.c if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, ipc 409 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, ipc 491 lib/cib/cib_native.c native->ipc = NULL; ipc 209 lib/common/crmcommon_private.h crm_ipc_t *ipc; // IPC connection ipc 107 lib/common/ipc_client.c (*api)->ipc = crm_ipc_new(pcmk_ipc_name(*api, false), ipc 109 lib/common/ipc_client.c if ((*api)->ipc == NULL) { ipc 187 lib/common/ipc_client.c api->ipc = NULL; ipc 215 lib/common/ipc_client.c if (api->ipc != NULL) { ipc 289 lib/common/ipc_client.c return (api != NULL) && crm_ipc_connected(api->ipc); ipc 408 lib/common/ipc_client.c rc = pcmk__ipc_fd(api->ipc, &(pollfd.fd)); ipc 444 lib/common/ipc_client.c while (crm_ipc_ready(api->ipc) > 0) { ipc 445 lib/common/ipc_client.c if (crm_ipc_read(api->ipc) > 0) { ipc 446 lib/common/ipc_client.c dispatch_ipc_data(crm_ipc_buffer(api->ipc), api); ipc 462 lib/common/ipc_client.c rc = pcmk__add_mainloop_ipc(api->ipc, G_PRIORITY_DEFAULT, api, ipc 479 lib/common/ipc_client.c int rc = pcmk__connect_generic_ipc(api->ipc); ipc 482 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 510 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 511 lib/common/ipc_client.c api->ipc = crm_ipc_new(pcmk_ipc_name(api, false), api->ipc_size_max); ipc 512 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 517 lib/common/ipc_client.c if (crm_ipc_connected(api->ipc)) { ipc 556 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 596 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL)) { ipc 606 lib/common/ipc_client.c api->ipc = NULL; ipc 616 lib/common/ipc_client.c crm_ipc_t *ipc = api->ipc; ipc 619 lib/common/ipc_client.c api->ipc = NULL; ipc 624 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 625 lib/common/ipc_client.c crm_ipc_destroy(ipc); ipc 674 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) { ipc 688 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); ipc 703 lib/common/ipc_client.c rc = crm_ipc_read(api->ipc); ipc 713 lib/common/ipc_client.c rc = dispatch_ipc_data(crm_ipc_buffer(api->ipc), api); ipc 832 lib/common/ipc_client.c qb_ipcc_connection_t *ipc; ipc 895 lib/common/ipc_client.c pcmk__connect_generic_ipc(crm_ipc_t *ipc) ipc 904 lib/common/ipc_client.c if (ipc == NULL) { ipc 908 lib/common/ipc_client.c ipc->need_reply = FALSE; ipc 909 lib/common/ipc_client.c ipc->ipc = qb_ipcc_connect(ipc->server_name, ipc->buf_size); ipc 910 lib/common/ipc_client.c if (ipc->ipc == NULL) { ipc 914 lib/common/ipc_client.c rc = qb_ipcc_fd_get(ipc->ipc, &ipc->pfd.fd); ipc 916 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 923 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 927 lib/common/ipc_client.c rc = is_ipc_provider_expected(ipc->ipc, ipc->pfd.fd, cl_uid, cl_gid, ipc 933 lib/common/ipc_client.c ipc->server_name, ipc 938 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 942 lib/common/ipc_client.c ipc->max_buf_size = qb_ipcc_get_buffer_size(ipc->ipc); ipc 943 lib/common/ipc_client.c if (ipc->max_buf_size > ipc->buf_size) { ipc 944 lib/common/ipc_client.c free(ipc->buffer); ipc 945 lib/common/ipc_client.c ipc->buffer = calloc(ipc->max_buf_size, sizeof(char)); ipc 946 lib/common/ipc_client.c if (ipc->buffer == NULL) { ipc 948 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 951 lib/common/ipc_client.c ipc->buf_size = ipc->max_buf_size; ipc 974 lib/common/ipc_client.c if ((client != NULL) && (client->ipc == NULL)) { ipc 995 lib/common/ipc_client.c if (client->ipc) { ipc 996 lib/common/ipc_client.c qb_ipcc_connection_t *ipc = client->ipc; ipc 998 lib/common/ipc_client.c client->ipc = NULL; ipc 999 lib/common/ipc_client.c qb_ipcc_disconnect(ipc); ipc 1008 lib/common/ipc_client.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { ipc 1040 lib/common/ipc_client.c pcmk__ipc_fd(crm_ipc_t *ipc, int *fd) ipc 1042 lib/common/ipc_client.c if ((ipc == NULL) || (fd == NULL)) { ipc 1045 lib/common/ipc_client.c if ((ipc->ipc == NULL) || (ipc->pfd.fd < 0)) { ipc 1048 lib/common/ipc_client.c *fd = ipc->pfd.fd; ipc 1075 lib/common/ipc_client.c } else if (client->ipc == NULL) { ipc 1084 lib/common/ipc_client.c rc = qb_ipcc_is_connected(client->ipc); ipc 1169 lib/common/ipc_client.c CRM_ASSERT(client->ipc != NULL); ipc 1173 lib/common/ipc_client.c client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer, ipc 1253 lib/common/ipc_client.c *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000); ipc 1335 lib/common/ipc_client.c qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout); ipc 1390 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv(client->ipc, iov, 2); ipc 1418 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, ipc 697 lib/common/mainloop.c crm_ipc_t *ipc; ipc 725 lib/common/mainloop.c if (client->ipc) { ipc 730 lib/common/mainloop.c read_rc = crm_ipc_read(client->ipc); ipc 736 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); ipc 761 lib/common/mainloop.c if (client->ipc && !crm_ipc_connected(client->ipc)) { ipc 819 lib/common/mainloop.c if (client->ipc) { ipc 820 lib/common/mainloop.c crm_ipc_close(client->ipc); ipc 830 lib/common/mainloop.c if (client->ipc) { ipc 831 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; ipc 833 lib/common/mainloop.c client->ipc = NULL; ipc 834 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 864 lib/common/mainloop.c pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 872 lib/common/mainloop.c CRM_CHECK((ipc != NULL) && (callbacks != NULL), return EINVAL); ipc 874 lib/common/mainloop.c ipc_name = pcmk__s(crm_ipc_name(ipc), "Pacemaker"); ipc 875 lib/common/mainloop.c rc = pcmk__connect_generic_ipc(ipc); ipc 881 lib/common/mainloop.c rc = pcmk__ipc_fd(ipc, &fd); ipc 885 lib/common/mainloop.c crm_ipc_close(ipc); ipc 892 lib/common/mainloop.c crm_ipc_close(ipc); ipc 896 lib/common/mainloop.c (*source)->ipc = ipc; ipc 922 lib/common/mainloop.c crm_ipc_t *ipc = crm_ipc_new(name, max_size); ipc 924 lib/common/mainloop.c int rc = pcmk__add_mainloop_ipc(ipc, priority, userdata, callbacks, ipc 932 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 953 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 852 lib/fencing/st_client.c native->ipc = NULL; ipc 854 lib/fencing/st_client.c } else if (native->ipc) { ipc 856 lib/fencing/st_client.c crm_ipc_t *ipc = native->ipc; ipc 858 lib/fencing/st_client.c native->ipc = NULL; ipc 859 lib/fencing/st_client.c crm_ipc_close(ipc); ipc 860 lib/fencing/st_client.c crm_ipc_destroy(ipc); ipc 1111 lib/fencing/st_client.c native->ipc = crm_ipc_new("stonith-ng", 0); ipc 1112 lib/fencing/st_client.c if (native->ipc != NULL) { ipc 1113 lib/fencing/st_client.c rc = pcmk__connect_generic_ipc(native->ipc); ipc 1115 lib/fencing/st_client.c rc = pcmk__ipc_fd(native->ipc, stonith_fd); ipc 1122 lib/fencing/st_client.c crm_ipc_close(native->ipc); ipc 1123 lib/fencing/st_client.c crm_ipc_destroy(native->ipc); ipc 1124 lib/fencing/st_client.c native->ipc = NULL; ipc 1132 lib/fencing/st_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1135 lib/fencing/st_client.c if (native->ipc == NULL) { ipc 1144 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); ipc 1205 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, -1, NULL); ipc 1596 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, ipc 1648 lib/fencing/st_client.c if (!crm_ipc_connected(native->ipc)) { ipc 1668 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { ipc 1670 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 1671 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 1676 lib/fencing/st_client.c if (!crm_ipc_connected(private->ipc)) { 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 563 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 777 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); ipc 801 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); ipc 831 lib/lrmd/lrmd_client.c return crm_ipc_connected(native->ipc); ipc 1060 lib/lrmd/lrmd_client.c native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0); ipc 1061 lib/lrmd/lrmd_client.c if (native->ipc != NULL) { ipc 1062 lib/lrmd/lrmd_client.c rc = pcmk__connect_generic_ipc(native->ipc); ipc 1064 lib/lrmd/lrmd_client.c rc = pcmk__ipc_fd(native->ipc, fd); ipc 1073 lib/lrmd/lrmd_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1076 lib/lrmd/lrmd_client.c if (native->ipc == NULL) { ipc 1631 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1633 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1635 lib/lrmd/lrmd_client.c crm_ipc_t *ipc = native->ipc; ipc 1637 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1638 lib/lrmd/lrmd_client.c crm_ipc_close(ipc); ipc 1639 lib/lrmd/lrmd_client.c crm_ipc_destroy(ipc); ipc 133 lib/lrmd/proxy_common.c flags = crm_ipc_buffer_flags(proxy->ipc); ipc 156 lib/lrmd/proxy_common.c proxy->ipc = NULL; ipc 191 lib/lrmd/proxy_common.c proxy->ipc = mainloop_get_ipc_client(proxy->source); ipc 244 lib/lrmd/proxy_common.c if (!crm_ipc_connected(proxy->ipc)) { ipc 269 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); ipc 275 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 286 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 296 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 298 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); ipc 301 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 304 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name);