ipc                60 include/crm/common/internal.h int pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata,
ipc                59 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               166 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               298 lib/cib/cib_native.c         native->ipc = crm_ipc_new(channel, 0);
ipc               300 lib/cib/cib_native.c         if (native->ipc && crm_ipc_connect(native->ipc)) {
ipc               301 lib/cib/cib_native.c             *async_fd = crm_ipc_get_fd(native->ipc);
ipc               303 lib/cib/cib_native.c         } else if (native->ipc) {
ipc               311 lib/cib/cib_native.c         native->ipc = mainloop_get_ipc_client(native->source);
ipc               314 lib/cib/cib_native.c     if (rc != pcmk_ok || native->ipc == NULL || !crm_ipc_connected(native->ipc)) {
ipc               328 lib/cib/cib_native.c         if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply) > 0) {
ipc               403 lib/cib/cib_native.c         rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response,
ipc               485 lib/cib/cib_native.c     native->ipc = NULL;
ipc               207 lib/common/crmcommon_private.h     crm_ipc_t *ipc;                       // IPC connection
ipc               103 lib/common/ipc_client.c     (*api)->ipc = crm_ipc_new(pcmk_ipc_name(*api, false),
ipc               105 lib/common/ipc_client.c     if ((*api)->ipc == NULL) {
ipc               183 lib/common/ipc_client.c     api->ipc = NULL;
ipc               211 lib/common/ipc_client.c     if (api->ipc != NULL) {
ipc               285 lib/common/ipc_client.c     return (api != NULL) && crm_ipc_connected(api->ipc);
ipc               403 lib/common/ipc_client.c     pollfd.fd = crm_ipc_get_fd(api->ipc);
ipc               433 lib/common/ipc_client.c     while (crm_ipc_ready(api->ipc) > 0) {
ipc               434 lib/common/ipc_client.c         if (crm_ipc_read(api->ipc) > 0) {
ipc               435 lib/common/ipc_client.c             dispatch_ipc_data(crm_ipc_buffer(api->ipc), api);
ipc               451 lib/common/ipc_client.c     rc = pcmk__add_mainloop_ipc(api->ipc, G_PRIORITY_DEFAULT, api,
ipc               470 lib/common/ipc_client.c     if (!crm_ipc_connect(api->ipc)) {
ipc               472 lib/common/ipc_client.c         crm_ipc_close(api->ipc);
ipc               499 lib/common/ipc_client.c     if (api->ipc == NULL) {
ipc               500 lib/common/ipc_client.c         api->ipc = crm_ipc_new(pcmk_ipc_name(api, false),
ipc               502 lib/common/ipc_client.c         if (api->ipc == NULL) {
ipc               508 lib/common/ipc_client.c     if (crm_ipc_connected(api->ipc)) {
ipc               547 lib/common/ipc_client.c             crm_ipc_close(api->ipc);
ipc               567 lib/common/ipc_client.c     if ((api == NULL) || (api->ipc == NULL)) {
ipc               577 lib/common/ipc_client.c                 api->ipc = NULL;
ipc               587 lib/common/ipc_client.c                 crm_ipc_t *ipc = api->ipc;
ipc               590 lib/common/ipc_client.c                 api->ipc = NULL;
ipc               595 lib/common/ipc_client.c                 crm_ipc_close(ipc);
ipc               596 lib/common/ipc_client.c                 crm_ipc_destroy(ipc);
ipc               645 lib/common/ipc_client.c     if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) {
ipc               659 lib/common/ipc_client.c     rc = crm_ipc_send(api->ipc, request, flags, 0, &reply);
ipc               674 lib/common/ipc_client.c             rc = crm_ipc_read(api->ipc);
ipc               684 lib/common/ipc_client.c             rc = dispatch_ipc_data(crm_ipc_buffer(api->ipc), api);
ipc               803 lib/common/ipc_client.c     qb_ipcc_connection_t *ipc;
ipc               880 lib/common/ipc_client.c     client->ipc = qb_ipcc_connect(client->server_name, client->buf_size);
ipc               882 lib/common/ipc_client.c     if (client->ipc == NULL) {
ipc               905 lib/common/ipc_client.c     if ((rv = pcmk__crm_ipc_is_authentic_process(client->ipc, client->pfd.fd, cl_uid, cl_gid,
ipc               930 lib/common/ipc_client.c     qb_ipcc_context_set(client->ipc, client);
ipc               932 lib/common/ipc_client.c     client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc);
ipc               945 lib/common/ipc_client.c         if (client->ipc) {
ipc               946 lib/common/ipc_client.c             qb_ipcc_connection_t *ipc = client->ipc;
ipc               948 lib/common/ipc_client.c             client->ipc = NULL;
ipc               949 lib/common/ipc_client.c             qb_ipcc_disconnect(ipc);
ipc               958 lib/common/ipc_client.c         if (client->ipc && qb_ipcc_is_connected(client->ipc)) {
ipc               985 lib/common/ipc_client.c     if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) {
ipc              1003 lib/common/ipc_client.c     } else if (client->ipc == NULL) {
ipc              1012 lib/common/ipc_client.c     rc = qb_ipcc_is_connected(client->ipc);
ipc              1096 lib/common/ipc_client.c     CRM_ASSERT(client->ipc != NULL);
ipc              1100 lib/common/ipc_client.c     client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer,
ipc              1180 lib/common/ipc_client.c         *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000);
ipc              1262 lib/common/ipc_client.c         qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout);
ipc              1317 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv(client->ipc, iov, 2);
ipc              1345 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer,
ipc               706 lib/common/mainloop.c     crm_ipc_t *ipc;
ipc               734 lib/common/mainloop.c         if (client->ipc) {
ipc               739 lib/common/mainloop.c                 read_rc = crm_ipc_read(client->ipc);
ipc               745 lib/common/mainloop.c                     const char *buffer = crm_ipc_buffer(client->ipc);
ipc               770 lib/common/mainloop.c     if (client->ipc && !crm_ipc_connected(client->ipc)) {
ipc               828 lib/common/mainloop.c     if (client->ipc) {
ipc               829 lib/common/mainloop.c         crm_ipc_close(client->ipc);
ipc               839 lib/common/mainloop.c     if (client->ipc) {
ipc               840 lib/common/mainloop.c         crm_ipc_t *ipc = client->ipc;
ipc               842 lib/common/mainloop.c         client->ipc = NULL;
ipc               843 lib/common/mainloop.c         crm_ipc_destroy(ipc);
ipc               873 lib/common/mainloop.c pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata,
ipc               877 lib/common/mainloop.c     CRM_CHECK((ipc != NULL) && (callbacks != NULL), return EINVAL);
ipc               879 lib/common/mainloop.c     if (!crm_ipc_connect(ipc)) {
ipc               881 lib/common/mainloop.c         crm_debug("Connection to %s failed: %d", crm_ipc_name(ipc), errno);
ipc               884 lib/common/mainloop.c     *source = mainloop_add_fd(crm_ipc_name(ipc), priority, crm_ipc_get_fd(ipc),
ipc               889 lib/common/mainloop.c         crm_ipc_close(ipc);
ipc               892 lib/common/mainloop.c     (*source)->ipc = ipc;
ipc               918 lib/common/mainloop.c     crm_ipc_t *ipc = crm_ipc_new(name, max_size);
ipc               920 lib/common/mainloop.c     int rc = pcmk__add_mainloop_ipc(ipc, priority, userdata, callbacks,
ipc               928 lib/common/mainloop.c         crm_ipc_destroy(ipc);
ipc               949 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               848 lib/fencing/st_client.c         native->ipc = NULL;
ipc               850 lib/fencing/st_client.c     } else if (native->ipc) {
ipc               852 lib/fencing/st_client.c         crm_ipc_t *ipc = native->ipc;
ipc               854 lib/fencing/st_client.c         native->ipc = NULL;
ipc               855 lib/fencing/st_client.c         crm_ipc_close(ipc);
ipc               856 lib/fencing/st_client.c         crm_ipc_destroy(ipc);
ipc              1107 lib/fencing/st_client.c         native->ipc = crm_ipc_new("stonith-ng", 0);
ipc              1109 lib/fencing/st_client.c         if (native->ipc && crm_ipc_connect(native->ipc)) {
ipc              1110 lib/fencing/st_client.c             *stonith_fd = crm_ipc_get_fd(native->ipc);
ipc              1111 lib/fencing/st_client.c         } else if (native->ipc) {
ipc              1112 lib/fencing/st_client.c             crm_ipc_close(native->ipc);
ipc              1113 lib/fencing/st_client.c             crm_ipc_destroy(native->ipc);
ipc              1114 lib/fencing/st_client.c             native->ipc = NULL;
ipc              1121 lib/fencing/st_client.c         native->ipc = mainloop_get_ipc_client(native->source);
ipc              1124 lib/fencing/st_client.c     if (native->ipc == NULL) {
ipc              1133 lib/fencing/st_client.c         rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply);
ipc              1194 lib/fencing/st_client.c         rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, -1, NULL);
ipc              1585 lib/fencing/st_client.c         rc = crm_ipc_send(native->ipc, op_msg, ipc_flags,
ipc              1637 lib/fencing/st_client.c     if (!crm_ipc_connected(native->ipc)) {
ipc              1657 lib/fencing/st_client.c     while (crm_ipc_ready(private->ipc)) {
ipc              1659 lib/fencing/st_client.c         if (crm_ipc_read(private->ipc) > 0) {
ipc              1660 lib/fencing/st_client.c             const char *msg = crm_ipc_buffer(private->ipc);
ipc              1665 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               550 lib/lrmd/lrmd_client.c     native->ipc = NULL;
ipc               762 lib/lrmd/lrmd_client.c             rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply);
ipc               786 lib/lrmd/lrmd_client.c             rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL);
ipc               816 lib/lrmd/lrmd_client.c             return crm_ipc_connected(native->ipc);
ipc              1040 lib/lrmd/lrmd_client.c         native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0);
ipc              1041 lib/lrmd/lrmd_client.c         if (native->ipc && crm_ipc_connect(native->ipc)) {
ipc              1042 lib/lrmd/lrmd_client.c             *fd = crm_ipc_get_fd(native->ipc);
ipc              1043 lib/lrmd/lrmd_client.c         } else if (native->ipc) {
ipc              1049 lib/lrmd/lrmd_client.c         native->ipc = mainloop_get_ipc_client(native->source);
ipc              1052 lib/lrmd/lrmd_client.c     if (native->ipc == NULL) {
ipc              1607 lib/lrmd/lrmd_client.c         native->ipc = NULL;
ipc              1609 lib/lrmd/lrmd_client.c     } else if (native->ipc) {
ipc              1611 lib/lrmd/lrmd_client.c         crm_ipc_t *ipc = native->ipc;
ipc              1613 lib/lrmd/lrmd_client.c         native->ipc = NULL;
ipc              1614 lib/lrmd/lrmd_client.c         crm_ipc_close(ipc);
ipc              1615 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);