ipc 59 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 167 lib/cib/cib_native.c if (!crm_ipc_connected(native->ipc)) { ipc 228 lib/cib/cib_native.c native->ipc = NULL; ipc 249 lib/cib/cib_native.c native->ipc = NULL; ipc 251 lib/cib/cib_native.c } else if (native->ipc) { ipc 253 lib/cib/cib_native.c crm_ipc_t *ipc = native->ipc; ipc 255 lib/cib/cib_native.c native->ipc = NULL; ipc 256 lib/cib/cib_native.c crm_ipc_close(ipc); ipc 257 lib/cib/cib_native.c crm_ipc_destroy(ipc); ipc 302 lib/cib/cib_native.c native->ipc = crm_ipc_new(channel, 0); ipc 303 lib/cib/cib_native.c if (native->ipc != NULL) { ipc 304 lib/cib/cib_native.c rc = pcmk__connect_generic_ipc(native->ipc); ipc 306 lib/cib/cib_native.c rc = pcmk__ipc_fd(native->ipc, async_fd); ipc 319 lib/cib/cib_native.c native->ipc = mainloop_get_ipc_client(native->source); ipc 322 lib/cib/cib_native.c if (rc != pcmk_ok || native->ipc == NULL || !crm_ipc_connected(native->ipc)) { ipc 335 lib/cib/cib_native.c if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, ipc 412 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, ipc 494 lib/cib/cib_native.c native->ipc = NULL; ipc 261 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 833 lib/common/ipc_client.c qb_ipcc_connection_t *ipc; ipc 896 lib/common/ipc_client.c pcmk__connect_generic_ipc(crm_ipc_t *ipc) ipc 905 lib/common/ipc_client.c if (ipc == NULL) { ipc 909 lib/common/ipc_client.c ipc->need_reply = FALSE; ipc 910 lib/common/ipc_client.c ipc->ipc = qb_ipcc_connect(ipc->server_name, ipc->buf_size); ipc 911 lib/common/ipc_client.c if (ipc->ipc == NULL) { ipc 915 lib/common/ipc_client.c rc = qb_ipcc_fd_get(ipc->ipc, &ipc->pfd.fd); ipc 917 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 924 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 928 lib/common/ipc_client.c rc = is_ipc_provider_expected(ipc->ipc, ipc->pfd.fd, cl_uid, cl_gid, ipc 934 lib/common/ipc_client.c ipc->server_name, ipc 939 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 943 lib/common/ipc_client.c ipc->max_buf_size = qb_ipcc_get_buffer_size(ipc->ipc); ipc 944 lib/common/ipc_client.c if (ipc->max_buf_size > ipc->buf_size) { ipc 945 lib/common/ipc_client.c free(ipc->buffer); ipc 946 lib/common/ipc_client.c ipc->buffer = calloc(ipc->max_buf_size, sizeof(char)); ipc 947 lib/common/ipc_client.c if (ipc->buffer == NULL) { ipc 949 lib/common/ipc_client.c crm_ipc_close(ipc); ipc 952 lib/common/ipc_client.c ipc->buf_size = ipc->max_buf_size; ipc 975 lib/common/ipc_client.c if ((client != NULL) && (client->ipc == NULL)) { ipc 996 lib/common/ipc_client.c if (client->ipc) { ipc 997 lib/common/ipc_client.c qb_ipcc_connection_t *ipc = client->ipc; ipc 999 lib/common/ipc_client.c client->ipc = NULL; ipc 1000 lib/common/ipc_client.c qb_ipcc_disconnect(ipc); ipc 1009 lib/common/ipc_client.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { ipc 1041 lib/common/ipc_client.c pcmk__ipc_fd(crm_ipc_t *ipc, int *fd) ipc 1043 lib/common/ipc_client.c if ((ipc == NULL) || (fd == NULL)) { ipc 1046 lib/common/ipc_client.c if ((ipc->ipc == NULL) || (ipc->pfd.fd < 0)) { ipc 1049 lib/common/ipc_client.c *fd = ipc->pfd.fd; ipc 1076 lib/common/ipc_client.c } else if (client->ipc == NULL) { ipc 1085 lib/common/ipc_client.c rc = qb_ipcc_is_connected(client->ipc); ipc 1162 lib/common/ipc_client.c pcmk__assert((client != NULL) && (client->ipc != NULL) ipc 1166 lib/common/ipc_client.c client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer, ipc 1246 lib/common/ipc_client.c *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000); ipc 1328 lib/common/ipc_client.c qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout); ipc 1383 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv(client->ipc, iov, 2); ipc 1411 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, ipc 696 lib/common/mainloop.c crm_ipc_t *ipc; ipc 724 lib/common/mainloop.c if (client->ipc) { ipc 729 lib/common/mainloop.c read_rc = crm_ipc_read(client->ipc); ipc 735 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); ipc 760 lib/common/mainloop.c if (client->ipc && !crm_ipc_connected(client->ipc)) { ipc 818 lib/common/mainloop.c if (client->ipc) { ipc 819 lib/common/mainloop.c crm_ipc_close(client->ipc); ipc 829 lib/common/mainloop.c if (client->ipc) { ipc 830 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; ipc 832 lib/common/mainloop.c client->ipc = NULL; ipc 833 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 863 lib/common/mainloop.c pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 871 lib/common/mainloop.c CRM_CHECK((ipc != NULL) && (callbacks != NULL), return EINVAL); ipc 873 lib/common/mainloop.c ipc_name = pcmk__s(crm_ipc_name(ipc), "Pacemaker"); ipc 874 lib/common/mainloop.c rc = pcmk__connect_generic_ipc(ipc); ipc 880 lib/common/mainloop.c rc = pcmk__ipc_fd(ipc, &fd); ipc 884 lib/common/mainloop.c crm_ipc_close(ipc); ipc 891 lib/common/mainloop.c crm_ipc_close(ipc); ipc 895 lib/common/mainloop.c (*source)->ipc = ipc; ipc 921 lib/common/mainloop.c crm_ipc_t *ipc = crm_ipc_new(name, max_size); ipc 923 lib/common/mainloop.c int rc = pcmk__add_mainloop_ipc(ipc, priority, userdata, callbacks, ipc 931 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 952 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 854 lib/fencing/st_client.c native->ipc = NULL; ipc 856 lib/fencing/st_client.c } else if (native->ipc) { ipc 858 lib/fencing/st_client.c crm_ipc_t *ipc = native->ipc; ipc 860 lib/fencing/st_client.c native->ipc = NULL; ipc 861 lib/fencing/st_client.c crm_ipc_close(ipc); ipc 862 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 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 1675 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { ipc 1677 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 1678 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 1683 lib/fencing/st_client.c if (!crm_ipc_connected(private->ipc)) { ipc 81 lib/lrmd/lrmd_client.c crm_ipc_t *ipc; ipc 498 lib/lrmd/lrmd_client.c return crm_ipc_ready(native->ipc); ipc 535 lib/lrmd/lrmd_client.c while (crm_ipc_ready(private->ipc)) { ipc 536 lib/lrmd/lrmd_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 537 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 608 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 826 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); ipc 850 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); ipc 880 lib/lrmd/lrmd_client.c return crm_ipc_connected(native->ipc); ipc 1111 lib/lrmd/lrmd_client.c native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0); ipc 1112 lib/lrmd/lrmd_client.c if (native->ipc != NULL) { ipc 1113 lib/lrmd/lrmd_client.c rc = pcmk__connect_generic_ipc(native->ipc); ipc 1115 lib/lrmd/lrmd_client.c rc = pcmk__ipc_fd(native->ipc, fd); ipc 1124 lib/lrmd/lrmd_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1127 lib/lrmd/lrmd_client.c if (native->ipc == NULL) { ipc 1788 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1790 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1792 lib/lrmd/lrmd_client.c crm_ipc_t *ipc = native->ipc; ipc 1794 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1795 lib/lrmd/lrmd_client.c crm_ipc_close(ipc); ipc 1796 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);