ipc 29 include/crm/attrd.h int attrd_update_delegate(crm_ipc_t * ipc, char command, const char *host, ipc 32 include/crm/attrd.h int attrd_clear_delegate(crm_ipc_t *ipc, const char *host, const char *resource, ipc 368 include/crm_internal.h crm_ipc_t *ipc; ipc 36 lib/cib/cib_native.c crm_ipc_t *ipc; ipc 69 lib/cib/cib_native.c native->ipc = NULL; ipc 146 lib/cib/cib_native.c while (crm_ipc_ready(native->ipc)) { ipc 148 lib/cib/cib_native.c if (crm_ipc_read(native->ipc) > 0) { ipc 149 lib/cib/cib_native.c const char *msg = crm_ipc_buffer(native->ipc); ipc 154 lib/cib/cib_native.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 172 lib/cib/cib_native.c native->ipc = NULL; ipc 212 lib/cib/cib_native.c native->ipc = crm_ipc_new(channel, 0); ipc 214 lib/cib/cib_native.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 215 lib/cib/cib_native.c *async_fd = crm_ipc_get_fd(native->ipc); ipc 217 lib/cib/cib_native.c } else if (native->ipc) { ipc 226 lib/cib/cib_native.c native->ipc = mainloop_get_ipc_client(native->source); ipc 229 lib/cib/cib_native.c if (rc != pcmk_ok || native->ipc == NULL || crm_ipc_connected(native->ipc) == FALSE) { ipc 230 lib/cib/cib_native.c crm_debug("Connection unsuccessful (%d %p)", rc, native->ipc); ipc 243 lib/cib/cib_native.c if (crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply) > 0) { ipc 289 lib/cib/cib_native.c native->ipc = NULL; ipc 291 lib/cib/cib_native.c } else if (native->ipc) { ipc 293 lib/cib/cib_native.c crm_ipc_t *ipc = native->ipc; ipc 295 lib/cib/cib_native.c native->ipc = NULL; ipc 296 lib/cib/cib_native.c crm_ipc_close(ipc); ipc 297 lib/cib/cib_native.c crm_ipc_destroy(ipc); ipc 385 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, cib->call_timeout * 1000, &op_reply); ipc 467 lib/cib/cib_native.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 503 lib/cib/cib_native.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, ipc 445 lib/cluster/heartbeat.c IPC_Channel *ipc = NULL; ipc 449 lib/cluster/heartbeat.c ipc = hb_conn->llc_ops->ipcchan(hb_conn); ipc 451 lib/cluster/heartbeat.c if (ipc != NULL) { ipc 453 lib/cluster/heartbeat.c send_q = ipc->send_queue; ipc 620 lib/cluster/legacy.c mainloop_io_t *ipc = ipc 624 lib/cluster/legacy.c crm_ipc_send(mainloop_get_ipc_client(ipc), poke, 0, 0, NULL); ipc 53 lib/common/attrd_client.c send_attrd_op(crm_ipc_t *ipc, xmlNode *attrd_op) ipc 62 lib/common/attrd_client.c if (ipc == NULL && local_ipc == NULL) { ipc 68 lib/common/attrd_client.c if (ipc == NULL) { ipc 69 lib/common/attrd_client.c ipc = local_ipc; ipc 75 lib/common/attrd_client.c connected = crm_ipc_connect(ipc); ipc 79 lib/common/attrd_client.c rc = crm_ipc_send(ipc, attrd_op, flags, 0, NULL); ipc 84 lib/common/attrd_client.c if (ipc != local_ipc) { ipc 95 lib/common/attrd_client.c crm_ipc_close(ipc); ipc 135 lib/common/attrd_client.c attrd_update_delegate(crm_ipc_t *ipc, char command, const char *host, ipc 209 lib/common/attrd_client.c rc = send_attrd_op(ipc, update); ipc 236 lib/common/attrd_client.c attrd_clear_delegate(crm_ipc_t *ipc, const char *host, const char *resource, ipc 250 lib/common/attrd_client.c rc = send_attrd_op(ipc, clear_op); ipc 819 lib/common/ipc.c qb_ipcc_connection_t *ipc; ipc 876 lib/common/ipc.c client->ipc = qb_ipcc_connect(client->name, client->buf_size); ipc 878 lib/common/ipc.c if (client->ipc == NULL) { ipc 889 lib/common/ipc.c qb_ipcc_context_set(client->ipc, client); ipc 892 lib/common/ipc.c client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc); ipc 907 lib/common/ipc.c crm_trace("Disconnecting %s IPC connection %p (%p)", client->name, client, client->ipc); ipc 909 lib/common/ipc.c if (client->ipc) { ipc 910 lib/common/ipc.c qb_ipcc_connection_t *ipc = client->ipc; ipc 912 lib/common/ipc.c client->ipc = NULL; ipc 913 lib/common/ipc.c qb_ipcc_disconnect(ipc); ipc 922 lib/common/ipc.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { ipc 946 lib/common/ipc.c if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) { ipc 964 lib/common/ipc.c } else if (client->ipc == NULL) { ipc 973 lib/common/ipc.c rc = qb_ipcc_is_connected(client->ipc); ipc 1055 lib/common/ipc.c CRM_ASSERT(client->ipc != NULL); ipc 1061 lib/common/ipc.c client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer, client->buf_size - 1, 0); ipc 1129 lib/common/ipc.c rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, client->buf_size, -1); ipc 1142 lib/common/ipc.c rc = qb_ipcc_sendv(client->ipc, iov, 2); ipc 1160 lib/common/ipc.c rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000); ipc 1226 lib/common/ipc.c rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout); ipc 1229 lib/common/ipc.c client->ipc); ipc 1234 lib/common/ipc.c client->ipc); ipc 1318 lib/common/ipc.c header->qb.id, client->name, client->ipc, pcmk_strerror(rc), rc, ms_timeout); ipc 1323 lib/common/ipc.c header->qb.id, client->name, client->ipc, pcmk_strerror(rc), rc); ipc 632 lib/common/mainloop.c crm_ipc_t *ipc; ipc 650 lib/common/mainloop.c if (client->ipc) { ipc 655 lib/common/mainloop.c rc = crm_ipc_read(client->ipc); ipc 661 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); ipc 683 lib/common/mainloop.c if (client->ipc && crm_ipc_connected(client->ipc) == FALSE) { ipc 740 lib/common/mainloop.c if (client->ipc) { ipc 741 lib/common/mainloop.c crm_ipc_close(client->ipc); ipc 751 lib/common/mainloop.c if (client->ipc) { ipc 752 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; ipc 754 lib/common/mainloop.c client->ipc = NULL; ipc 755 lib/common/mainloop.c crm_ipc_destroy(ipc); ipc 788 lib/common/mainloop.c client->ipc = conn; ipc 804 lib/common/mainloop.c return client->ipc; ipc 84 lib/fencing/st_client.c crm_ipc_t *ipc; ipc 193 lib/fencing/st_client.c native->ipc = NULL; ipc 1716 lib/fencing/st_client.c native->ipc = NULL; ipc 1718 lib/fencing/st_client.c } else if (native->ipc) { ipc 1720 lib/fencing/st_client.c crm_ipc_t *ipc = native->ipc; ipc 1722 lib/fencing/st_client.c native->ipc = NULL; ipc 1723 lib/fencing/st_client.c crm_ipc_close(ipc); ipc 1724 lib/fencing/st_client.c crm_ipc_destroy(ipc); ipc 1748 lib/fencing/st_client.c native->ipc = crm_ipc_new("stonith-ng", 0); ipc 1750 lib/fencing/st_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 1751 lib/fencing/st_client.c *stonith_fd = crm_ipc_get_fd(native->ipc); ipc 1752 lib/fencing/st_client.c } else if (native->ipc) { ipc 1761 lib/fencing/st_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 1764 lib/fencing/st_client.c if (native->ipc == NULL) { ipc 1776 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, hello, crm_ipc_client_response, -1, &reply); ipc 1840 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, notify_msg, crm_ipc_client_response, -1, NULL); ipc 2278 lib/fencing/st_client.c rc = crm_ipc_send(native->ipc, op_msg, ipc_flags, 1000 * (timeout + 60), &op_reply); ipc 2329 lib/fencing/st_client.c if (crm_ipc_connected(native->ipc) == FALSE) { ipc 2348 lib/fencing/st_client.c while (crm_ipc_ready(private->ipc)) { ipc 2350 lib/fencing/st_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 2351 lib/fencing/st_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 2356 lib/fencing/st_client.c if (crm_ipc_connected(private->ipc) == FALSE) { ipc 83 lib/lrmd/lrmd_client.c crm_ipc_t *ipc; ipc 409 lib/lrmd/lrmd_client.c return crm_ipc_ready(native->ipc); ipc 437 lib/lrmd/lrmd_client.c while (crm_ipc_ready(private->ipc)) { ipc 438 lib/lrmd/lrmd_client.c if (crm_ipc_read(private->ipc) > 0) { ipc 439 lib/lrmd/lrmd_client.c const char *msg = crm_ipc_buffer(private->ipc); ipc 496 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 712 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_client_response, timeout, reply); ipc 734 lib/lrmd/lrmd_client.c rc = crm_ipc_send(native->ipc, msg, crm_ipc_flags_none, 0, NULL); ipc 761 lib/lrmd/lrmd_client.c return crm_ipc_connected(native->ipc); ipc 972 lib/lrmd/lrmd_client.c native->ipc = crm_ipc_new(CRM_SYSTEM_LRMD, 0); ipc 973 lib/lrmd/lrmd_client.c if (native->ipc && crm_ipc_connect(native->ipc)) { ipc 974 lib/lrmd/lrmd_client.c *fd = crm_ipc_get_fd(native->ipc); ipc 975 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 981 lib/lrmd/lrmd_client.c native->ipc = mainloop_get_ipc_client(native->source); ipc 984 lib/lrmd/lrmd_client.c if (native->ipc == NULL) { ipc 1340 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1342 lib/lrmd/lrmd_client.c } else if (native->ipc) { ipc 1344 lib/lrmd/lrmd_client.c crm_ipc_t *ipc = native->ipc; ipc 1346 lib/lrmd/lrmd_client.c native->ipc = NULL; ipc 1347 lib/lrmd/lrmd_client.c crm_ipc_close(ipc); ipc 1348 lib/lrmd/lrmd_client.c crm_ipc_destroy(ipc); ipc 141 lib/lrmd/proxy_common.c flags = crm_ipc_buffer_flags(proxy->ipc); ipc 164 lib/lrmd/proxy_common.c proxy->ipc = NULL; ipc 199 lib/lrmd/proxy_common.c proxy->ipc = mainloop_get_ipc_client(proxy->source); ipc 252 lib/lrmd/proxy_common.c if (crm_ipc_connected(proxy->ipc) == FALSE) { ipc 274 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 5000, NULL); ipc 280 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 291 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 301 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 303 lib/lrmd/proxy_common.c rc = crm_ipc_send(proxy->ipc, request, flags, 10000, &op_reply); ipc 306 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name, pcmk_strerror(rc), rc); ipc 309 lib/lrmd/proxy_common.c op, msg_id, proxy->node_name, crm_ipc_name(proxy->ipc), name); ipc 227 tools/attrd_updater.c crm_ipc_t *ipc; ipc 243 tools/attrd_updater.c ipc = crm_ipc_new(T_ATTRD, 0); ipc 244 tools/attrd_updater.c if (crm_ipc_connect(ipc) == FALSE) { ipc 248 tools/attrd_updater.c rc = crm_ipc_send(ipc, query, crm_ipc_flags_none|crm_ipc_client_response, 0, reply); ipc 252 tools/attrd_updater.c crm_ipc_close(ipc); ipc 339 tools/crm_node.c mainloop_io_t *ipc = ipc 341 tools/crm_node.c if (ipc != NULL) { ipc 345 tools/crm_node.c crm_ipc_send(mainloop_get_ipc_client(ipc), poke, 0, 0, NULL);