ipc 61 include/crm/common/internal.h int pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 92 include/crm/common/ipc_internal.h int pcmk__connect_generic_ipc(crm_ipc_t *ipc); ipc 93 include/crm/common/ipc_internal.h int pcmk__ipc_fd(crm_ipc_t *ipc, int *fd); ipc 65 include/crm/lrmd_internal.h crm_ipc_t *ipc; ipc 31 lib/cib/cib_native.c crm_ipc_t *ipc; ipc 80 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, cib->call_timeout * 1000, &op_reply); ipc 163 lib/cib/cib_native.c if (!crm_ipc_connected(native->ipc)) { ipc 224 lib/cib/cib_native.c native->ipc = NULL; ipc 245 lib/cib/cib_native.c native->ipc = NULL; ipc 247 lib/cib/cib_native.c } else if (native->ipc) { ipc 249 lib/cib/cib_native.c crm_ipc_t *ipc = native->ipc; ipc 251 lib/cib/cib_native.c native->ipc = NULL; ipc 252 lib/cib/cib_native.c crm_ipc_close(ipc); ipc 253 lib/cib/cib_native.c crm_ipc_destroy(ipc); ipc 302 lib/cib/cib_native.c native->ipc = mainloop_get_ipc_client(native->source); ipc 304 lib/cib/cib_native.c if (rc != pcmk_ok || native->ipc == NULL || !crm_ipc_connected(native->ipc)) { ipc 317 lib/cib/cib_native.c if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, ipc 388 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, ipc 470 lib/cib/cib_native.c native->ipc = NULL; ipc 298 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), 0); 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 273 lib/common/ipc_client.c return (api != NULL) && crm_ipc_connected(api->ipc); ipc 392 lib/common/ipc_client.c rc = pcmk__ipc_fd(api->ipc, &(pollfd.fd)); 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 431 lib/common/ipc_client.c pcmk__ipc_free_client_buffer(api->ipc); ipc 447 lib/common/ipc_client.c rc = pcmk__add_mainloop_ipc(api->ipc, G_PRIORITY_DEFAULT, api, ipc 464 lib/common/ipc_client.c int rc = pcmk__connect_generic_ipc(api->ipc); ipc 467 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 526 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 527 lib/common/ipc_client.c api->ipc = crm_ipc_new(pcmk_ipc_name(api, false), 0); ipc 528 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 533 lib/common/ipc_client.c if (crm_ipc_connected(api->ipc)) { ipc 572 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 612 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL)) { ipc 622 lib/common/ipc_client.c api->ipc = NULL; ipc 632 lib/common/ipc_client.c crm_ipc_t *ipc = api->ipc; ipc 635 lib/common/ipc_client.c api->ipc = NULL; ipc 640 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 641 lib/common/ipc_client.c crm_ipc_destroy(ipc); ipc 690 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) { ipc 708 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); ipc 723 lib/common/ipc_client.c rc = crm_ipc_read(api->ipc); ipc 733 lib/common/ipc_client.c rc = dispatch_ipc_data(crm_ipc_buffer(api->ipc), api); ipc 734 lib/common/ipc_client.c pcmk__ipc_free_client_buffer(api->ipc); ipc 858 lib/common/ipc_client.c qb_ipcc_connection_t *ipc; ipc 912 lib/common/ipc_client.c pcmk__connect_generic_ipc(crm_ipc_t *ipc) ipc 921 lib/common/ipc_client.c if (ipc == NULL) { ipc 925 lib/common/ipc_client.c ipc->need_reply = FALSE; ipc 926 lib/common/ipc_client.c ipc->ipc = qb_ipcc_connect(ipc->server_name, crm_ipc_default_buffer_size()); ipc 927 lib/common/ipc_client.c if (ipc->ipc == NULL) { ipc 931 lib/common/ipc_client.c rc = qb_ipcc_fd_get(ipc->ipc, &ipc->pfd.fd); ipc 933 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 940 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 944 lib/common/ipc_client.c rc = is_ipc_provider_expected(ipc->ipc, ipc->pfd.fd, cl_uid, cl_gid, ipc 950 lib/common/ipc_client.c ipc->server_name, ipc 955 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 966 lib/common/ipc_client.c if (client->ipc) { ipc 967 lib/common/ipc_client.c qb_ipcc_connection_t *ipc = client->ipc; ipc 969 lib/common/ipc_client.c client->ipc = NULL; ipc 970 lib/common/ipc_client.c qb_ipcc_disconnect(ipc); ipc 979 lib/common/ipc_client.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { ipc 1015 lib/common/ipc_client.c pcmk__ipc_fd(crm_ipc_t *ipc, int *fd) ipc 1017 lib/common/ipc_client.c if ((ipc == NULL) || (fd == NULL)) { ipc 1020 lib/common/ipc_client.c if ((ipc->ipc == NULL) || (ipc->pfd.fd < 0)) { ipc 1023 lib/common/ipc_client.c *fd = ipc->pfd.fd; ipc 1050 lib/common/ipc_client.c } else if (client->ipc == NULL) { ipc 1059 lib/common/ipc_client.c rc = qb_ipcc_is_connected(client->ipc); ipc 1095 lib/common/ipc_client.c pcmk__assert((client != NULL) && (client->ipc != NULL)); ipc 1100 lib/common/ipc_client.c ssize_t bytes = qb_ipcc_event_recv(client->ipc, buffer, ipc 1220 lib/common/ipc_client.c *bytes = qb_ipcc_recv(client->ipc, buffer, crm_ipc_default_buffer_size(), ipc 1306 lib/common/ipc_client.c qb_rc = qb_ipcc_recv(client->ipc, buffer, crm_ipc_default_buffer_size(), ipc 1440 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv(client->ipc, iov, 2); ipc 1773 lib/common/ipc_client.c if ((client != NULL) && (client->ipc == NULL)) { ipc 694 lib/common/mainloop.c crm_ipc_t *ipc; ipc 722 lib/common/mainloop.c if (client->ipc) { ipc 727 lib/common/mainloop.c read_rc = crm_ipc_read(client->ipc); ipc 737 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); ipc 748 lib/common/mainloop.c pcmk__ipc_free_client_buffer(client->ipc); ipc 764 lib/common/mainloop.c if (client->ipc && !crm_ipc_connected(client->ipc)) { ipc 822 lib/common/mainloop.c if (client->ipc) { ipc 823 lib/common/mainloop.c crm_ipc_close(client->ipc); ipc 833 lib/common/mainloop.c if (client->ipc) { ipc 834 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; ipc 836 lib/common/mainloop.c client->ipc = NULL; ipc 837 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 867 lib/common/mainloop.c pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 875 lib/common/mainloop.c CRM_CHECK((ipc != NULL) && (callbacks != NULL), return EINVAL); ipc 877 lib/common/mainloop.c ipc_name = pcmk__s(crm_ipc_name(ipc), "Pacemaker"); ipc 878 lib/common/mainloop.c rc = pcmk__connect_generic_ipc(ipc); ipc 884 lib/common/mainloop.c rc = pcmk__ipc_fd(ipc, &fd); ipc 888 lib/common/mainloop.c crm_ipc_close(ipc); ipc 895 lib/common/mainloop.c crm_ipc_close(ipc); ipc 899 lib/common/mainloop.c (*source)->ipc = ipc; ipc 925 lib/common/mainloop.c crm_ipc_t *ipc = crm_ipc_new(name, 0); ipc 927 lib/common/mainloop.c int rc = pcmk__add_mainloop_ipc(ipc, priority, userdata, callbacks, ipc 935 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 956 lib/common/mainloop.c return client->ipc; ipc 38 lib/fencing/st_client.c crm_ipc_t *ipc; ipc 290 lib/fencing/st_client.c native->ipc = NULL; ipc 874 lib/fencing/st_client.c native->ipc = NULL; ipc 876 lib/fencing/st_client.c } else if (native->ipc) { ipc 878 lib/fencing/st_client.c crm_ipc_t *ipc = native->ipc; ipc 880 lib/fencing/st_client.c native->ipc = NULL; ipc 881 lib/fencing/st_client.c crm_ipc_close(ipc); ipc 882 lib/fencing/st_client.c crm_ipc_destroy(ipc); ipc 1136 lib/fencing/st_client.c native->ipc = crm_ipc_new("stonith-ng", 0); ipc 1137 lib/fencing/st_client.c if (native->ipc != NULL) { ipc 1138 lib/fencing/st_client.c rc = pcmk__connect_generic_ipc(native->ipc); ipc 1140 lib/fencing/st_client.c rc = pcmk__ipc_fd(native->ipc, stonith_fd); ipc 1147 lib/fencing/st_client.c crm_ipc_close(native->ipc); ipc 1148 lib/fencing/st_client.c crm_ipc_destroy(native->ipc); ipc 1149 lib/fencing/st_client.c native->ipc = NULL; ipc 1157 lib/fencing/st_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1160 lib/fencing/st_client.c if (native->ipc == NULL) { ipc 1169 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); ipc 1230 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, -1, NULL); ipc 1601 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, ipc 1655 lib/fencing/st_client.c if (!crm_ipc_connected(native->ipc)) { ipc 1684 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { ipc 1685 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 1686 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 1689 lib/fencing/st_client.c pcmk__ipc_free_client_buffer(private->ipc); ipc 1692 lib/fencing/st_client.c if (!crm_ipc_connected(private->ipc)) { ipc 74 lib/lrmd/lrmd_client.c crm_ipc_t *ipc; ipc 501 lib/lrmd/lrmd_client.c return crm_ipc_ready(native->ipc); ipc 536 lib/lrmd/lrmd_client.c while (crm_ipc_ready(private->ipc)) { ipc 537 lib/lrmd/lrmd_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 538 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 541 lib/lrmd/lrmd_client.c pcmk__ipc_free_client_buffer(private->ipc); ipc 606 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 820 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); ipc 842 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); ipc 870 lib/lrmd/lrmd_client.c return crm_ipc_connected(native->ipc); ipc 1132 lib/lrmd/lrmd_client.c native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0); ipc 1133 lib/lrmd/lrmd_client.c if (native->ipc != NULL) { ipc 1134 lib/lrmd/lrmd_client.c rc = pcmk__connect_generic_ipc(native->ipc); ipc 1136 lib/lrmd/lrmd_client.c rc = pcmk__ipc_fd(native->ipc, fd); ipc 1145 lib/lrmd/lrmd_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1148 lib/lrmd/lrmd_client.c if (native->ipc == NULL) { ipc 1753 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1755 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1757 lib/lrmd/lrmd_client.c crm_ipc_t *ipc = native->ipc; ipc 1759 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1760 lib/lrmd/lrmd_client.c crm_ipc_close(ipc); ipc 1761 lib/lrmd/lrmd_client.c crm_ipc_destroy(ipc); ipc 143 lib/lrmd/proxy_common.c flags = crm_ipc_buffer_flags(proxy->ipc); ipc 166 lib/lrmd/proxy_common.c proxy->ipc = NULL; ipc 201 lib/lrmd/proxy_common.c proxy->ipc = mainloop_get_ipc_client(proxy->source); ipc 258 lib/lrmd/proxy_common.c if (!crm_ipc_connected(proxy->ipc)) { ipc 288 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); ipc 294 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 305 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 315 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 317 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); ipc 320 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 323 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name);