client 149 attrd/attrd_common.c crm_client_t *client = crm_client_get(c); client 151 attrd/attrd_common.c if (client == NULL) { client 155 attrd/attrd_common.c crm_client_destroy(client); client 444 attrd/commands.c attrd_client_query(crm_client_t *client, uint32_t id, uint32_t flags, xmlNode *query) client 474 attrd/commands.c client->request_id = 0; client 475 attrd/commands.c if ((rc = crm_ipcs_send(client, id, reply, flags)) < 0) { client 52 attrd/internal.h #define attrd_send_ack(client, id, flags) \ client 53 attrd/internal.h crm_ipcs_send_ack((client), (id), (flags), "ack", __FUNCTION__, __LINE__) client 56 attrd/internal.h void attrd_peer_message(crm_node_t *client, xmlNode *msg); client 61 attrd/internal.h void attrd_client_query(crm_client_t *client, uint32_t id, uint32_t flags, xmlNode *query); client 112 attrd/legacy.c crm_client_t *client = crm_client_get(c); client 113 attrd/legacy.c xmlNode *msg = crm_ipcs_recv(client, data, size, &id, &flags); client 115 attrd/legacy.c crm_ipcs_send_ack(client, id, flags, "ack", __FUNCTION__, __LINE__); client 121 attrd/legacy.c CRM_ASSERT(client->user != NULL); client 122 attrd/legacy.c crm_acl_get_set_user(msg, F_ATTRD_USER, client->user); client 237 attrd/main.c crm_client_t *client = crm_client_get(c); client 238 attrd/main.c xmlNode *xml = crm_ipcs_recv(client, data, size, &id, &flags); client 246 attrd/main.c CRM_ASSERT(client->user != NULL); client 247 attrd/main.c crm_acl_get_set_user(xml, F_ATTRD_USER, client->user); client 255 attrd/main.c if (client->name == NULL) { client 257 attrd/main.c client->name = crm_strdup_printf("%s.%d", value?value:"unknown", client->pid); client 261 attrd/main.c attrd_send_ack(client, id, flags); client 262 attrd/main.c attrd_client_peer_remove(client->name, xml); client 265 attrd/main.c attrd_send_ack(client, id, flags); client 269 attrd/main.c attrd_send_ack(client, id, flags); client 273 attrd/main.c attrd_send_ack(client, id, flags); client 277 attrd/main.c attrd_send_ack(client, id, flags); client 281 attrd/main.c attrd_send_ack(client, id, flags); client 286 attrd/main.c attrd_client_query(client, id, flags, xml); client 290 attrd/main.c client->name, op); client 132 cib/callbacks.c crm_client_t *client = crm_client_get(c); client 134 cib/callbacks.c crm_trace("%p message from %s", c, client->id); client 141 cib/callbacks.c crm_client_t *client = crm_client_get(c); client 143 cib/callbacks.c crm_trace("%p message from %s", c, client->id); client 151 cib/callbacks.c crm_client_t *client = crm_client_get(c); client 153 cib/callbacks.c if (client == NULL) { client 157 cib/callbacks.c crm_client_destroy(client); client 1357 cib/callbacks.c const char *client = crm_element_value(request, F_CIB_CLIENTNAME); client 1360 cib/callbacks.c cib_diff_notify(call_options, client, call_id, op, input, rc, *cib_diff); client 1484 cib/callbacks.c cib_client_status_callback(const char *node, const char *client, const char *status, void *private) client 1489 cib/callbacks.c if (safe_str_eq(client, CRM_SYSTEM_CIB)) { client 1494 cib/callbacks.c node, client, status); client 1498 cib/callbacks.c crm_info("Status update: Client %s/%s now has status [%s]", node, client, status); client 71 cib/callbacks.h extern void cib_client_status_callback(const char *node, const char *client, client 57 cib/notify.c crm_client_t *client = value; client 59 cib/notify.c if (is_set(client->options, cib_notify_pre)) { client 69 cib/notify.c crm_client_t *client = value; client 71 cib/notify.c if (is_set(client->options, cib_notify_post)) { client 84 cib/notify.c crm_client_t *client = value; client 87 cib/notify.c CRM_CHECK(client != NULL, return TRUE); client 90 cib/notify.c if (client->ipcs == NULL && client->remote == NULL) { client 98 cib/notify.c if (is_set(client->options, cib_notify_diff) && safe_str_eq(type, T_CIB_DIFF_NOTIFY)) { client 101 cib/notify.c } else if (is_set(client->options, cib_notify_replace) client 105 cib/notify.c } else if (is_set(client->options, cib_notify_confirm) client 109 cib/notify.c } else if (is_set(client->options, cib_notify_pre) && safe_str_eq(type, T_CIB_PRE_NOTIFY)) { client 112 cib/notify.c } else if (is_set(client->options, cib_notify_post) && safe_str_eq(type, T_CIB_POST_NOTIFY)) { client 117 cib/notify.c switch (client->kind) { client 119 cib/notify.c if (crm_ipcs_sendv(client, update->iov, crm_ipc_server_event) < 0) { client 120 cib/notify.c crm_warn("Notification of client %s/%s failed", client->name, client->id); client 127 cib/notify.c crm_debug("Sent %s notification to client %s/%s", type, client->name, client->id); client 128 cib/notify.c crm_remote_send(client->remote, update->msg); client 131 cib/notify.c crm_err("Unknown transport %d for %s", client->kind, client->name); client 236 cib/notify.c cib_diff_notify(int options, const char *client, const char *call_id, const char *op, client 263 cib/notify.c client, call_id ? ", call:" : "", call_id ? call_id : "", client 270 cib/notify.c client, call_id ? ", call: " : "", call_id ? call_id : "", client 34 cib/notify.h extern void cib_diff_notify(int options, const char *client, const char *call_id, const char *op, client 268 cib/remote.c crm_client_t *client = data; client 270 cib/remote.c client->remote->auth_timeout = 0; client 272 cib/remote.c if (client->remote->authenticated == TRUE) { client 276 cib/remote.c mainloop_del_fd(client->remote->source); client 359 cib/remote.c crm_client_t *client = user_data; client 362 cib/remote.c if (client == NULL) { client 366 cib/remote.c crm_trace("Cleaning up after client disconnect: %s/%s", crm_str(client->name), client->id); client 371 cib/remote.c switch (client->kind) { client 373 cib/remote.c csock = client->remote->tcp_socket; client 377 cib/remote.c if (client->remote->tls_session) { client 378 cib/remote.c void *sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session); client 381 cib/remote.c if (client->remote->tls_handshake_complete) { client 382 cib/remote.c gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_WR); client 384 cib/remote.c gnutls_deinit(*client->remote->tls_session); client 385 cib/remote.c gnutls_free(client->remote->tls_session); client 386 cib/remote.c client->remote->tls_session = NULL; client 391 cib/remote.c crm_warn("Unexpected client type %d", client->kind); client 398 cib/remote.c crm_client_destroy(client); client 409 cib/remote.c cib_handle_remote_msg(crm_client_t * client, xmlNode * command) client 419 cib/remote.c if (client->name == NULL) { client 422 cib/remote.c client->name = strdup(client->id); client 424 cib/remote.c client->name = strdup(value); client 428 cib/remote.c if (client->userdata == NULL) { client 431 cib/remote.c client->userdata = strdup(value); client 432 cib/remote.c crm_trace("Callback channel for %s is %s", client->id, (char*)client->userdata); client 435 cib/remote.c client->userdata = strdup(client->id); client 445 cib/remote.c crm_xml_add(command, F_CIB_CLIENTID, client->id); client 446 cib/remote.c crm_xml_add(command, F_CIB_CLIENTNAME, client->name); client 448 cib/remote.c crm_xml_add(command, F_CIB_USER, client->user); client 464 cib/remote.c cib_common_callback_worker(0, 0, command, client, TRUE); client 471 cib/remote.c crm_client_t *client = data; client 473 cib/remote.c int timeout = client->remote->authenticated ? -1 : 1000; client 475 cib/remote.c crm_trace("%s callback", client->kind != CRM_CLIENT_TCP ? "secure" : "clear-text"); client 478 cib/remote.c if (client->kind == CRM_CLIENT_TLS && (client->remote->tls_handshake_complete == FALSE)) { client 484 cib/remote.c rc = gnutls_handshake(*client->remote->tls_session); client 494 cib/remote.c client->remote->tls_handshake_complete = TRUE; client 495 cib/remote.c if (client->remote->auth_timeout) { client 496 cib/remote.c g_source_remove(client->remote->auth_timeout); client 499 cib/remote.c client->remote->auth_timeout = client 500 cib/remote.c g_timeout_add(REMOTE_AUTH_TIMEOUT, remote_auth_timeout_cb, client); client 506 cib/remote.c crm_remote_recv(client->remote, timeout, &disconnected); client 509 cib/remote.c if (client->remote->authenticated == FALSE) { client 515 cib/remote.c command = crm_remote_parse_buffer(client->remote); client 522 cib/remote.c client->remote->authenticated = TRUE; client 523 cib/remote.c g_source_remove(client->remote->auth_timeout); client 524 cib/remote.c client->remote->auth_timeout = 0; client 525 cib/remote.c client->name = crm_element_value_copy(command, "name"); client 530 cib/remote.c client->user = strdup(user); client 537 cib/remote.c crm_xml_add(reg, F_CIB_CLIENTID, client->id); client 538 cib/remote.c crm_remote_send(client->remote, reg); client 543 cib/remote.c command = crm_remote_parse_buffer(client->remote); client 546 cib/remote.c cib_handle_remote_msg(client, command); client 548 cib/remote.c command = crm_remote_parse_buffer(client->remote); client 247 crmd/control.c crm_client_t *client = value; client 249 crmd/control.c crm_err("%s is still connected at exit", crm_client_name(client)); client 308 crmd/control.c if (pe_subsystem && pe_subsystem->client && pe_subsystem->client->ipcs) { client 310 crmd/control.c qb_ipcs_disconnect(pe_subsystem->client->ipcs); client 712 crmd/control.c crm_client_t *client = crm_client_get(c); client 714 crmd/control.c xmlNode *msg = crm_ipcs_recv(client, data, size, &id, &flags); client 716 crmd/control.c crm_trace("Invoked: %s", crm_client_name(client)); client 717 crmd/control.c crm_ipcs_send_ack(client, id, flags, "ack", __FUNCTION__, __LINE__); client 724 crmd/control.c CRM_ASSERT(client->user != NULL); client 725 crmd/control.c crm_acl_get_set_user(msg, F_CRM_USER, client->user); client 728 crmd/control.c crm_trace("Processing msg from %s", crm_client_name(client)); client 731 crmd/control.c crm_xml_add(msg, F_CRM_SYS_FROM, client->id); client 732 crmd/control.c if (crmd_authorize_message(msg, client, NULL)) { client 744 crmd/control.c crm_client_t *client = crm_client_get(c); client 747 crmd/control.c if (client == NULL) { client 753 crmd/control.c if (client->userdata == NULL) { client 756 crmd/control.c } else if (strcasecmp(CRM_SYSTEM_PENGINE, client->userdata) == 0) { client 759 crmd/control.c } else if (strcasecmp(CRM_SYSTEM_TENGINE, client->userdata) == 0) { client 762 crmd/control.c } else if (strcasecmp(CRM_SYSTEM_CIB, client->userdata) == 0) { client 768 crmd/control.c the_subsystem->client = NULL; client 776 crmd/control.c crm_trace("Disconnecting client %s (%p)", crm_client_name(client), client); client 777 crmd/control.c free(client->userdata); client 778 crmd/control.c crm_client_destroy(client); client 32 crmd/crmd_callbacks.h extern void crmd_client_status_callback(const char *node, const char *client, const char *status, client 45 crmd/crmd_fsa.h crm_client_t *client; /* Client connection object */ client 415 crmd/heartbeat.c crmd_client_status_callback(const char *node, const char *client, const char *status, void *private) client 420 crmd/heartbeat.c if (safe_str_neq(client, CRM_SYSTEM_CRMD)) { client 429 crmd/heartbeat.c node, client, status, AM_I_DC ? "true" : "false"); client 436 crmd/heartbeat.c node, client, status, AM_I_DC ? "true" : "false"); client 101 crmd/pengine.c pe_subsystem->client = NULL; client 343 fencing/admin.c event->target, event->client, event->origin, ctime(&complete)); client 373 fencing/admin.c hp->client, hp->origin, ctime(&complete)); client 385 fencing/admin.c hp->client, hp->origin, action_s, hp->target, hp->state, hp->completed); client 99 fencing/commands.c char *client; client 233 fencing/commands.c free(cmd->client); client 259 fencing/commands.c cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID); client 268 fencing/commands.c CRM_CHECK(cmd->client != NULL, crm_log_xml_warn(msg, "NoClient")); client 468 fencing/commands.c cmd->action, device->id, cmd->client, cmd->timeout); client 981 fencing/commands.c cmd->client = strdup(crm_system_name); client 2041 fencing/commands.c do_local_reply(reply, cmd->client, cmd->options & st_opt_sync_call, FALSE); client 2054 fencing/commands.c crm_xml_add(notify_data, F_STONITH_ORIGIN, cmd->client); client 2187 fencing/commands.c if (safe_str_eq(cmd->client, cmd_other->client) || client 2366 fencing/commands.c crm_xml_add(reply, F_STONITH_CLIENTID, cmd->client); client 2448 fencing/commands.c handle_request(crm_client_t * client, uint32_t id, uint32_t flags, xmlNode * request, client 2464 fencing/commands.c CRM_ASSERT(client == NULL || client->request_id == id); client 2470 fencing/commands.c CRM_ASSERT(client); client 2472 fencing/commands.c crm_xml_add(reply, F_STONITH_CLIENTID, client->id); client 2473 fencing/commands.c crm_ipcs_send(client, id, reply, flags); client 2474 fencing/commands.c client->request_id = 0; client 2500 fencing/commands.c CRM_ASSERT(client); client 2503 fencing/commands.c crm_debug("Setting %s callbacks for %s (%s): ON", flag_name, client->name, client->id); client 2504 fencing/commands.c client->options |= get_stonith_flag(flag_name); client 2509 fencing/commands.c crm_debug("Setting %s callbacks for %s (%s): off", flag_name, client->name, client->id); client 2510 fencing/commands.c client->options |= get_stonith_flag(flag_name); client 2514 fencing/commands.c crm_ipcs_send_ack(client, id, flags, "ack", __FUNCTION__, __LINE__); client 2523 fencing/commands.c client ? client->name : remote_peer, client 2542 fencing/commands.c rop = initiate_remote_stonith_op(client, request, TRUE); client 2552 fencing/commands.c if (client) { client 2556 fencing/commands.c client->name, client->id, action, target, device ? device : "(any)"); client 2572 fencing/commands.c if (alternate_host && client) { client 2577 fencing/commands.c if (client->id) { client 2578 fencing/commands.c client_id = client->id; client 2587 fencing/commands.c crm_xml_add(request, F_STONITH_CLIENTID, client->id); client 2592 fencing/commands.c } else if (initiate_remote_stonith_op(client, request, FALSE) != NULL) { client 2648 fencing/commands.c crm_err("Unknown %s from %s", op, client ? client->name : remote_peer); client 2658 fencing/commands.c crm_trace("Reply handling: %p %u %u %d %d %s", client, client?client->request_id:0, client 2663 fencing/commands.c CRM_ASSERT(client == NULL || client->request_id == id); client 2677 fencing/commands.c handle_reply(crm_client_t * client, xmlNode * request, const char *remote_peer) client 2689 fencing/commands.c crm_err("Unknown %s reply from %s", op, client ? client->name : remote_peer); client 2695 fencing/commands.c stonith_command(crm_client_t * client, uint32_t id, uint32_t flags, xmlNode * request, client 2719 fencing/commands.c id, client ? client->name : remote_peer, call_options); client 2722 fencing/commands.c CRM_ASSERT(client == NULL || client->request_id == id); client 2726 fencing/commands.c handle_reply(client, request, remote_peer); client 2728 fencing/commands.c rc = handle_request(client, id, flags, request, remote_peer); client 2732 fencing/commands.c is_reply ? " reply" : "", client ? client->name : remote_peer, client 175 fencing/internal.h void stonith_command(crm_client_t * client, uint32_t id, uint32_t flags, client 197 fencing/internal.h do_stonith_async_timeout_update(const char *client, const char *call_id, int timeout); client 203 fencing/internal.h remote_fencing_op_t *initiate_remote_stonith_op(crm_client_t * client, xmlNode * request, client 210 fencing/internal.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer); client 162 fencing/main.c crm_client_t *client = crm_client_get(c); client 164 fencing/main.c if (client == NULL) { client 169 fencing/main.c crm_client_destroy(client); client 319 fencing/main.c crm_client_t *client = value; client 322 fencing/main.c CRM_CHECK(client != NULL, return); client 328 fencing/main.c if (client->ipcs == NULL) { client 333 fencing/main.c if (client->options & get_stonith_flag(type)) { client 334 fencing/main.c int rc = crm_ipcs_send(client, 0, update_msg, crm_ipc_server_event | crm_ipc_server_error); client 338 fencing/main.c type, crm_client_name(client), client->id, pcmk_strerror(rc), rc); client 340 fencing/main.c crm_trace("Sent %s notification to client %s.%.6s", type, crm_client_name(client), client 341 fencing/main.c client->id); client 349 fencing/main.c crm_client_t *client = NULL; client 356 fencing/main.c client = crm_client_get_by_id(client_id); client 357 fencing/main.c if (!client) { client 368 fencing/main.c if (client) { client 369 fencing/main.c crm_ipcs_send(client, 0, notify_data, crm_ipc_server_event); client 959 fencing/remote.c create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer) client 1009 fencing/remote.c CRM_LOG_ASSERT(client != NULL); client 1010 fencing/remote.c if (client) { client 1011 fencing/remote.c op->client_id = strdup(client); client 1050 fencing/remote.c initiate_remote_stonith_op(crm_client_t * client, xmlNode * request, gboolean manual_ack) client 1057 fencing/remote.c if (client) { client 1058 fencing/remote.c client_id = client->id; client 64 include/crm/common/ipc.h bool crm_ipc_connect(crm_ipc_t * client); client 65 include/crm/common/ipc.h void crm_ipc_close(crm_ipc_t * client); client 66 include/crm/common/ipc.h void crm_ipc_destroy(crm_ipc_t * client); client 68 include/crm/common/ipc.h int crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags, client 71 include/crm/common/ipc.h int crm_ipc_get_fd(crm_ipc_t * client); client 72 include/crm/common/ipc.h bool crm_ipc_connected(crm_ipc_t * client); client 73 include/crm/common/ipc.h int crm_ipc_ready(crm_ipc_t * client); client 74 include/crm/common/ipc.h long crm_ipc_read(crm_ipc_t * client); client 75 include/crm/common/ipc.h const char *crm_ipc_buffer(crm_ipc_t * client); client 76 include/crm/common/ipc.h uint32_t crm_ipc_buffer_flags(crm_ipc_t * client); client 77 include/crm/common/ipc.h const char *crm_ipc_name(crm_ipc_t * client); client 115 include/crm/common/ipcs.h bool crm_set_client_queue_max(crm_client_t *client, const char *qmax); client 85 include/crm/common/mainloop.h void mainloop_del_ipc_client(mainloop_io_t * client); client 87 include/crm/common/mainloop.h crm_ipc_t *mainloop_get_ipc_client(mainloop_io_t * client); client 97 include/crm/common/mainloop.h void mainloop_del_fd(mainloop_io_t * client); client 89 include/crm/stonith-ng.h char *client; client 829 lib/ais/plugin.c const char *client = NULL; client 840 lib/ais/plugin.c client = pcmk_children[lpc].name; client 848 lib/ais/plugin.c if (client) { client 849 lib/ais/plugin.c do_ais_log(LOG_INFO, "Client %s (conn=%p, async-conn=%p) left", client, conn, async_conn); client 421 lib/cib/cib_client.c cib_notify_client_t *client = g_list_nth_data(list, 0); client 423 lib/cib/cib_client.c list = g_list_remove(list, client); client 424 lib/cib/cib_client.c free(client); client 500 lib/cib/cib_client.c cib_notify_client_t *client = (cib_notify_client_t *)l->data; client 502 lib/cib/cib_client.c if (strcmp(client->event, event) == 0) { client 221 lib/common/ipc.c crm_client_t *client; client 226 lib/common/ipc.c while (g_hash_table_iter_next(&iter, &key, (gpointer *) & client)) { client 227 lib/common/ipc.c if (strcmp(client->id, id) == 0) { client 228 lib/common/ipc.c return client; client 306 lib/common/ipc.c crm_client_t *client = calloc(1, sizeof(crm_client_t)); client 308 lib/common/ipc.c CRM_ASSERT(client != NULL); client 309 lib/common/ipc.c client->id = crm_generate_uuid(); client 310 lib/common/ipc.c g_hash_table_insert(client_connections, (key? key : client->id), client); client 311 lib/common/ipc.c return client; client 320 lib/common/ipc.c crm_client_t *client = NULL; client 347 lib/common/ipc.c client = crm_client_alloc(c); client 348 lib/common/ipc.c client->ipcs = c; client 349 lib/common/ipc.c client->kind = CRM_CLIENT_IPC; client 350 lib/common/ipc.c client->pid = crm_ipcs_client_pid(c); client 354 lib/common/ipc.c set_bit(client->flags, crm_client_flag_ipc_privileged); client 357 lib/common/ipc.c crm_debug("Connecting %p for uid=%d gid=%d pid=%u id=%s", c, uid_client, gid_client, client->pid, client->id); client 360 lib/common/ipc.c client->user = uid2username(uid_client); client 362 lib/common/ipc.c return client; client 421 lib/common/ipc.c crm_set_client_queue_max(crm_client_t *client, const char *qmax) client 423 lib/common/ipc.c if (is_set(client->flags, crm_client_flag_ipc_privileged)) { client 427 lib/common/ipc.c client->queue_max = qmax_int; client 847 lib/common/ipc.c crm_ipc_t *client = NULL; client 849 lib/common/ipc.c client = calloc(1, sizeof(crm_ipc_t)); client 851 lib/common/ipc.c client->name = strdup(name); client 852 lib/common/ipc.c client->buf_size = pick_ipc_buffer(max_size); client 853 lib/common/ipc.c client->buffer = malloc(client->buf_size); client 856 lib/common/ipc.c client->max_buf_size = client->buf_size; client 858 lib/common/ipc.c client->pfd.fd = -1; client 859 lib/common/ipc.c client->pfd.events = POLLIN; client 860 lib/common/ipc.c client->pfd.revents = 0; client 862 lib/common/ipc.c return client; client 873 lib/common/ipc.c crm_ipc_connect(crm_ipc_t * client) client 875 lib/common/ipc.c client->need_reply = FALSE; client 876 lib/common/ipc.c client->ipc = qb_ipcc_connect(client->name, client->buf_size); client 878 lib/common/ipc.c if (client->ipc == NULL) { client 879 lib/common/ipc.c crm_debug("Could not establish %s connection: %s (%d)", client->name, pcmk_strerror(errno), errno); client 883 lib/common/ipc.c client->pfd.fd = crm_ipc_get_fd(client); client 884 lib/common/ipc.c if (client->pfd.fd < 0) { client 885 lib/common/ipc.c crm_debug("Could not obtain file descriptor for %s connection: %s (%d)", client->name, pcmk_strerror(errno), errno); client 889 lib/common/ipc.c qb_ipcc_context_set(client->ipc, client); client 892 lib/common/ipc.c client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc); client 893 lib/common/ipc.c if (client->max_buf_size > client->buf_size) { client 894 lib/common/ipc.c free(client->buffer); client 895 lib/common/ipc.c client->buffer = calloc(1, client->max_buf_size); client 896 lib/common/ipc.c client->buf_size = client->max_buf_size; client 904 lib/common/ipc.c crm_ipc_close(crm_ipc_t * client) client 906 lib/common/ipc.c if (client) { client 907 lib/common/ipc.c crm_trace("Disconnecting %s IPC connection %p (%p)", client->name, client, client->ipc); client 909 lib/common/ipc.c if (client->ipc) { client 910 lib/common/ipc.c qb_ipcc_connection_t *ipc = client->ipc; client 912 lib/common/ipc.c client->ipc = NULL; client 919 lib/common/ipc.c crm_ipc_destroy(crm_ipc_t * client) client 921 lib/common/ipc.c if (client) { client 922 lib/common/ipc.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { client 923 lib/common/ipc.c crm_notice("Destroying an active IPC connection to %s", client->name); client 934 lib/common/ipc.c crm_trace("Destroying IPC connection to %s: %p", client->name, client); client 935 lib/common/ipc.c free(client->buffer); client 936 lib/common/ipc.c free(client->name); client 937 lib/common/ipc.c free(client); client 942 lib/common/ipc.c crm_ipc_get_fd(crm_ipc_t * client) client 946 lib/common/ipc.c if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) { client 951 lib/common/ipc.c (client? client->name : "unspecified client")); client 956 lib/common/ipc.c crm_ipc_connected(crm_ipc_t * client) client 960 lib/common/ipc.c if (client == NULL) { client 964 lib/common/ipc.c } else if (client->ipc == NULL) { client 968 lib/common/ipc.c } else if (client->pfd.fd < 0) { client 973 lib/common/ipc.c rc = qb_ipcc_is_connected(client->ipc); client 975 lib/common/ipc.c client->pfd.fd = -EINVAL; client 988 lib/common/ipc.c crm_ipc_ready(crm_ipc_t *client) client 992 lib/common/ipc.c CRM_ASSERT(client != NULL); client 994 lib/common/ipc.c if (crm_ipc_connected(client) == FALSE) { client 998 lib/common/ipc.c client->pfd.revents = 0; client 999 lib/common/ipc.c rc = poll(&(client->pfd), 1, 0); client 1004 lib/common/ipc.c crm_ipc_decompress(crm_ipc_t * client) client 1006 lib/common/ipc.c struct crm_ipc_response_header *header = (struct crm_ipc_response_header *)(void*)client->buffer; client 1012 lib/common/ipc.c unsigned int new_buf_size = QB_MAX((hdr_offset + size_u), client->max_buf_size); client 1019 lib/common/ipc.c client->buffer + hdr_offset, header->size_compressed, 1, 0); client 1037 lib/common/ipc.c memcpy(uncompressed, client->buffer, hdr_offset); /* Preserve the header */ client 1040 lib/common/ipc.c free(client->buffer); client 1041 lib/common/ipc.c client->buf_size = new_buf_size; client 1042 lib/common/ipc.c client->buffer = uncompressed; client 1045 lib/common/ipc.c CRM_ASSERT(client->buffer[hdr_offset + header->size_uncompressed - 1] == 0); client 1050 lib/common/ipc.c crm_ipc_read(crm_ipc_t * client) client 1054 lib/common/ipc.c CRM_ASSERT(client != NULL); client 1055 lib/common/ipc.c CRM_ASSERT(client->ipc != NULL); client 1056 lib/common/ipc.c CRM_ASSERT(client->buffer != NULL); client 1060 lib/common/ipc.c client->buffer[0] = 0; client 1061 lib/common/ipc.c client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer, client->buf_size - 1, 0); client 1062 lib/common/ipc.c if (client->msg_size >= 0) { client 1063 lib/common/ipc.c int rc = crm_ipc_decompress(client); client 1069 lib/common/ipc.c header = (struct crm_ipc_response_header *)(void*)client->buffer; client 1077 lib/common/ipc.c client->name, header->qb.id, header->qb.size, client->msg_size, client 1078 lib/common/ipc.c client->buffer + hdr_offset); client 1081 lib/common/ipc.c crm_trace("No message from %s received: %s", client->name, pcmk_strerror(client->msg_size)); client 1084 lib/common/ipc.c if (crm_ipc_connected(client) == FALSE || client->msg_size == -ENOTCONN) { client 1085 lib/common/ipc.c crm_err("Connection to %s failed", client->name); client 1096 lib/common/ipc.c crm_ipc_buffer(crm_ipc_t * client) client 1098 lib/common/ipc.c CRM_ASSERT(client != NULL); client 1099 lib/common/ipc.c return client->buffer + sizeof(struct crm_ipc_response_header); client 1103 lib/common/ipc.c crm_ipc_buffer_flags(crm_ipc_t * client) client 1107 lib/common/ipc.c CRM_ASSERT(client != NULL); client 1108 lib/common/ipc.c if (client->buffer == NULL) { client 1112 lib/common/ipc.c header = (struct crm_ipc_response_header *)(void*)client->buffer; client 1117 lib/common/ipc.c crm_ipc_name(crm_ipc_t * client) client 1119 lib/common/ipc.c CRM_ASSERT(client != NULL); client 1120 lib/common/ipc.c return client->name; client 1124 lib/common/ipc.c internal_ipc_send_recv(crm_ipc_t * client, const void *iov) client 1129 lib/common/ipc.c rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, client->buf_size, -1); client 1130 lib/common/ipc.c } while (rc == -EAGAIN && crm_ipc_connected(client)); client 1136 lib/common/ipc.c internal_ipc_send_request(crm_ipc_t * client, const void *iov, int ms_timeout) client 1142 lib/common/ipc.c rc = qb_ipcc_sendv(client->ipc, iov, 2); client 1143 lib/common/ipc.c } while (rc == -EAGAIN && time(NULL) < timeout && crm_ipc_connected(client)); client 1149 lib/common/ipc.c internal_ipc_get_reply(crm_ipc_t * client, int request_id, int ms_timeout) client 1157 lib/common/ipc.c crm_trace("client %s waiting on reply to msg id %d", client->name, request_id); client 1160 lib/common/ipc.c rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000); client 1164 lib/common/ipc.c int rc = crm_ipc_decompress(client); client 1170 lib/common/ipc.c hdr = (struct crm_ipc_response_header *)(void*)client->buffer; client 1175 lib/common/ipc.c xmlNode *bad = string2xml(crm_ipc_buffer(client)); client 1181 lib/common/ipc.c xmlNode *bad = string2xml(crm_ipc_buffer(client)); client 1187 lib/common/ipc.c } else if (crm_ipc_connected(client) == FALSE) { client 1188 lib/common/ipc.c crm_err("Server disconnected client %s while waiting for msg id %d", client->name, client 1199 lib/common/ipc.c crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags, int32_t ms_timeout, client 1210 lib/common/ipc.c if (client == NULL) { client 1214 lib/common/ipc.c } else if (crm_ipc_connected(client) == FALSE) { client 1216 lib/common/ipc.c crm_notice("Connection to %s closed", client->name); client 1224 lib/common/ipc.c if (client->need_reply) { client 1225 lib/common/ipc.c crm_trace("Trying again to obtain pending reply from %s", client->name); client 1226 lib/common/ipc.c rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout); client 1228 lib/common/ipc.c crm_warn("Sending to %s (%p) is disabled until pending reply is received", client->name, client 1229 lib/common/ipc.c client->ipc); client 1233 lib/common/ipc.c crm_notice("Lost reply from %s (%p) finally arrived, sending re-enabled", client->name, client 1234 lib/common/ipc.c client->ipc); client 1235 lib/common/ipc.c client->need_reply = FALSE; client 1241 lib/common/ipc.c rc = crm_ipc_prepare(id, message, &iov, client->max_buf_size); client 1255 lib/common/ipc.c if(factor < 10 && (client->max_buf_size / 10) < (rc / factor)) { client 1258 lib/common/ipc.c factor, client->max_buf_size, 2 * client->max_buf_size); client 1264 lib/common/ipc.c client->name, header->qb.id, header->qb.size, ms_timeout); client 1268 lib/common/ipc.c rc = internal_ipc_send_request(client, iov, ms_timeout); client 1272 lib/common/ipc.c client->name, header->qb.id, header->qb.size); client 1277 lib/common/ipc.c header->qb.id, client->name, header->qb.size); client 1282 lib/common/ipc.c rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout); client 1291 lib/common/ipc.c client->need_reply = TRUE; client 1295 lib/common/ipc.c rc = internal_ipc_send_recv(client, iov); client 1299 lib/common/ipc.c struct crm_ipc_response_header *hdr = (struct crm_ipc_response_header *)(void*)client->buffer; client 1302 lib/common/ipc.c rc, crm_ipc_buffer(client)); client 1305 lib/common/ipc.c *reply = string2xml(crm_ipc_buffer(client)); client 1313 lib/common/ipc.c if (crm_ipc_connected(client) == FALSE) { client 1314 lib/common/ipc.c crm_notice("Connection to %s closed: %s (%ld)", client->name, pcmk_strerror(rc), rc); client 1318 lib/common/ipc.c header->qb.id, client->name, client->ipc, pcmk_strerror(rc), rc, ms_timeout); client 1323 lib/common/ipc.c header->qb.id, client->name, client->ipc, pcmk_strerror(rc), rc); client 645 lib/common/mainloop.c mainloop_io_t *client = data; client 647 lib/common/mainloop.c CRM_ASSERT(client->fd == g_io_channel_unix_get_fd(gio)); client 650 lib/common/mainloop.c if (client->ipc) { client 655 lib/common/mainloop.c rc = crm_ipc_read(client->ipc); client 658 lib/common/mainloop.c client->name, client, pcmk_strerror(rc), rc); client 660 lib/common/mainloop.c } else if (client->dispatch_fn_ipc) { client 661 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); client 663 lib/common/mainloop.c crm_trace("New message from %s[%p] = %ld (I/O condition=%d)", client->name, client, rc, condition); client 664 lib/common/mainloop.c if (client->dispatch_fn_ipc(buffer, rc, client->userdata) < 0) { client 665 lib/common/mainloop.c crm_trace("Connection to %s no longer required", client->name); client 673 lib/common/mainloop.c crm_trace("New message from %s[%p] %u", client->name, client, condition); client 674 lib/common/mainloop.c if (client->dispatch_fn_io) { client 675 lib/common/mainloop.c if (client->dispatch_fn_io(client->userdata) < 0) { client 676 lib/common/mainloop.c crm_trace("Connection to %s no longer required", client->name); client 683 lib/common/mainloop.c if (client->ipc && crm_ipc_connected(client->ipc) == FALSE) { client 684 lib/common/mainloop.c crm_err("Connection to %s[%p] closed (I/O condition=%d)", client->name, client, condition); client 689 lib/common/mainloop.c client->name, client, condition); client 732 lib/common/mainloop.c mainloop_io_t *client = c; client 733 lib/common/mainloop.c char *c_name = strdup(client->name); client 740 lib/common/mainloop.c if (client->ipc) { client 741 lib/common/mainloop.c crm_ipc_close(client->ipc); client 744 lib/common/mainloop.c if (client->destroy_fn) { client 745 lib/common/mainloop.c void (*destroy_fn) (gpointer userdata) = client->destroy_fn; client 747 lib/common/mainloop.c client->destroy_fn = NULL; client 748 lib/common/mainloop.c destroy_fn(client->userdata); client 751 lib/common/mainloop.c if (client->ipc) { client 752 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; client 754 lib/common/mainloop.c client->ipc = NULL; client 760 lib/common/mainloop.c free(client->name); client->name = NULL; client 761 lib/common/mainloop.c free(client); client 770 lib/common/mainloop.c mainloop_io_t *client = NULL; client 776 lib/common/mainloop.c client = mainloop_add_fd(name, priority, fd, userdata, NULL); client 779 lib/common/mainloop.c if (client == NULL) { client 788 lib/common/mainloop.c client->ipc = conn; client 789 lib/common/mainloop.c client->destroy_fn = callbacks->destroy; client 790 lib/common/mainloop.c client->dispatch_fn_ipc = callbacks->dispatch; client 791 lib/common/mainloop.c return client; client 795 lib/common/mainloop.c mainloop_del_ipc_client(mainloop_io_t * client) client 797 lib/common/mainloop.c mainloop_del_fd(client); client 801 lib/common/mainloop.c mainloop_get_ipc_client(mainloop_io_t * client) client 803 lib/common/mainloop.c if (client) { client 804 lib/common/mainloop.c return client->ipc; client 813 lib/common/mainloop.c mainloop_io_t *client = NULL; client 816 lib/common/mainloop.c client = calloc(1, sizeof(mainloop_io_t)); client 817 lib/common/mainloop.c if (client == NULL) { client 820 lib/common/mainloop.c client->name = strdup(name); client 821 lib/common/mainloop.c client->userdata = userdata; client 824 lib/common/mainloop.c client->destroy_fn = callbacks->destroy; client 825 lib/common/mainloop.c client->dispatch_fn_io = callbacks->dispatch; client 828 lib/common/mainloop.c client->fd = fd; client 829 lib/common/mainloop.c client->channel = g_io_channel_unix_new(fd); client 830 lib/common/mainloop.c client->source = client 831 lib/common/mainloop.c g_io_add_watch_full(client->channel, priority, client 833 lib/common/mainloop.c client, mainloop_gio_destroy); client 844 lib/common/mainloop.c g_io_channel_unref(client->channel); client 845 lib/common/mainloop.c crm_trace("Added connection %d for %s[%p].%d", client->source, client->name, client, fd); client 850 lib/common/mainloop.c return client; client 854 lib/common/mainloop.c mainloop_del_fd(mainloop_io_t * client) client 856 lib/common/mainloop.c if (client != NULL) { client 857 lib/common/mainloop.c crm_trace("Removing client %s[%p]", client->name, client); client 858 lib/common/mainloop.c if (client->source) { client 862 lib/common/mainloop.c g_source_remove(client->source); client 1568 lib/fencing/st_client.c kvp->client = crm_element_value_copy(op, F_STONITH_CLIENTNAME); client 503 lib/services/dbus.c mainloop_io_t *client = dbus_watch_get_data(watch); client 505 lib/services/dbus.c crm_trace("Dispatching client %p: %s", client, dbus_watch_flags_to_string(flags)); client 515 lib/services/dbus.c crm_trace("Dispatched client %p: %s (%d)", client, client 521 lib/services/dbus.c client, dbus_watch_flags_to_string(flags)); client 533 lib/services/dbus.c mainloop_io_t *client = dbus_watch_get_data(userdata); client 534 lib/services/dbus.c crm_trace("Destroyed %p", client); client 548 lib/services/dbus.c mainloop_io_t *client = mainloop_add_fd( client 551 lib/services/dbus.c crm_trace("Added watch %p with fd=%d to client %p", watch, fd, client); client 552 lib/services/dbus.c dbus_watch_set_data(watch, client, NULL); client 559 lib/services/dbus.c mainloop_io_t *client = dbus_watch_get_data(watch); client 561 lib/services/dbus.c client, (dbus_watch_get_enabled(watch)? "enabled" : "disabled")); client 568 lib/services/dbus.c mainloop_io_t *client = dbus_watch_get_data(watch); client 570 lib/services/dbus.c crm_trace("Removed client %p (%p)", client, data); client 571 lib/services/dbus.c mainloop_del_fd(client); client 78 lrmd/ipc_proxy.c crm_client_t *client; client 91 lrmd/ipc_proxy.c client = crm_client_new(c, uid, gid); client 92 lrmd/ipc_proxy.c if (client == NULL) { client 98 lrmd/ipc_proxy.c client->userdata = strdup(ipc_proxy->id); client 99 lrmd/ipc_proxy.c client->name = crm_strdup_printf("proxy-%s-%d-%.8s", ipc_channel, client->pid, client->id); client 101 lrmd/ipc_proxy.c g_hash_table_insert(ipc_clients, client->id, client); client 106 lrmd/ipc_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id); client 109 lrmd/ipc_proxy.c crm_debug("created new ipc proxy with session id %s", client->id); client 225 lrmd/ipc_proxy.c crm_client_t *client = crm_client_get(c); client 226 lrmd/ipc_proxy.c crm_client_t *ipc_proxy = crm_client_get_by_id(client->userdata); client 231 lrmd/ipc_proxy.c qb_ipcs_disconnect(client->ipcs); client 246 lrmd/ipc_proxy.c request = crm_ipcs_recv(client, data, size, &id, &flags); client 252 lrmd/ipc_proxy.c CRM_CHECK(client != NULL, crm_err("Invalid client"); client 254 lrmd/ipc_proxy.c CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p", client); client 260 lrmd/ipc_proxy.c client->request_id = id; client 264 lrmd/ipc_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id); client 265 lrmd/ipc_proxy.c crm_xml_add(msg, F_LRMD_IPC_CLIENT, crm_client_name(client)); client 266 lrmd/ipc_proxy.c crm_xml_add(msg, F_LRMD_IPC_USER, client->user); client 304 lrmd/ipc_proxy.c crm_client_t *client = crm_client_get(c); client 307 lrmd/ipc_proxy.c if (client == NULL) { client 311 lrmd/ipc_proxy.c ipc_proxy = crm_client_get_by_id(client->userdata); client 318 lrmd/ipc_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id); client 323 lrmd/ipc_proxy.c g_hash_table_remove(ipc_clients, client->id); client 325 lrmd/ipc_proxy.c free(client->userdata); client 326 lrmd/ipc_proxy.c client->userdata = NULL; client 327 lrmd/ipc_proxy.c crm_client_destroy(client); client 165 lrmd/lrmd.c create_lrmd_cmd(xmlNode * msg, crm_client_t * client, lrmd_rsc_t *rsc) client 175 lrmd/lrmd.c cmd->client_id = strdup(client->id); client 376 lrmd/lrmd.c send_reply(crm_client_t * client, int rc, uint32_t id, int call_id) client 386 lrmd/lrmd.c send_rc = lrmd_server_send_reply(client, id, reply); client 390 lrmd/lrmd.c crm_warn("LRMD reply to %s failed: %d", client->name, send_rc); client 398 lrmd/lrmd.c crm_client_t *client = value; client 401 lrmd/lrmd.c if (client == NULL) { client 404 lrmd/lrmd.c } else if (client->name == NULL) { client 409 lrmd/lrmd.c rc = lrmd_server_send_notify(client, update_msg); client 412 lrmd/lrmd.c client->name, client->id, client 543 lrmd/lrmd.c crm_client_t *client = crm_client_get_by_id(cmd->client_id); client 545 lrmd/lrmd.c if (client) { client 546 lrmd/lrmd.c send_client_notify(client->id, client, notify); client 774 lrmd/lrmd.c crm_client_t *client = NULL; client 784 lrmd/lrmd.c while (g_hash_table_iter_next(&iter, (gpointer *) & key, (gpointer *) & client)) { client 786 lrmd/lrmd.c if (safe_str_eq(client->id, new_client->id)) { client 790 lrmd/lrmd.c send_client_notify((gpointer) key, (gpointer) client, (gpointer) notify); client 1374 lrmd/lrmd.c process_lrmd_signon(crm_client_t * client, uint32_t id, xmlNode * request) client 1387 lrmd/lrmd.c crm_xml_add(reply, F_LRMD_CLIENTID, client->id); client 1389 lrmd/lrmd.c lrmd_server_send_reply(client, id, reply); client 1394 lrmd/lrmd.c ipc_proxy_add_provider(client); client 1403 lrmd/lrmd.c process_lrmd_rsc_register(crm_client_t * client, uint32_t id, xmlNode * request) client 1428 lrmd/lrmd.c process_lrmd_get_rsc_info(crm_client_t * client, uint32_t id, xmlNode * request) client 1466 lrmd/lrmd.c send_rc = lrmd_server_send_reply(client, id, reply); client 1469 lrmd/lrmd.c crm_warn("LRMD reply to %s failed: %d", client->name, send_rc); client 1476 lrmd/lrmd.c process_lrmd_rsc_unregister(crm_client_t * client, uint32_t id, xmlNode * request) client 1505 lrmd/lrmd.c process_lrmd_rsc_exec(crm_client_t * client, uint32_t id, xmlNode * request) client 1522 lrmd/lrmd.c cmd = create_lrmd_cmd(request, client, rsc); client 1628 lrmd/lrmd.c process_lrmd_rsc_cancel(crm_client_t * client, uint32_t id, xmlNode * request) client 1645 lrmd/lrmd.c process_lrmd_message(crm_client_t * client, uint32_t id, xmlNode * request) client 1653 lrmd/lrmd.c crm_trace("Processing %s operation from %s", op, client->id); client 1658 lrmd/lrmd.c ipc_proxy_forward_client(client, request); client 1662 lrmd/lrmd.c rc = process_lrmd_signon(client, id, request); client 1664 lrmd/lrmd.c rc = process_lrmd_rsc_register(client, id, request); client 1668 lrmd/lrmd.c process_lrmd_get_rsc_info(client, id, request); client 1670 lrmd/lrmd.c rc = process_lrmd_rsc_unregister(client, id, request); client 1677 lrmd/lrmd.c rc = process_lrmd_rsc_exec(client, id, request); client 1680 lrmd/lrmd.c rc = process_lrmd_rsc_cancel(client, id, request); client 1691 lrmd/lrmd.c rc = process_lrmd_alert_exec(client, id, request); client 1696 lrmd/lrmd.c crm_err("Unknown %s from %s", op, client->name); client 1701 lrmd/lrmd.c op, client->id, rc, do_reply, do_notify); client 1704 lrmd/lrmd.c send_reply(client, rc, id, call_id); client 81 lrmd/lrmd_alert_api.c process_lrmd_alert_exec(crm_client_t *client, uint32_t id, xmlNode *request) client 103 lrmd/lrmd_alert_api.c crm_info("Executing alert %s for %s", alert_id, client->id); client 113 lrmd/lrmd_alert_api.c cb_data->client_id = strdup(client->id); client 73 lrmd/lrmd_private.h int lrmd_server_send_reply(crm_client_t * client, uint32_t id, xmlNode * reply); client 75 lrmd/lrmd_private.h int lrmd_server_send_notify(crm_client_t * client, xmlNode * msg); client 79 lrmd/lrmd_private.h void process_lrmd_message(crm_client_t * client, uint32_t id, xmlNode * request); client 87 lrmd/lrmd_private.h void lrmd_client_destroy(crm_client_t *client); client 107 lrmd/lrmd_private.h void ipc_proxy_add_provider(crm_client_t *client); client 108 lrmd/lrmd_private.h void ipc_proxy_remove_provider(crm_client_t *client); client 109 lrmd/lrmd_private.h void ipc_proxy_forward_client(crm_client_t *client, xmlNode *xml); client 114 lrmd/lrmd_private.h int process_lrmd_alert_exec(crm_client_t *client, uint32_t id, xmlNode *request); client 128 lrmd/main.c crm_client_t *client = crm_client_get(c); client 129 lrmd/main.c xmlNode *request = crm_ipcs_recv(client, data, size, &id, &flags); client 131 lrmd/main.c CRM_CHECK(client != NULL, crm_err("Invalid client"); client 133 lrmd/main.c CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p", client); client 136 lrmd/main.c CRM_CHECK(flags & crm_ipc_client_response, crm_err("Invalid client request: %p", client); client 143 lrmd/main.c if (!client->name) { client 147 lrmd/main.c client->name = crm_itoa(crm_ipcs_client_pid(c)); client 149 lrmd/main.c client->name = strdup(value); client 158 lrmd/main.c crm_xml_add(request, F_LRMD_CLIENTID, client->id); client 159 lrmd/main.c crm_xml_add(request, F_LRMD_CLIENTNAME, client->name); client 162 lrmd/main.c process_lrmd_message(client, id, request); client 175 lrmd/main.c lrmd_client_destroy(crm_client_t *client) client 177 lrmd/main.c crm_client_destroy(client); client 192 lrmd/main.c crm_client_t *client = crm_client_get(c); client 194 lrmd/main.c if (client == NULL) { client 199 lrmd/main.c client_disconnect_cleanup(client->id); client 201 lrmd/main.c ipc_proxy_remove_provider(client); client 203 lrmd/main.c lrmd_client_destroy(client); client 223 lrmd/main.c lrmd_server_send_reply(crm_client_t * client, uint32_t id, xmlNode * reply) client 226 lrmd/main.c crm_trace("Sending reply (%d) to client (%s)", id, client->id); client 227 lrmd/main.c switch (client->kind) { client 229 lrmd/main.c return crm_ipcs_send(client, id, reply, FALSE); client 232 lrmd/main.c return lrmd_tls_send_msg(client->remote, reply, id, "reply"); client 236 lrmd/main.c client->kind); client 242 lrmd/main.c lrmd_server_send_notify(crm_client_t * client, xmlNode * msg) client 244 lrmd/main.c crm_trace("Sending notification to client (%s)", client->id); client 245 lrmd/main.c switch (client->kind) { client 247 lrmd/main.c if (client->ipcs == NULL) { client 251 lrmd/main.c return crm_ipcs_send(client, 0, msg, crm_ipc_server_event); client 254 lrmd/main.c if (client->remote == NULL) { client 258 lrmd/main.c return lrmd_tls_send_msg(client->remote, msg, 0, "notify"); client 261 lrmd/main.c crm_err("Could not notify client: unknown type %d", client->kind); client 59 lrmd/tls_backend.c crm_client_t *client = data; client 61 lrmd/tls_backend.c if (client->remote->tls_handshake_complete == FALSE) { client 67 lrmd/tls_backend.c rc = gnutls_handshake(*client->remote->tls_session); client 77 lrmd/tls_backend.c client->remote->tls_handshake_complete = TRUE; client 78 lrmd/tls_backend.c if (client->remote->auth_timeout) { client 79 lrmd/tls_backend.c g_source_remove(client->remote->auth_timeout); client 81 lrmd/tls_backend.c client->remote->auth_timeout = 0; client 84 lrmd/tls_backend.c notify_of_new_client(client); client 89 lrmd/tls_backend.c rc = crm_remote_ready(client->remote, 0); client 98 lrmd/tls_backend.c crm_remote_recv(client->remote, -1, &disconnected); client 100 lrmd/tls_backend.c request = crm_remote_parse_buffer(client->remote); client 104 lrmd/tls_backend.c if (!client->name) { client 108 lrmd/tls_backend.c client->name = strdup(value); client 117 lrmd/tls_backend.c crm_xml_add(request, F_LRMD_CLIENTID, client->id); client 118 lrmd/tls_backend.c crm_xml_add(request, F_LRMD_CLIENTNAME, client->name); client 121 lrmd/tls_backend.c process_lrmd_message(client, id, request); client 125 lrmd/tls_backend.c request = crm_remote_parse_buffer(client->remote); client 139 lrmd/tls_backend.c crm_client_t *client = user_data; client 141 lrmd/tls_backend.c if (client == NULL) { client 145 lrmd/tls_backend.c ipc_proxy_remove_provider(client); client 154 lrmd/tls_backend.c client->name ? client->name : "<unknown>", client->id); client 156 lrmd/tls_backend.c if (client->remote->tls_session) { client 160 lrmd/tls_backend.c sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session); client 163 lrmd/tls_backend.c gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_RDWR); client 164 lrmd/tls_backend.c gnutls_deinit(*client->remote->tls_session); client 165 lrmd/tls_backend.c gnutls_free(client->remote->tls_session); client 169 lrmd/tls_backend.c lrmd_client_destroy(client); client 176 lrmd/tls_backend.c crm_client_t *client = data; client 178 lrmd/tls_backend.c client->remote->auth_timeout = 0; client 180 lrmd/tls_backend.c if (client->remote->tls_handshake_complete == TRUE) { client 184 lrmd/tls_backend.c mainloop_del_fd(client->remote->source); client 185 lrmd/tls_backend.c client->remote->source = NULL; client 83 mcp/pacemaker.c void update_process_clients(crm_client_t *client); client 529 mcp/pacemaker.c crm_client_t *client = crm_client_get(c); client 531 mcp/pacemaker.c if (client == NULL) { client 535 mcp/pacemaker.c crm_client_destroy(client); client 561 mcp/pacemaker.c update_process_clients(crm_client_t *client) client 581 mcp/pacemaker.c if(client) { client 582 mcp/pacemaker.c crm_trace("Sending process list to client %s", client->id); client 583 mcp/pacemaker.c crm_ipcs_send(client, 0, update, crm_ipc_server_event); client 588 mcp/pacemaker.c while (g_hash_table_iter_next(&iter, NULL, (gpointer *) & client)) { client 589 mcp/pacemaker.c crm_ipcs_send(client, 0, update, crm_ipc_server_event); client 86 pengine/main.c crm_client_t *client = crm_client_get(c); client 88 pengine/main.c if (client == NULL) { client 92 pengine/main.c crm_client_destroy(client); client 2314 tools/crm_mon.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); client 2321 tools/crm_mon.c print_as((user || client || origin)? "\n" : "\t\t"); client 2326 tools/crm_mon.c if (client) { client 2327 tools/crm_mon.c print_as(" via %s", client); client 2342 tools/crm_mon.c if (client) { client 2343 tools/crm_mon.c fprintf(stream, " via %s", client); client 2355 tools/crm_mon.c client ? client : "", origin ? origin : "");