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 108 include/crm/common/internal.h int pcmk__add_mainloop_ipc(crm_ipc_t *ipc, int priority, void *userdata, ipc 44 include/crm/lrmd_internal.h crm_ipc_t *ipc; ipc 35 lib/cib/cib_native.c crm_ipc_t *ipc; ipc 66 lib/cib/cib_native.c native->ipc = NULL; ipc 139 lib/cib/cib_native.c native->ipc = NULL; ipc 179 lib/cib/cib_native.c native->ipc = crm_ipc_new(channel, 0); ipc 181 lib/cib/cib_native.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 182 lib/cib/cib_native.c *async_fd = crm_ipc_get_fd(native->ipc); ipc 184 lib/cib/cib_native.c } else if (native->ipc) { ipc 192 lib/cib/cib_native.c native->ipc = mainloop_get_ipc_client(native->source); ipc 195 lib/cib/cib_native.c if (rc != pcmk_ok || native->ipc == NULL || crm_ipc_connected(native->ipc) == FALSE) { ipc 209 lib/cib/cib_native.c if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply) > 0) { ipc 260 lib/cib/cib_native.c native->ipc = NULL; ipc 262 lib/cib/cib_native.c } else if (native->ipc) { ipc 264 lib/cib/cib_native.c crm_ipc_t *ipc = native->ipc; ipc 266 lib/cib/cib_native.c native->ipc = NULL; ipc 267 lib/cib/cib_native.c crm_ipc_close(ipc); ipc 268 lib/cib/cib_native.c crm_ipc_destroy(ipc); ipc 352 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, cib->call_timeout * 1000, &op_reply); ipc 434 lib/cib/cib_native.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 470 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 66 lib/fencing/st_client.c crm_ipc_t *ipc; ipc 262 lib/fencing/st_client.c native->ipc = NULL; ipc 1250 lib/fencing/st_client.c native->ipc = NULL; ipc 1252 lib/fencing/st_client.c } else if (native->ipc) { ipc 1254 lib/fencing/st_client.c crm_ipc_t *ipc = native->ipc; ipc 1256 lib/fencing/st_client.c native->ipc = NULL; ipc 1257 lib/fencing/st_client.c crm_ipc_close(ipc); ipc 1258 lib/fencing/st_client.c crm_ipc_destroy(ipc); ipc 1476 lib/fencing/st_client.c native->ipc = crm_ipc_new("stonith-ng", 0); ipc 1478 lib/fencing/st_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 1479 lib/fencing/st_client.c *stonith_fd = crm_ipc_get_fd(native->ipc); ipc 1480 lib/fencing/st_client.c } else if (native->ipc) { ipc 1481 lib/fencing/st_client.c crm_ipc_close(native->ipc); ipc 1482 lib/fencing/st_client.c crm_ipc_destroy(native->ipc); ipc 1483 lib/fencing/st_client.c native->ipc = NULL; ipc 1490 lib/fencing/st_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1493 lib/fencing/st_client.c if (native->ipc == NULL) { ipc 1502 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); ipc 1566 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, -1, NULL); ipc 1890 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, ipc 1941 lib/fencing/st_client.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 1961 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { ipc 1963 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 1964 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 1969 lib/fencing/st_client.c if (crm_ipc_connected(private->ipc) == FALSE) { ipc 75 lib/lrmd/lrmd_client.c crm_ipc_t *ipc; ipc 447 lib/lrmd/lrmd_client.c return crm_ipc_ready(native->ipc); ipc 484 lib/lrmd/lrmd_client.c while (crm_ipc_ready(private->ipc)) { ipc 485 lib/lrmd/lrmd_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 486 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 544 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 756 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); ipc 780 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); ipc 810 lib/lrmd/lrmd_client.c return crm_ipc_connected(native->ipc); ipc 1023 lib/lrmd/lrmd_client.c native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0); ipc 1024 lib/lrmd/lrmd_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 1025 lib/lrmd/lrmd_client.c *fd = crm_ipc_get_fd(native->ipc); ipc 1026 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1032 lib/lrmd/lrmd_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1035 lib/lrmd/lrmd_client.c if (native->ipc == NULL) { ipc 1587 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1589 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1591 lib/lrmd/lrmd_client.c crm_ipc_t *ipc = native->ipc; ipc 1593 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1594 lib/lrmd/lrmd_client.c crm_ipc_close(ipc); ipc 1595 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);