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);