ipc                57 include/crm/common/internal.h int pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata,
ipc                57 include/crm/lrmd_internal.h     crm_ipc_t *ipc;
ipc                35 lib/cib/cib_native.c     crm_ipc_t *ipc;
ipc                75 lib/cib/cib_native.c     native->ipc = NULL;
ipc               148 lib/cib/cib_native.c     native->ipc = NULL;
ipc               188 lib/cib/cib_native.c         native->ipc = crm_ipc_new(channel, 0);
ipc               190 lib/cib/cib_native.c         if (native->ipc && crm_ipc_connect(native->ipc)) {
ipc               191 lib/cib/cib_native.c             *async_fd = crm_ipc_get_fd(native->ipc);
ipc               193 lib/cib/cib_native.c         } else if (native->ipc) {
ipc               201 lib/cib/cib_native.c         native->ipc = mainloop_get_ipc_client(native->source);
ipc               204 lib/cib/cib_native.c     if (rc != pcmk_ok || native->ipc == NULL || crm_ipc_connected(native->ipc) == FALSE) {
ipc               218 lib/cib/cib_native.c         if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply) > 0) {
ipc               269 lib/cib/cib_native.c         native->ipc = NULL;
ipc               271 lib/cib/cib_native.c     } else if (native->ipc) {
ipc               273 lib/cib/cib_native.c         crm_ipc_t *ipc = native->ipc;
ipc               275 lib/cib/cib_native.c         native->ipc = NULL;
ipc               276 lib/cib/cib_native.c         crm_ipc_close(ipc);
ipc               277 lib/cib/cib_native.c         crm_ipc_destroy(ipc);
ipc               361 lib/cib/cib_native.c     rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, cib->call_timeout * 1000, &op_reply);
ipc               443 lib/cib/cib_native.c     if (crm_ipc_connected(native->ipc) == FALSE) {
ipc               479 lib/cib/cib_native.c         rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response,
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               430 lib/common/ipc_client.c     while (crm_ipc_ready(api->ipc) > 0) {
ipc               431 lib/common/ipc_client.c         if (crm_ipc_read(api->ipc) > 0) {
ipc               432 lib/common/ipc_client.c             dispatch_ipc_data(crm_ipc_buffer(api->ipc), api);
ipc               448 lib/common/ipc_client.c     rc = pcmk__add_mainloop_ipc(api->ipc, G_PRIORITY_DEFAULT, api,
ipc               467 lib/common/ipc_client.c     if (!crm_ipc_connect(api->ipc)) {
ipc               469 lib/common/ipc_client.c         crm_ipc_close(api->ipc);
ipc               495 lib/common/ipc_client.c     if (api->ipc == NULL) {
ipc               496 lib/common/ipc_client.c         api->ipc = crm_ipc_new(pcmk_ipc_name(api, false),
ipc               498 lib/common/ipc_client.c         if (api->ipc == NULL) {
ipc               504 lib/common/ipc_client.c     if (crm_ipc_connected(api->ipc)) {
ipc               527 lib/common/ipc_client.c             crm_ipc_close(api->ipc);
ipc               547 lib/common/ipc_client.c     if ((api == NULL) || (api->ipc == NULL)) {
ipc               557 lib/common/ipc_client.c                 api->ipc = NULL;
ipc               567 lib/common/ipc_client.c                 crm_ipc_t *ipc = api->ipc;
ipc               570 lib/common/ipc_client.c                 api->ipc = NULL;
ipc               575 lib/common/ipc_client.c                 crm_ipc_close(ipc);
ipc               576 lib/common/ipc_client.c                 crm_ipc_destroy(ipc);
ipc               625 lib/common/ipc_client.c     if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) {
ipc               639 lib/common/ipc_client.c     rc = crm_ipc_send(api->ipc, request, flags, 0, &reply);
ipc               654 lib/common/ipc_client.c             rc = crm_ipc_read(api->ipc);
ipc               664 lib/common/ipc_client.c             rc = dispatch_ipc_data(crm_ipc_buffer(api->ipc), api);
ipc               783 lib/common/ipc_client.c     qb_ipcc_connection_t *ipc;
ipc               855 lib/common/ipc_client.c     client->ipc = qb_ipcc_connect(client->server_name, client->buf_size);
ipc               857 lib/common/ipc_client.c     if (client->ipc == NULL) {
ipc               880 lib/common/ipc_client.c     if ((rv = pcmk__crm_ipc_is_authentic_process(client->ipc, client->pfd.fd, cl_uid, cl_gid,
ipc               905 lib/common/ipc_client.c     qb_ipcc_context_set(client->ipc, client);
ipc               907 lib/common/ipc_client.c     client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc);
ipc               920 lib/common/ipc_client.c         if (client->ipc) {
ipc               921 lib/common/ipc_client.c             qb_ipcc_connection_t *ipc = client->ipc;
ipc               923 lib/common/ipc_client.c             client->ipc = NULL;
ipc               924 lib/common/ipc_client.c             qb_ipcc_disconnect(ipc);
ipc               933 lib/common/ipc_client.c         if (client->ipc && qb_ipcc_is_connected(client->ipc)) {
ipc               960 lib/common/ipc_client.c     if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) {
ipc               978 lib/common/ipc_client.c     } else if (client->ipc == NULL) {
ipc               987 lib/common/ipc_client.c     rc = qb_ipcc_is_connected(client->ipc);
ipc              1071 lib/common/ipc_client.c     CRM_ASSERT(client->ipc != NULL);
ipc              1075 lib/common/ipc_client.c     client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer,
ipc              1155 lib/common/ipc_client.c         *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000);
ipc              1237 lib/common/ipc_client.c         qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout);
ipc              1292 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv(client->ipc, iov, 2);
ipc              1320 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer,
ipc               707 lib/common/mainloop.c     crm_ipc_t *ipc;
ipc               735 lib/common/mainloop.c         if (client->ipc) {
ipc               740 lib/common/mainloop.c                 read_rc = crm_ipc_read(client->ipc);
ipc               746 lib/common/mainloop.c                     const char *buffer = crm_ipc_buffer(client->ipc);
ipc               771 lib/common/mainloop.c     if (client->ipc && crm_ipc_connected(client->ipc) == FALSE) {
ipc               829 lib/common/mainloop.c     if (client->ipc) {
ipc               830 lib/common/mainloop.c         crm_ipc_close(client->ipc);
ipc               840 lib/common/mainloop.c     if (client->ipc) {
ipc               841 lib/common/mainloop.c         crm_ipc_t *ipc = client->ipc;
ipc               843 lib/common/mainloop.c         client->ipc = NULL;
ipc               844 lib/common/mainloop.c         crm_ipc_destroy(ipc);
ipc               874 lib/common/mainloop.c pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata,
ipc               878 lib/common/mainloop.c     CRM_CHECK((ipc != NULL) && (callbacks != NULL), return EINVAL);
ipc               880 lib/common/mainloop.c     if (!crm_ipc_connect(ipc)) {
ipc               882 lib/common/mainloop.c         crm_debug("Connection to %s failed: %d", crm_ipc_name(ipc), errno);
ipc               885 lib/common/mainloop.c     *source = mainloop_add_fd(crm_ipc_name(ipc), priority, crm_ipc_get_fd(ipc),
ipc               890 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               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              1638 lib/fencing/st_client.c     if (crm_ipc_connected(native->ipc) == FALSE) {
ipc              1658 lib/fencing/st_client.c     while (crm_ipc_ready(private->ipc)) {
ipc              1660 lib/fencing/st_client.c         if (crm_ipc_read(private->ipc) > 0) {
ipc              1661 lib/fencing/st_client.c             const char *msg = crm_ipc_buffer(private->ipc);
ipc              1666 lib/fencing/st_client.c         if (crm_ipc_connected(private->ipc) == FALSE) {
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              1031 lib/lrmd/lrmd_client.c         native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0);
ipc              1032 lib/lrmd/lrmd_client.c         if (native->ipc && crm_ipc_connect(native->ipc)) {
ipc              1033 lib/lrmd/lrmd_client.c             *fd = crm_ipc_get_fd(native->ipc);
ipc              1034 lib/lrmd/lrmd_client.c         } else if (native->ipc) {
ipc              1040 lib/lrmd/lrmd_client.c         native->ipc = mainloop_get_ipc_client(native->source);
ipc              1043 lib/lrmd/lrmd_client.c     if (native->ipc == NULL) {
ipc              1598 lib/lrmd/lrmd_client.c         native->ipc = NULL;
ipc              1600 lib/lrmd/lrmd_client.c     } else if (native->ipc) {
ipc              1602 lib/lrmd/lrmd_client.c         crm_ipc_t *ipc = native->ipc;
ipc              1604 lib/lrmd/lrmd_client.c         native->ipc = NULL;
ipc              1605 lib/lrmd/lrmd_client.c         crm_ipc_close(ipc);
ipc              1606 lib/lrmd/lrmd_client.c         crm_ipc_destroy(ipc);
ipc               132 lib/lrmd/proxy_common.c     flags = crm_ipc_buffer_flags(proxy->ipc);
ipc               155 lib/lrmd/proxy_common.c     proxy->ipc = NULL;
ipc               190 lib/lrmd/proxy_common.c         proxy->ipc = mainloop_get_ipc_client(proxy->source);
ipc               243 lib/lrmd/proxy_common.c         if (crm_ipc_connected(proxy->ipc) == FALSE) {
ipc               268 lib/lrmd/proxy_common.c             rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL);
ipc               274 lib/lrmd/proxy_common.c                          op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc);
ipc               285 lib/lrmd/proxy_common.c                           op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name);
ipc               295 lib/lrmd/proxy_common.c                       op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name);
ipc               297 lib/lrmd/proxy_common.c             rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply);
ipc               300 lib/lrmd/proxy_common.c                          op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc);
ipc               303 lib/lrmd/proxy_common.c                           op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name);