ipc 32 include/crm/common/attrd_internal.h int pcmk__node_attr_request(crm_ipc_t * ipc, char command, const char *host, ipc 38 include/crm/common/attrd_internal.h int pcmk__node_attr_request_clear(crm_ipc_t *ipc, const char *host, ipc 111 include/crm/common/internal.h int pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 51 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 52 lib/common/attrd_client.c send_attrd_op(crm_ipc_t *ipc, xmlNode *attrd_op) ipc 61 lib/common/attrd_client.c if (ipc == NULL && local_ipc == NULL) { ipc 67 lib/common/attrd_client.c if (ipc == NULL) { ipc 68 lib/common/attrd_client.c ipc = local_ipc; ipc 74 lib/common/attrd_client.c connected = crm_ipc_connect(ipc); ipc 78 lib/common/attrd_client.c rc = crm_ipc_send(ipc, attrd_op, flags, 0, NULL); ipc 83 lib/common/attrd_client.c if (ipc != local_ipc) { ipc 94 lib/common/attrd_client.c crm_ipc_close(ipc); ipc 133 lib/common/attrd_client.c pcmk__node_attr_request(crm_ipc_t *ipc, char command, const char *host, ipc 209 lib/common/attrd_client.c rc = send_attrd_op(ipc, update); ipc 239 lib/common/attrd_client.c pcmk__node_attr_request_clear(crm_ipc_t *ipc, const char *host, ipc 257 lib/common/attrd_client.c rc = send_attrd_op(ipc, clear_op); ipc 230 lib/common/crmcommon_private.h crm_ipc_t *ipc; // IPC connection ipc 101 lib/common/ipc_client.c (*api)->ipc = crm_ipc_new(pcmk_ipc_name(*api, false), ipc 103 lib/common/ipc_client.c if ((*api)->ipc == NULL) { ipc 181 lib/common/ipc_client.c api->ipc = NULL; ipc 209 lib/common/ipc_client.c if (api->ipc != NULL) { ipc 283 lib/common/ipc_client.c return (api != NULL) && crm_ipc_connected(api->ipc); ipc 369 lib/common/ipc_client.c pollfd.fd = crm_ipc_get_fd(api->ipc); ipc 396 lib/common/ipc_client.c while (crm_ipc_ready(api->ipc) > 0) { ipc 397 lib/common/ipc_client.c if (crm_ipc_read(api->ipc) > 0) { ipc 398 lib/common/ipc_client.c dispatch_ipc_data(crm_ipc_buffer(api->ipc), 0, api); ipc 414 lib/common/ipc_client.c rc = pcmk__add_mainloop_ipc(api->ipc, G_PRIORITY_DEFAULT, api, ipc 433 lib/common/ipc_client.c if (!crm_ipc_connect(api->ipc)) { ipc 435 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 461 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 462 lib/common/ipc_client.c api->ipc = crm_ipc_new(pcmk_ipc_name(api, false), ipc 464 lib/common/ipc_client.c if (api->ipc == NULL) { ipc 470 lib/common/ipc_client.c if (crm_ipc_connected(api->ipc)) { ipc 493 lib/common/ipc_client.c crm_ipc_close(api->ipc); ipc 513 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL)) { ipc 523 lib/common/ipc_client.c api->ipc = NULL; ipc 533 lib/common/ipc_client.c crm_ipc_t *ipc = api->ipc; ipc 536 lib/common/ipc_client.c api->ipc = NULL; ipc 541 lib/common/ipc_client.c crm_ipc_destroy(ipc); ipc 590 lib/common/ipc_client.c if ((api == NULL) || (api->ipc == NULL) || (request == NULL)) { ipc 604 lib/common/ipc_client.c rc = crm_ipc_send(api->ipc, request, flags, 0, &reply); ipc 728 lib/common/ipc_client.c qb_ipcc_connection_t *ipc; ipc 800 lib/common/ipc_client.c client->ipc = qb_ipcc_connect(client->server_name, client->buf_size); ipc 802 lib/common/ipc_client.c if (client->ipc == NULL) { ipc 825 lib/common/ipc_client.c if ((rv = pcmk__crm_ipc_is_authentic_process(client->ipc, client->pfd.fd, cl_uid, cl_gid, ipc 850 lib/common/ipc_client.c qb_ipcc_context_set(client->ipc, client); ipc 852 lib/common/ipc_client.c client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc); ipc 865 lib/common/ipc_client.c if (client->ipc) { ipc 866 lib/common/ipc_client.c qb_ipcc_connection_t *ipc = client->ipc; ipc 868 lib/common/ipc_client.c client->ipc = NULL; ipc 869 lib/common/ipc_client.c qb_ipcc_disconnect(ipc); ipc 878 lib/common/ipc_client.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { ipc 905 lib/common/ipc_client.c if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) { ipc 923 lib/common/ipc_client.c } else if (client->ipc == NULL) { ipc 932 lib/common/ipc_client.c rc = qb_ipcc_is_connected(client->ipc); ipc 1016 lib/common/ipc_client.c CRM_ASSERT(client->ipc != NULL); ipc 1020 lib/common/ipc_client.c client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer, ipc 1096 lib/common/ipc_client.c *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000); ipc 1178 lib/common/ipc_client.c qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout); ipc 1233 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv(client->ipc, iov, 2); ipc 1261 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, ipc 726 lib/common/mainloop.c crm_ipc_t *ipc; ipc 754 lib/common/mainloop.c if (client->ipc) { ipc 759 lib/common/mainloop.c read_rc = crm_ipc_read(client->ipc); ipc 765 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); ipc 790 lib/common/mainloop.c if (client->ipc && crm_ipc_connected(client->ipc) == FALSE) { ipc 848 lib/common/mainloop.c if (client->ipc) { ipc 849 lib/common/mainloop.c crm_ipc_close(client->ipc); ipc 859 lib/common/mainloop.c if (client->ipc) { ipc 860 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; ipc 862 lib/common/mainloop.c client->ipc = NULL; ipc 863 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 893 lib/common/mainloop.c pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 897 lib/common/mainloop.c CRM_CHECK((ipc != NULL) && (callbacks != NULL), return EINVAL); ipc 899 lib/common/mainloop.c if (!crm_ipc_connect(ipc)) { ipc 901 lib/common/mainloop.c crm_debug("Connection to %s failed: %d", crm_ipc_name(ipc), errno); ipc 904 lib/common/mainloop.c *source = mainloop_add_fd(crm_ipc_name(ipc), priority, crm_ipc_get_fd(ipc), ipc 909 lib/common/mainloop.c crm_ipc_close(ipc); ipc 912 lib/common/mainloop.c (*source)->ipc = ipc; ipc 938 lib/common/mainloop.c crm_ipc_t *ipc = crm_ipc_new(name, max_size); ipc 940 lib/common/mainloop.c int rc = pcmk__add_mainloop_ipc(ipc, priority, userdata, callbacks, ipc 948 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 969 lib/common/mainloop.c return client->ipc; ipc 67 lib/fencing/st_client.c crm_ipc_t *ipc; ipc 323 lib/fencing/st_client.c native->ipc = NULL; ipc 1315 lib/fencing/st_client.c native->ipc = NULL; ipc 1317 lib/fencing/st_client.c } else if (native->ipc) { ipc 1319 lib/fencing/st_client.c crm_ipc_t *ipc = native->ipc; ipc 1321 lib/fencing/st_client.c native->ipc = NULL; ipc 1322 lib/fencing/st_client.c crm_ipc_close(ipc); ipc 1323 lib/fencing/st_client.c crm_ipc_destroy(ipc); ipc 1541 lib/fencing/st_client.c native->ipc = crm_ipc_new("stonith-ng", 0); ipc 1543 lib/fencing/st_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 1544 lib/fencing/st_client.c *stonith_fd = crm_ipc_get_fd(native->ipc); ipc 1545 lib/fencing/st_client.c } else if (native->ipc) { ipc 1546 lib/fencing/st_client.c crm_ipc_close(native->ipc); ipc 1547 lib/fencing/st_client.c crm_ipc_destroy(native->ipc); ipc 1548 lib/fencing/st_client.c native->ipc = NULL; ipc 1555 lib/fencing/st_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1558 lib/fencing/st_client.c if (native->ipc == NULL) { ipc 1567 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); ipc 1631 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, -1, NULL); ipc 1955 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, ipc 2006 lib/fencing/st_client.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 2026 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { ipc 2028 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 2029 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 2034 lib/fencing/st_client.c if (crm_ipc_connected(private->ipc) == FALSE) { ipc 77 lib/lrmd/lrmd_client.c crm_ipc_t *ipc; ipc 450 lib/lrmd/lrmd_client.c return crm_ipc_ready(native->ipc); ipc 487 lib/lrmd/lrmd_client.c while (crm_ipc_ready(private->ipc)) { ipc 488 lib/lrmd/lrmd_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 489 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 547 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 759 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); ipc 783 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); ipc 813 lib/lrmd/lrmd_client.c return crm_ipc_connected(native->ipc); ipc 1028 lib/lrmd/lrmd_client.c native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0); ipc 1029 lib/lrmd/lrmd_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 1030 lib/lrmd/lrmd_client.c *fd = crm_ipc_get_fd(native->ipc); ipc 1031 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1037 lib/lrmd/lrmd_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1040 lib/lrmd/lrmd_client.c if (native->ipc == NULL) { ipc 1595 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1597 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1599 lib/lrmd/lrmd_client.c crm_ipc_t *ipc = native->ipc; ipc 1601 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1602 lib/lrmd/lrmd_client.c crm_ipc_close(ipc); ipc 1603 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); ipc 299 tools/attrd_updater.c crm_ipc_t *ipc; ipc 315 tools/attrd_updater.c ipc = crm_ipc_new(T_ATTRD, 0); ipc 316 tools/attrd_updater.c if (crm_ipc_connect(ipc) == FALSE) { ipc 320 tools/attrd_updater.c rc = crm_ipc_send(ipc, query, crm_ipc_client_response, 0, reply); ipc 324 tools/attrd_updater.c crm_ipc_close(ipc); ipc 326 tools/attrd_updater.c crm_ipc_destroy(ipc);