ipc 60 include/crm/common/internal.h int pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 91 include/crm/common/ipc_internal.h int pcmk__connect_generic_ipc(crm_ipc_t *ipc); ipc 92 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 280 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 279 lib/common/ipc_client.c return (api != NULL) && crm_ipc_connected(api->ipc); ipc 398 lib/common/ipc_client.c rc = pcmk__ipc_fd(api->ipc, &(pollfd.fd)); ipc 434 lib/common/ipc_client.c while (crm_ipc_ready(api->ipc) > 0) { ipc 435 lib/common/ipc_client.c if (crm_ipc_read(api->ipc) > 0) { ipc 436 lib/common/ipc_client.c dispatch_ipc_data(crm_ipc_buffer(api->ipc), api); ipc 452 lib/common/ipc_client.c rc = pcmk__add_mainloop_ipc(api->ipc, G_PRIORITY_DEFAULT, api, ipc 469 lib/common/ipc_client.c int rc = pcmk__connect_generic_ipc(api->ipc); ipc 472 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 500 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 501 lib/common/ipc_client.c api->ipc = crm_ipc_new(pcmk_ipc_name(api, false), api->ipc_size_max); ipc 502 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 507 lib/common/ipc_client.c if (crm_ipc_connected(api->ipc)) { ipc 546 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 586 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL)) { ipc 596 lib/common/ipc_client.c api->ipc = NULL; ipc 606 lib/common/ipc_client.c crm_ipc_t *ipc = api->ipc; ipc 609 lib/common/ipc_client.c api->ipc = NULL; ipc 614 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 615 lib/common/ipc_client.c crm_ipc_destroy(ipc); ipc 664 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) { ipc 678 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); ipc 693 lib/common/ipc_client.c rc = crm_ipc_read(api->ipc); ipc 703 lib/common/ipc_client.c rc = dispatch_ipc_data(crm_ipc_buffer(api->ipc), api); ipc 827 lib/common/ipc_client.c qb_ipcc_connection_t *ipc; ipc 890 lib/common/ipc_client.c pcmk__connect_generic_ipc(crm_ipc_t *ipc) ipc 899 lib/common/ipc_client.c if (ipc == NULL) { ipc 903 lib/common/ipc_client.c ipc->need_reply = FALSE; ipc 904 lib/common/ipc_client.c ipc->ipc = qb_ipcc_connect(ipc->server_name, ipc->buf_size); ipc 905 lib/common/ipc_client.c if (ipc->ipc == NULL) { ipc 909 lib/common/ipc_client.c rc = qb_ipcc_fd_get(ipc->ipc, &ipc->pfd.fd); ipc 911 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 918 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 922 lib/common/ipc_client.c rc = is_ipc_provider_expected(ipc->ipc, ipc->pfd.fd, cl_uid, cl_gid, ipc 928 lib/common/ipc_client.c ipc->server_name, ipc 933 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 937 lib/common/ipc_client.c ipc->max_buf_size = qb_ipcc_get_buffer_size(ipc->ipc); ipc 938 lib/common/ipc_client.c if (ipc->max_buf_size > ipc->buf_size) { ipc 939 lib/common/ipc_client.c free(ipc->buffer); ipc 940 lib/common/ipc_client.c ipc->buffer = calloc(ipc->max_buf_size, sizeof(char)); ipc 941 lib/common/ipc_client.c if (ipc->buffer == NULL) { ipc 943 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 946 lib/common/ipc_client.c ipc->buf_size = ipc->max_buf_size; ipc 956 lib/common/ipc_client.c if (client->ipc) { ipc 957 lib/common/ipc_client.c qb_ipcc_connection_t *ipc = client->ipc; ipc 959 lib/common/ipc_client.c client->ipc = NULL; ipc 960 lib/common/ipc_client.c qb_ipcc_disconnect(ipc); ipc 969 lib/common/ipc_client.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { ipc 1001 lib/common/ipc_client.c pcmk__ipc_fd(crm_ipc_t *ipc, int *fd) ipc 1003 lib/common/ipc_client.c if ((ipc == NULL) || (fd == NULL)) { ipc 1006 lib/common/ipc_client.c if ((ipc->ipc == NULL) || (ipc->pfd.fd < 0)) { ipc 1009 lib/common/ipc_client.c *fd = ipc->pfd.fd; ipc 1036 lib/common/ipc_client.c } else if (client->ipc == NULL) { ipc 1045 lib/common/ipc_client.c rc = qb_ipcc_is_connected(client->ipc); ipc 1122 lib/common/ipc_client.c pcmk__assert((client != NULL) && (client->ipc != NULL) ipc 1126 lib/common/ipc_client.c client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer, ipc 1206 lib/common/ipc_client.c *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000); ipc 1288 lib/common/ipc_client.c qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout); ipc 1343 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv(client->ipc, iov, 2); ipc 1371 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, ipc 1661 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 733 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); ipc 758 lib/common/mainloop.c if (client->ipc && !crm_ipc_connected(client->ipc)) { ipc 816 lib/common/mainloop.c if (client->ipc) { ipc 817 lib/common/mainloop.c crm_ipc_close(client->ipc); ipc 827 lib/common/mainloop.c if (client->ipc) { ipc 828 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; ipc 830 lib/common/mainloop.c client->ipc = NULL; ipc 831 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 861 lib/common/mainloop.c pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 869 lib/common/mainloop.c CRM_CHECK((ipc != NULL) && (callbacks != NULL), return EINVAL); ipc 871 lib/common/mainloop.c ipc_name = pcmk__s(crm_ipc_name(ipc), "Pacemaker"); ipc 872 lib/common/mainloop.c rc = pcmk__connect_generic_ipc(ipc); ipc 878 lib/common/mainloop.c rc = pcmk__ipc_fd(ipc, &fd); ipc 882 lib/common/mainloop.c crm_ipc_close(ipc); ipc 889 lib/common/mainloop.c crm_ipc_close(ipc); ipc 893 lib/common/mainloop.c (*source)->ipc = ipc; ipc 919 lib/common/mainloop.c crm_ipc_t *ipc = crm_ipc_new(name, max_size); ipc 921 lib/common/mainloop.c int rc = pcmk__add_mainloop_ipc(ipc, priority, userdata, callbacks, ipc 929 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 950 lib/common/mainloop.c return client->ipc; ipc 35 lib/fencing/st_client.c crm_ipc_t *ipc; ipc 279 lib/fencing/st_client.c native->ipc = NULL; ipc 853 lib/fencing/st_client.c native->ipc = NULL; ipc 855 lib/fencing/st_client.c } else if (native->ipc) { ipc 857 lib/fencing/st_client.c crm_ipc_t *ipc = native->ipc; ipc 859 lib/fencing/st_client.c native->ipc = NULL; ipc 860 lib/fencing/st_client.c crm_ipc_close(ipc); ipc 861 lib/fencing/st_client.c crm_ipc_destroy(ipc); ipc 1115 lib/fencing/st_client.c native->ipc = crm_ipc_new("stonith-ng", 0); ipc 1116 lib/fencing/st_client.c if (native->ipc != NULL) { ipc 1117 lib/fencing/st_client.c rc = pcmk__connect_generic_ipc(native->ipc); ipc 1119 lib/fencing/st_client.c rc = pcmk__ipc_fd(native->ipc, stonith_fd); ipc 1126 lib/fencing/st_client.c crm_ipc_close(native->ipc); ipc 1127 lib/fencing/st_client.c crm_ipc_destroy(native->ipc); ipc 1128 lib/fencing/st_client.c native->ipc = NULL; ipc 1136 lib/fencing/st_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1139 lib/fencing/st_client.c if (native->ipc == NULL) { ipc 1148 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); ipc 1209 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, -1, NULL); ipc 1599 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, ipc 1653 lib/fencing/st_client.c if (!crm_ipc_connected(native->ipc)) { ipc 1673 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { ipc 1675 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 1676 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 1681 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 605 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 819 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); ipc 841 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); ipc 869 lib/lrmd/lrmd_client.c return crm_ipc_connected(native->ipc); ipc 1131 lib/lrmd/lrmd_client.c native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0); ipc 1132 lib/lrmd/lrmd_client.c if (native->ipc != NULL) { ipc 1133 lib/lrmd/lrmd_client.c rc = pcmk__connect_generic_ipc(native->ipc); ipc 1135 lib/lrmd/lrmd_client.c rc = pcmk__ipc_fd(native->ipc, fd); ipc 1144 lib/lrmd/lrmd_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1147 lib/lrmd/lrmd_client.c if (native->ipc == NULL) { ipc 1752 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1754 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1756 lib/lrmd/lrmd_client.c crm_ipc_t *ipc = native->ipc; ipc 1758 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1759 lib/lrmd/lrmd_client.c crm_ipc_close(ipc); ipc 1760 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 287 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); ipc 293 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); ipc 314 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 316 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); ipc 319 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 322 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name);