client 465 daemons/attrd/attrd_commands.c attrd_client_query(pcmk__client_t *client, uint32_t id, uint32_t flags, client 496 daemons/attrd/attrd_commands.c client->request_id = 0; client 498 daemons/attrd/attrd_commands.c int rc = pcmk__ipc_send_xml(client, id, reply, flags); client 130 daemons/attrd/attrd_utils.c pcmk__client_t *client = pcmk__find_client(c); client 132 daemons/attrd/attrd_utils.c if (client == NULL) { client 136 daemons/attrd/attrd_utils.c pcmk__free_client(client); client 227 daemons/attrd/pacemaker-attrd.c pcmk__client_t *client = pcmk__find_client(c); client 232 daemons/attrd/pacemaker-attrd.c CRM_CHECK((c != NULL) && (client != NULL), return 0); client 237 daemons/attrd/pacemaker-attrd.c xml = pcmk__client_data2xml(client, data, &id, &flags); client 244 daemons/attrd/pacemaker-attrd.c CRM_ASSERT(client->user != NULL); client 245 daemons/attrd/pacemaker-attrd.c pcmk__update_acl_user(xml, PCMK__XA_ATTR_USER, client->user); client 250 daemons/attrd/pacemaker-attrd.c if (client->name == NULL) { client 252 daemons/attrd/pacemaker-attrd.c client->name = crm_strdup_printf("%s.%d", value?value:"unknown", client->pid); client 256 daemons/attrd/pacemaker-attrd.c attrd_send_ack(client, id, flags); client 257 daemons/attrd/pacemaker-attrd.c attrd_client_peer_remove(client->name, xml); client 260 daemons/attrd/pacemaker-attrd.c attrd_send_ack(client, id, flags); client 264 daemons/attrd/pacemaker-attrd.c attrd_send_ack(client, id, flags); client 268 daemons/attrd/pacemaker-attrd.c attrd_send_ack(client, id, flags); client 272 daemons/attrd/pacemaker-attrd.c attrd_send_ack(client, id, flags); client 276 daemons/attrd/pacemaker-attrd.c attrd_send_ack(client, id, flags); client 281 daemons/attrd/pacemaker-attrd.c attrd_client_query(client, id, flags, xml); client 285 daemons/attrd/pacemaker-attrd.c client->name, op); client 115 daemons/attrd/pacemaker-attrd.h #define attrd_send_ack(client, id, flags) \ client 116 daemons/attrd/pacemaker-attrd.h pcmk__ipc_send_ack((client), (id), (flags), "ack", CRM_EX_INDETERMINATE) client 122 daemons/attrd/pacemaker-attrd.h void attrd_peer_message(crm_node_t *client, xmlNode *msg); client 127 daemons/attrd/pacemaker-attrd.h void attrd_client_query(pcmk__client_t *client, uint32_t id, uint32_t flags, client 87 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); client 89 daemons/based/based_callbacks.c crm_trace("%p message from %s", c, client->id); client 96 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); client 98 daemons/based/based_callbacks.c crm_trace("%p message from %s", c, client->id); client 106 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); client 108 daemons/based/based_callbacks.c if (client == NULL) { client 112 daemons/based/based_callbacks.c pcmk__free_client(client); client 1327 daemons/based/based_callbacks.c const char *client = crm_element_value(request, F_CIB_CLIENTNAME); client 1331 daemons/based/based_callbacks.c cib_diff_notify(call_options, client, call_id, op, input, rc, *cib_diff); client 51 daemons/based/based_notify.c pcmk__client_t *client = value; client 54 daemons/based/based_notify.c if (client->ipcs == NULL && client->remote == NULL) { client 62 daemons/based/based_notify.c if (pcmk_is_set(client->flags, cib_notify_diff) client 67 daemons/based/based_notify.c } else if (pcmk_is_set(client->flags, cib_notify_replace) client 71 daemons/based/based_notify.c } else if (pcmk_is_set(client->flags, cib_notify_confirm) client 75 daemons/based/based_notify.c } else if (pcmk_is_set(client->flags, cib_notify_pre) client 79 daemons/based/based_notify.c } else if (pcmk_is_set(client->flags, cib_notify_post) client 86 daemons/based/based_notify.c switch (PCMK__CLIENT_TYPE(client)) { client 88 daemons/based/based_notify.c if (pcmk__ipc_send_iov(client, update->iov, client 90 daemons/based/based_notify.c crm_warn("Notification of client %s/%s failed", client->name, client->id); client 97 daemons/based/based_notify.c crm_debug("Sent %s notification to client %s/%s", type, client->name, client->id); client 98 daemons/based/based_notify.c pcmk__remote_send_xml(client->remote, update->msg); client 102 daemons/based/based_notify.c pcmk__client_name(client), client 103 daemons/based/based_notify.c (unsigned long long) client->flags); client 131 daemons/based/based_notify.c cib_diff_notify(int options, const char *client, const char *call_id, const char *op, client 158 daemons/based/based_notify.c client, call_id ? ", call:" : "", call_id ? call_id : "", client 165 daemons/based/based_notify.c client, call_id ? ", call: " : "", call_id ? call_id : "", client 263 daemons/based/based_remote.c pcmk__client_t *client = data; client 265 daemons/based/based_remote.c client->remote->auth_timeout = 0; client 267 daemons/based/based_remote.c if (client->remote->authenticated == TRUE) { client 271 daemons/based/based_remote.c mainloop_del_fd(client->remote->source); client 356 daemons/based/based_remote.c pcmk__client_t *client = user_data; client 359 daemons/based/based_remote.c if (client == NULL) { client 363 daemons/based/based_remote.c crm_trace("Cleaning up after client disconnect: %s/%s", crm_str(client->name), client->id); client 368 daemons/based/based_remote.c switch (PCMK__CLIENT_TYPE(client)) { client 370 daemons/based/based_remote.c csock = client->remote->tcp_socket; client 374 daemons/based/based_remote.c if (client->remote->tls_session) { client 375 daemons/based/based_remote.c void *sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session); client 378 daemons/based/based_remote.c if (client->remote->tls_handshake_complete) { client 379 daemons/based/based_remote.c gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_WR); client 381 daemons/based/based_remote.c gnutls_deinit(*client->remote->tls_session); client 382 daemons/based/based_remote.c gnutls_free(client->remote->tls_session); client 383 daemons/based/based_remote.c client->remote->tls_session = NULL; client 389 daemons/based/based_remote.c pcmk__client_name(client), client 390 daemons/based/based_remote.c (unsigned long long) client->flags); client 397 daemons/based/based_remote.c pcmk__free_client(client); client 408 daemons/based/based_remote.c cib_handle_remote_msg(pcmk__client_t *client, xmlNode *command) client 418 daemons/based/based_remote.c if (client->name == NULL) { client 421 daemons/based/based_remote.c client->name = strdup(client->id); client 423 daemons/based/based_remote.c client->name = strdup(value); client 427 daemons/based/based_remote.c if (client->userdata == NULL) { client 430 daemons/based/based_remote.c client->userdata = strdup(value); client 431 daemons/based/based_remote.c crm_trace("Callback channel for %s is %s", client->id, (char*)client->userdata); client 434 daemons/based/based_remote.c client->userdata = strdup(client->id); client 444 daemons/based/based_remote.c crm_xml_add(command, F_CIB_CLIENTID, client->id); client 445 daemons/based/based_remote.c crm_xml_add(command, F_CIB_CLIENTNAME, client->name); client 447 daemons/based/based_remote.c crm_xml_add(command, F_CIB_USER, client->user); client 463 daemons/based/based_remote.c cib_common_callback_worker(0, 0, command, client, TRUE); client 470 daemons/based/based_remote.c pcmk__client_t *client = data; client 472 daemons/based/based_remote.c int timeout = client->remote->authenticated ? -1 : 1000; client 475 daemons/based/based_remote.c pcmk__client_type_str(PCMK__CLIENT_TYPE(client)), client 476 daemons/based/based_remote.c pcmk__client_name(client)); client 479 daemons/based/based_remote.c if ((PCMK__CLIENT_TYPE(client) == pcmk__client_tls) client 480 daemons/based/based_remote.c && !(client->remote->tls_handshake_complete)) { client 482 daemons/based/based_remote.c int rc = pcmk__read_handshake_data(client); client 494 daemons/based/based_remote.c client->remote->tls_handshake_complete = TRUE; client 495 daemons/based/based_remote.c if (client->remote->auth_timeout) { client 496 daemons/based/based_remote.c g_source_remove(client->remote->auth_timeout); client 500 daemons/based/based_remote.c client->remote->auth_timeout = g_timeout_add(REMOTE_AUTH_TIMEOUT, client 502 daemons/based/based_remote.c client); client 507 daemons/based/based_remote.c rc = pcmk__read_remote_message(client->remote, timeout); client 510 daemons/based/based_remote.c if (client->remote->authenticated == FALSE) { client 516 daemons/based/based_remote.c command = pcmk__remote_message_xml(client->remote); client 523 daemons/based/based_remote.c client->remote->authenticated = TRUE; client 524 daemons/based/based_remote.c g_source_remove(client->remote->auth_timeout); client 525 daemons/based/based_remote.c client->remote->auth_timeout = 0; client 526 daemons/based/based_remote.c client->name = crm_element_value_copy(command, "name"); client 531 daemons/based/based_remote.c client->user = strdup(user); client 538 daemons/based/based_remote.c crm_xml_add(reg, F_CIB_CLIENTID, client->id); client 539 daemons/based/based_remote.c pcmk__remote_send_xml(client->remote, reg); client 544 daemons/based/based_remote.c command = pcmk__remote_message_xml(client->remote); client 547 daemons/based/based_remote.c cib_handle_remote_msg(client, command); client 549 daemons/based/based_remote.c command = pcmk__remote_message_xml(client->remote); client 147 daemons/based/pacemaker-based.h void cib_diff_notify(int options, const char *client, const char *call_id, client 377 daemons/controld/controld_control.c pcmk__client_t *client = pcmk__find_client(c); client 379 daemons/controld/controld_control.c xmlNode *msg = pcmk__client_data2xml(client, data, &id, &flags); client 382 daemons/controld/controld_control.c pcmk__ipc_send_ack(client, id, flags, "ack", CRM_EX_PROTOCOL); client 385 daemons/controld/controld_control.c pcmk__ipc_send_ack(client, id, flags, "ack", CRM_EX_INDETERMINATE); client 388 daemons/controld/controld_control.c CRM_ASSERT(client->user != NULL); client 389 daemons/controld/controld_control.c pcmk__update_acl_user(msg, F_CRM_USER, client->user); client 392 daemons/controld/controld_control.c crm_xml_add(msg, F_CRM_SYS_FROM, client->id); client 393 daemons/controld/controld_control.c if (controld_authorize_ipc_message(msg, client, NULL)) { client 394 daemons/controld/controld_control.c crm_trace("Processing IPC message from %s", pcmk__client_name(client)); client 406 daemons/controld/controld_control.c pcmk__client_t *client = pcmk__find_client(c); client 408 daemons/controld/controld_control.c if (client) { client 410 daemons/controld/controld_control.c (client->userdata? "" : "un"), pcmk__client_name(client), client 411 daemons/controld/controld_control.c c, client); client 412 daemons/controld/controld_control.c free(client->userdata); client 413 daemons/controld/controld_control.c pcmk__free_client(client); client 83 daemons/execd/execd_alerts.c process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id, xmlNode *request) client 97 daemons/execd/execd_alerts.c (client == NULL) || (client->id == NULL)) { /* hint static analyzer */ client 106 daemons/execd/execd_alerts.c crm_info("Executing alert %s for %s", alert_id, client->id); client 117 daemons/execd/execd_alerts.c cb_data->client_id = strdup(client->id); client 265 daemons/execd/execd_commands.c create_lrmd_cmd(xmlNode *msg, pcmk__client_t *client) client 275 daemons/execd/execd_commands.c cmd->client_id = strdup(client->id); client 503 daemons/execd/execd_commands.c pcmk__client_t *client = value; client 508 daemons/execd/execd_commands.c CRM_CHECK(client != NULL, return); client 509 daemons/execd/execd_commands.c if (client->name == NULL) { client 513 daemons/execd/execd_commands.c if (pcmk_is_set(client->flags, pcmk__client_to_proxy)) { client 519 daemons/execd/execd_commands.c client->name); client 523 daemons/execd/execd_commands.c rc = lrmd_server_send_notify(client, update_msg); client 541 daemons/execd/execd_commands.c client->name, client->id, msg, rc); client 619 daemons/execd/execd_commands.c pcmk__client_t *client = pcmk__find_client_by_id(cmd->client_id); client 621 daemons/execd/execd_commands.c if (client) { client 622 daemons/execd/execd_commands.c send_client_notify(client->id, client, notify); client 823 daemons/execd/execd_commands.c pcmk__client_t *client = value; client 826 daemons/execd/execd_commands.c if (!pcmk__str_eq(client->id, data->new_client->id, pcmk__str_casei)) { client 827 daemons/execd/execd_commands.c send_client_notify(key, (gpointer) client, (gpointer) data->notify); client 1515 daemons/execd/execd_commands.c process_lrmd_signon(pcmk__client_t *client, xmlNode *request, int call_id, client 1530 daemons/execd/execd_commands.c if ((client->remote != NULL) && client->remote->tls_handshake_complete) { client 1532 daemons/execd/execd_commands.c ipc_proxy_add_provider(client); client 1543 daemons/execd/execd_commands.c crm_xml_add(*reply, F_LRMD_CLIENTID, client->id); client 1550 daemons/execd/execd_commands.c process_lrmd_rsc_register(pcmk__client_t *client, uint32_t id, xmlNode *request) client 1600 daemons/execd/execd_commands.c process_lrmd_rsc_unregister(pcmk__client_t *client, uint32_t id, client 1632 daemons/execd/execd_commands.c process_lrmd_rsc_exec(pcmk__client_t *client, uint32_t id, xmlNode *request) client 1649 daemons/execd/execd_commands.c cmd = create_lrmd_cmd(request, client); client 1761 daemons/execd/execd_commands.c process_lrmd_rsc_cancel(pcmk__client_t *client, uint32_t id, xmlNode *request) client 1841 daemons/execd/execd_commands.c process_lrmd_message(pcmk__client_t *client, uint32_t id, xmlNode *request) client 1855 daemons/execd/execd_commands.c bool allowed = pcmk_is_set(client->flags, pcmk__client_privileged); client 1860 daemons/execd/execd_commands.c crm_trace("Processing %s operation from %s", op, client->id); client 1866 daemons/execd/execd_commands.c ipc_proxy_forward_client(client, request); client 1875 daemons/execd/execd_commands.c rc = process_lrmd_signon(client, request, call_id, &reply); client 1879 daemons/execd/execd_commands.c rc = process_lrmd_rsc_register(client, id, request); client 1894 daemons/execd/execd_commands.c rc = process_lrmd_rsc_unregister(client, id, request); client 1905 daemons/execd/execd_commands.c rc = process_lrmd_rsc_exec(client, id, request); client 1912 daemons/execd/execd_commands.c rc = process_lrmd_rsc_cancel(client, id, request); client 1931 daemons/execd/execd_commands.c rc = process_lrmd_alert_exec(client, id, request); client 1946 daemons/execd/execd_commands.c crm_err("Unknown IPC request '%s' from %s", op, client->name); client 1951 daemons/execd/execd_commands.c op, pcmk__client_name(client)); client 1955 daemons/execd/execd_commands.c op, client->id, rc, do_reply, do_notify); client 1963 daemons/execd/execd_commands.c send_rc = lrmd_server_send_reply(client, id, reply); client 1967 daemons/execd/execd_commands.c client->name, pcmk_rc_str(send_rc), send_rc); client 113 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); client 114 daemons/execd/pacemaker-execd.c xmlNode *request = pcmk__client_data2xml(client, data, &id, &flags); client 116 daemons/execd/pacemaker-execd.c CRM_CHECK(client != NULL, crm_err("Invalid client"); client 118 daemons/execd/pacemaker-execd.c CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p", client); client 121 daemons/execd/pacemaker-execd.c CRM_CHECK(flags & crm_ipc_client_response, crm_err("Invalid client request: %p", client); client 128 daemons/execd/pacemaker-execd.c if (!client->name) { client 132 daemons/execd/pacemaker-execd.c client->name = crm_itoa(pcmk__client_pid(c)); client 134 daemons/execd/pacemaker-execd.c client->name = strdup(value); client 143 daemons/execd/pacemaker-execd.c crm_xml_add(request, F_LRMD_CLIENTID, client->id); client 144 daemons/execd/pacemaker-execd.c crm_xml_add(request, F_LRMD_CLIENTNAME, client->name); client 147 daemons/execd/pacemaker-execd.c process_lrmd_message(client, id, request); client 160 daemons/execd/pacemaker-execd.c lrmd_client_destroy(pcmk__client_t *client) client 162 daemons/execd/pacemaker-execd.c pcmk__free_client(client); client 177 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); client 179 daemons/execd/pacemaker-execd.c if (client == NULL) { client 184 daemons/execd/pacemaker-execd.c client_disconnect_cleanup(client->id); client 186 daemons/execd/pacemaker-execd.c ipc_proxy_remove_provider(client); client 188 daemons/execd/pacemaker-execd.c lrmd_client_destroy(client); client 209 daemons/execd/pacemaker-execd.c lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply) client 211 daemons/execd/pacemaker-execd.c crm_trace("Sending reply (%d) to client (%s)", id, client->id); client 212 daemons/execd/pacemaker-execd.c switch (PCMK__CLIENT_TYPE(client)) { client 214 daemons/execd/pacemaker-execd.c return pcmk__ipc_send_xml(client, id, reply, FALSE); client 217 daemons/execd/pacemaker-execd.c return lrmd_tls_send_msg(client->remote, reply, id, "reply"); client 222 daemons/execd/pacemaker-execd.c pcmk__client_name(client), client->flags); client 229 daemons/execd/pacemaker-execd.c lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg) client 231 daemons/execd/pacemaker-execd.c crm_trace("Sending notification to client (%s)", client->id); client 232 daemons/execd/pacemaker-execd.c switch (PCMK__CLIENT_TYPE(client)) { client 234 daemons/execd/pacemaker-execd.c if (client->ipcs == NULL) { client 238 daemons/execd/pacemaker-execd.c return pcmk__ipc_send_xml(client, 0, msg, crm_ipc_server_event); client 241 daemons/execd/pacemaker-execd.c if (client->remote == NULL) { client 245 daemons/execd/pacemaker-execd.c return lrmd_tls_send_msg(client->remote, msg, 0, "notify"); client 251 daemons/execd/pacemaker-execd.c pcmk__client_name(client), client->flags); client 56 daemons/execd/pacemaker-execd.h int lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply); client 58 daemons/execd/pacemaker-execd.h int lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg); client 62 daemons/execd/pacemaker-execd.h void process_lrmd_message(pcmk__client_t *client, uint32_t id, client 71 daemons/execd/pacemaker-execd.h void lrmd_client_destroy(pcmk__client_t *client); client 91 daemons/execd/pacemaker-execd.h void ipc_proxy_add_provider(pcmk__client_t *client); client 92 daemons/execd/pacemaker-execd.h void ipc_proxy_remove_provider(pcmk__client_t *client); client 93 daemons/execd/pacemaker-execd.h void ipc_proxy_forward_client(pcmk__client_t *client, xmlNode *xml); client 99 daemons/execd/pacemaker-execd.h int process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id, client 68 daemons/execd/remoted_proxy.c pcmk__client_t *client; client 81 daemons/execd/remoted_proxy.c client = pcmk__new_client(c, uid, gid); client 82 daemons/execd/remoted_proxy.c if (client == NULL) { client 88 daemons/execd/remoted_proxy.c client->userdata = strdup(ipc_proxy->id); client 89 daemons/execd/remoted_proxy.c client->name = crm_strdup_printf("proxy-%s-%d-%.8s", ipc_channel, client->pid, client->id); client 94 daemons/execd/remoted_proxy.c pcmk__set_client_flags(client, pcmk__client_to_proxy); client 96 daemons/execd/remoted_proxy.c g_hash_table_insert(ipc_clients, client->id, client); client 101 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id); client 106 daemons/execd/remoted_proxy.c client->id, uid, gid, ipc_channel); client 219 daemons/execd/remoted_proxy.c pcmk__client_t *client = pcmk__find_client(c); client 220 daemons/execd/remoted_proxy.c pcmk__client_t *ipc_proxy = pcmk__find_client_by_id(client->userdata); client 225 daemons/execd/remoted_proxy.c qb_ipcs_disconnect(client->ipcs); client 242 daemons/execd/remoted_proxy.c request = pcmk__client_data2xml(client, data, &id, &flags); client 248 daemons/execd/remoted_proxy.c CRM_CHECK(client != NULL, crm_err("Invalid client"); client 250 daemons/execd/remoted_proxy.c CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p", client); client 256 daemons/execd/remoted_proxy.c pcmk__set_ipc_flags(flags, pcmk__client_name(client), crm_ipc_proxied); client 257 daemons/execd/remoted_proxy.c client->request_id = id; client 261 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id); client 262 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_CLIENT, pcmk__client_name(client)); client 263 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_USER, client->user); client 301 daemons/execd/remoted_proxy.c pcmk__client_t *client = pcmk__find_client(c); client 304 daemons/execd/remoted_proxy.c if (client == NULL) { client 308 daemons/execd/remoted_proxy.c ipc_proxy = pcmk__find_client_by_id(client->userdata); client 315 daemons/execd/remoted_proxy.c crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id); client 320 daemons/execd/remoted_proxy.c g_hash_table_remove(ipc_clients, client->id); client 322 daemons/execd/remoted_proxy.c free(client->userdata); client 323 daemons/execd/remoted_proxy.c client->userdata = NULL; client 324 daemons/execd/remoted_proxy.c pcmk__free_client(client); client 54 daemons/execd/remoted_tls.c remoted__read_handshake_data(pcmk__client_t *client) client 56 daemons/execd/remoted_tls.c int rc = pcmk__read_handshake_data(client); client 67 daemons/execd/remoted_tls.c if (client->remote->auth_timeout) { client 68 daemons/execd/remoted_tls.c g_source_remove(client->remote->auth_timeout); client 70 daemons/execd/remoted_tls.c client->remote->auth_timeout = 0; client 72 daemons/execd/remoted_tls.c client->remote->tls_handshake_complete = TRUE; client 78 daemons/execd/remoted_tls.c pcmk__set_client_flags(client, pcmk__client_privileged); client 81 daemons/execd/remoted_tls.c notify_of_new_client(client); client 91 daemons/execd/remoted_tls.c pcmk__client_t *client = data; client 93 daemons/execd/remoted_tls.c if (client->remote->tls_handshake_complete == FALSE) { client 94 daemons/execd/remoted_tls.c return remoted__read_handshake_data(client); client 97 daemons/execd/remoted_tls.c switch (pcmk__remote_ready(client->remote, 0)) { client 107 daemons/execd/remoted_tls.c rc = pcmk__read_remote_message(client->remote, -1); client 109 daemons/execd/remoted_tls.c request = pcmk__remote_message_xml(client->remote); client 113 daemons/execd/remoted_tls.c if (!client->name) { client 117 daemons/execd/remoted_tls.c client->name = strdup(value); client 126 daemons/execd/remoted_tls.c crm_xml_add(request, F_LRMD_CLIENTID, client->id); client 127 daemons/execd/remoted_tls.c crm_xml_add(request, F_LRMD_CLIENTNAME, client->name); client 130 daemons/execd/remoted_tls.c process_lrmd_message(client, id, request); client 134 daemons/execd/remoted_tls.c request = pcmk__remote_message_xml(client->remote); client 148 daemons/execd/remoted_tls.c pcmk__client_t *client = user_data; client 150 daemons/execd/remoted_tls.c if (client == NULL) { client 156 daemons/execd/remoted_tls.c (client->name? client->name : ""), client->id); client 158 daemons/execd/remoted_tls.c ipc_proxy_remove_provider(client); client 166 daemons/execd/remoted_tls.c if (client->remote->tls_session) { client 170 daemons/execd/remoted_tls.c sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session); client 173 daemons/execd/remoted_tls.c gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_RDWR); client 174 daemons/execd/remoted_tls.c gnutls_deinit(*client->remote->tls_session); client 175 daemons/execd/remoted_tls.c gnutls_free(client->remote->tls_session); client 179 daemons/execd/remoted_tls.c lrmd_client_destroy(client); client 186 daemons/execd/remoted_tls.c pcmk__client_t *client = data; client 188 daemons/execd/remoted_tls.c client->remote->auth_timeout = 0; client 190 daemons/execd/remoted_tls.c if (client->remote->tls_handshake_complete == TRUE) { client 194 daemons/execd/remoted_tls.c mainloop_del_fd(client->remote->source); client 195 daemons/execd/remoted_tls.c client->remote->source = NULL; client 86 daemons/fenced/fenced_commands.c char *client; client 222 daemons/fenced/fenced_commands.c free(cmd->client); client 250 daemons/fenced/fenced_commands.c cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID); client 259 daemons/fenced/fenced_commands.c CRM_CHECK(cmd->client != NULL, crm_log_xml_warn(msg, "NoClient")); client 506 daemons/fenced/fenced_commands.c device->id, cmd->client, cmd->timeout); client 986 daemons/fenced/fenced_commands.c cmd->client = strdup(crm_system_name); client 2094 daemons/fenced/fenced_commands.c do_local_reply(reply, cmd->client, cmd->options & st_opt_sync_call, FALSE); client 2107 daemons/fenced/fenced_commands.c crm_xml_add(notify_data, F_STONITH_ORIGIN, cmd->client); client 2219 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->client, cmd_other->client, pcmk__str_casei) || client 2404 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTID, cmd->client); client 2537 daemons/fenced/fenced_commands.c handle_request(pcmk__client_t *client, uint32_t id, uint32_t flags, client 2557 daemons/fenced/fenced_commands.c bool allowed = (client == NULL) client 2558 daemons/fenced/fenced_commands.c || pcmk_is_set(client->flags, pcmk__client_privileged); client 2566 daemons/fenced/fenced_commands.c CRM_ASSERT(client == NULL || client->request_id == id); client 2572 daemons/fenced/fenced_commands.c CRM_ASSERT(client); client 2574 daemons/fenced/fenced_commands.c crm_xml_add(reply, F_STONITH_CLIENTID, client->id); client 2575 daemons/fenced/fenced_commands.c pcmk__ipc_send_xml(client, id, reply, flags); client 2576 daemons/fenced/fenced_commands.c client->request_id = 0; client 2606 daemons/fenced/fenced_commands.c CRM_ASSERT(client); client 2610 daemons/fenced/fenced_commands.c flag_name, client->name, client->id); client 2611 daemons/fenced/fenced_commands.c pcmk__set_client_flags(client, get_stonith_flag(flag_name)); client 2617 daemons/fenced/fenced_commands.c flag_name, client->name, client->id); client 2618 daemons/fenced/fenced_commands.c pcmk__clear_client_flags(client, get_stonith_flag(flag_name)); client 2621 daemons/fenced/fenced_commands.c pcmk__ipc_send_ack(client, id, flags, "ack", CRM_EX_OK); client 2629 daemons/fenced/fenced_commands.c client ? client->name : remote_peer, client 2648 daemons/fenced/fenced_commands.c rop = initiate_remote_stonith_op(client, request, TRUE); client 2658 daemons/fenced/fenced_commands.c if (client) { client 2662 daemons/fenced/fenced_commands.c client->name, client->id, action, target, device ? device : "(any)"); client 2678 daemons/fenced/fenced_commands.c if (alternate_host && client) { client 2684 daemons/fenced/fenced_commands.c if (client->id) { client 2685 daemons/fenced/fenced_commands.c client_id = client->id; client 2695 daemons/fenced/fenced_commands.c crm_xml_add(request, F_STONITH_CLIENTID, client->id); client 2701 daemons/fenced/fenced_commands.c } else if (initiate_remote_stonith_op(client, request, FALSE) != NULL) { client 2770 daemons/fenced/fenced_commands.c op, (client? client->name : remote_peer)); client 2777 daemons/fenced/fenced_commands.c crm_str(op), pcmk__client_name(client)); client 2784 daemons/fenced/fenced_commands.c crm_trace("Reply handling: %p %u %u %d %d %s", client, client?client->request_id:0, client 2789 daemons/fenced/fenced_commands.c CRM_ASSERT(client == NULL || client->request_id == id); client 2803 daemons/fenced/fenced_commands.c handle_reply(pcmk__client_t *client, xmlNode *request, const char *remote_peer) client 2815 daemons/fenced/fenced_commands.c crm_err("Unknown %s reply from %s", op, client ? client->name : remote_peer); client 2821 daemons/fenced/fenced_commands.c stonith_command(pcmk__client_t *client, uint32_t id, uint32_t flags, client 2845 daemons/fenced/fenced_commands.c id, client ? client->name : remote_peer, call_options); client 2848 daemons/fenced/fenced_commands.c CRM_ASSERT(client == NULL || client->request_id == id); client 2852 daemons/fenced/fenced_commands.c handle_reply(client, request, remote_peer); client 2854 daemons/fenced/fenced_commands.c rc = handle_request(client, id, flags, request, remote_peer); client 2858 daemons/fenced/fenced_commands.c is_reply ? " reply" : "", client ? client->name : remote_peer, client 986 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer) client 1037 daemons/fenced/fenced_remote.c CRM_LOG_ASSERT(client != NULL); client 1038 daemons/fenced/fenced_remote.c if (client) { client 1039 daemons/fenced/fenced_remote.c op->client_id = strdup(client); client 1095 daemons/fenced/fenced_remote.c initiate_remote_stonith_op(pcmk__client_t *client, xmlNode *request, client 1105 daemons/fenced/fenced_remote.c if (client) { client 1106 daemons/fenced/fenced_remote.c client_id = client->id; client 146 daemons/fenced/pacemaker-fenced.c pcmk__client_t *client = pcmk__find_client(c); client 148 daemons/fenced/pacemaker-fenced.c if (client == NULL) { client 153 daemons/fenced/pacemaker-fenced.c pcmk__free_client(client); client 291 daemons/fenced/pacemaker-fenced.c pcmk__client_t *client = value; client 294 daemons/fenced/pacemaker-fenced.c CRM_CHECK(client != NULL, return); client 300 daemons/fenced/pacemaker-fenced.c if (client->ipcs == NULL) { client 305 daemons/fenced/pacemaker-fenced.c if (pcmk_is_set(client->flags, get_stonith_flag(type))) { client 306 daemons/fenced/pacemaker-fenced.c int rc = pcmk__ipc_send_xml(client, 0, update_msg, client 311 daemons/fenced/pacemaker-fenced.c CRM_XS " id=%.8s rc=%d", type, pcmk__client_name(client), client 312 daemons/fenced/pacemaker-fenced.c pcmk_rc_str(rc), client->id, rc); client 315 daemons/fenced/pacemaker-fenced.c pcmk__client_name(client), client->id); client 323 daemons/fenced/pacemaker-fenced.c pcmk__client_t *client = NULL; client 330 daemons/fenced/pacemaker-fenced.c client = pcmk__find_client_by_id(client_id); client 331 daemons/fenced/pacemaker-fenced.c if (!client) { client 342 daemons/fenced/pacemaker-fenced.c if (client) { client 343 daemons/fenced/pacemaker-fenced.c pcmk__ipc_send_xml(client, 0, notify_data, crm_ipc_server_event); client 214 daemons/fenced/pacemaker-fenced.h void stonith_command(pcmk__client_t *client, uint32_t id, uint32_t flags, client 236 daemons/fenced/pacemaker-fenced.h do_stonith_async_timeout_update(const char *client, const char *call_id, int timeout); client 242 daemons/fenced/pacemaker-fenced.h remote_fencing_op_t *initiate_remote_stonith_op(pcmk__client_t *client, client 250 daemons/fenced/pacemaker-fenced.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer); client 626 daemons/pacemakerd/pacemakerd.c pcmk__client_t *client = pcmk__find_client(c); client 628 daemons/pacemakerd/pacemakerd.c if (client == NULL) { client 632 daemons/pacemakerd/pacemakerd.c if (shutdown_complete_state_reported_to == client->pid) { client 638 daemons/pacemakerd/pacemakerd.c pcmk__free_client(client); client 243 daemons/schedulerd/pacemaker-schedulerd.c pcmk__client_t *client = pcmk__find_client(c); client 245 daemons/schedulerd/pacemaker-schedulerd.c if (client == NULL) { client 249 daemons/schedulerd/pacemaker-schedulerd.c pcmk__free_client(client); client 165 include/crm/common/ipc.h bool crm_ipc_connect(crm_ipc_t * client); client 166 include/crm/common/ipc.h void crm_ipc_close(crm_ipc_t * client); client 167 include/crm/common/ipc.h void crm_ipc_destroy(crm_ipc_t * client); client 170 include/crm/common/ipc.h int crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags, client 173 include/crm/common/ipc.h int crm_ipc_get_fd(crm_ipc_t * client); client 174 include/crm/common/ipc.h bool crm_ipc_connected(crm_ipc_t * client); client 175 include/crm/common/ipc.h int crm_ipc_ready(crm_ipc_t * client); client 176 include/crm/common/ipc.h long crm_ipc_read(crm_ipc_t * client); client 177 include/crm/common/ipc.h const char *crm_ipc_buffer(crm_ipc_t * client); client 178 include/crm/common/ipc.h uint32_t crm_ipc_buffer_flags(crm_ipc_t * client); client 179 include/crm/common/ipc.h const char *crm_ipc_name(crm_ipc_t * client); client 131 include/crm/common/ipc_internal.h #define PCMK__CLIENT_TYPE(client) ((client)->flags & UINT64_C(0xff00000000)) client 162 include/crm/common/ipc_internal.h #define pcmk__set_client_flags(client, flags_to_set) do { \ client 163 include/crm/common/ipc_internal.h (client)->flags = pcmk__set_flags_as(__func__, __LINE__, \ client 165 include/crm/common/ipc_internal.h "Client", ((client)->name? (client)->name : "client"), \ client 166 include/crm/common/ipc_internal.h (client)->flags, (flags_to_set), #flags_to_set); \ client 169 include/crm/common/ipc_internal.h #define pcmk__clear_client_flags(client, flags_to_clear) do { \ client 170 include/crm/common/ipc_internal.h (client)->flags = pcmk__clear_flags_as(__func__, __LINE__, \ client 172 include/crm/common/ipc_internal.h "Client", ((client)->name? (client)->name : "client"), \ client 173 include/crm/common/ipc_internal.h (client)->flags, (flags_to_clear), #flags_to_clear); \ client 204 include/crm/common/ipc_internal.h bool pcmk__set_client_queue_max(pcmk__client_t *client, const char *qmax); client 110 include/crm/common/mainloop.h void mainloop_del_ipc_client(mainloop_io_t * client); client 112 include/crm/common/mainloop.h crm_ipc_t *mainloop_get_ipc_client(mainloop_io_t * client); client 122 include/crm/common/mainloop.h void mainloop_del_fd(mainloop_io_t * client); client 34 include/crm/common/remote_internal.h int pcmk__read_handshake_data(pcmk__client_t *client); client 103 include/crm/stonith-ng.h char *client; client 412 lib/cib/cib_client.c cib_notify_client_t *client = g_list_nth_data(list, 0); client 414 lib/cib/cib_client.c list = g_list_remove(list, client); client 415 lib/cib/cib_client.c free(client); client 491 lib/cib/cib_client.c cib_notify_client_t *client = (cib_notify_client_t *)l->data; client 493 lib/cib/cib_client.c if (strcmp(client->event, event) == 0) { client 647 lib/common/ipc_client.c const char *client = crm_system_name? crm_system_name : "client"; client 665 lib/common/ipc_client.c pcmk_ipc_name(api, false), client, NULL); client 747 lib/common/ipc_client.c crm_ipc_t *client = NULL; client 749 lib/common/ipc_client.c client = calloc(1, sizeof(crm_ipc_t)); client 750 lib/common/ipc_client.c if (client == NULL) { client 755 lib/common/ipc_client.c client->name = strdup(name); client 756 lib/common/ipc_client.c if (client->name == NULL) { client 758 lib/common/ipc_client.c free(client); client 761 lib/common/ipc_client.c client->buf_size = pcmk__ipc_buffer_size(max_size); client 762 lib/common/ipc_client.c client->buffer = malloc(client->buf_size); client 763 lib/common/ipc_client.c if (client->buffer == NULL) { client 765 lib/common/ipc_client.c free(client->name); client 766 lib/common/ipc_client.c free(client); client 771 lib/common/ipc_client.c client->max_buf_size = client->buf_size; client 773 lib/common/ipc_client.c client->pfd.fd = -1; client 774 lib/common/ipc_client.c client->pfd.events = POLLIN; client 775 lib/common/ipc_client.c client->pfd.revents = 0; client 777 lib/common/ipc_client.c return client; client 790 lib/common/ipc_client.c crm_ipc_connect(crm_ipc_t * client) client 797 lib/common/ipc_client.c client->need_reply = FALSE; client 798 lib/common/ipc_client.c client->ipc = qb_ipcc_connect(client->name, client->buf_size); client 800 lib/common/ipc_client.c if (client->ipc == NULL) { client 801 lib/common/ipc_client.c crm_debug("Could not establish %s connection: %s (%d)", client->name, pcmk_strerror(errno), errno); client 805 lib/common/ipc_client.c client->pfd.fd = crm_ipc_get_fd(client); client 806 lib/common/ipc_client.c if (client->pfd.fd < 0) { client 809 lib/common/ipc_client.c crm_ipc_close(client); client 817 lib/common/ipc_client.c crm_ipc_close(client); client 822 lib/common/ipc_client.c if (!(rv = crm_ipc_is_authentic_process(client->pfd.fd, cl_uid, cl_gid, client 827 lib/common/ipc_client.c client->name, (long long) PCMK__SPECIAL_PID_AS_0(found_pid), client 829 lib/common/ipc_client.c crm_ipc_close(client); client 836 lib/common/ipc_client.c client->name); client 837 lib/common/ipc_client.c crm_ipc_close(client); client 842 lib/common/ipc_client.c qb_ipcc_context_set(client->ipc, client); client 845 lib/common/ipc_client.c client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc); client 846 lib/common/ipc_client.c if (client->max_buf_size > client->buf_size) { client 847 lib/common/ipc_client.c free(client->buffer); client 848 lib/common/ipc_client.c client->buffer = calloc(1, client->max_buf_size); client 849 lib/common/ipc_client.c client->buf_size = client->max_buf_size; client 857 lib/common/ipc_client.c crm_ipc_close(crm_ipc_t * client) client 859 lib/common/ipc_client.c if (client) { client 860 lib/common/ipc_client.c if (client->ipc) { client 861 lib/common/ipc_client.c qb_ipcc_connection_t *ipc = client->ipc; client 863 lib/common/ipc_client.c client->ipc = NULL; client 870 lib/common/ipc_client.c crm_ipc_destroy(crm_ipc_t * client) client 872 lib/common/ipc_client.c if (client) { client 873 lib/common/ipc_client.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { client 874 lib/common/ipc_client.c crm_notice("Destroying an active IPC connection to %s", client->name); client 885 lib/common/ipc_client.c crm_trace("Destroying IPC connection to %s: %p", client->name, client); client 886 lib/common/ipc_client.c free(client->buffer); client 887 lib/common/ipc_client.c free(client->name); client 888 lib/common/ipc_client.c free(client); client 893 lib/common/ipc_client.c crm_ipc_get_fd(crm_ipc_t * client) client 897 lib/common/ipc_client.c if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) { client 902 lib/common/ipc_client.c (client? client->name : "unspecified client")); client 907 lib/common/ipc_client.c crm_ipc_connected(crm_ipc_t * client) client 911 lib/common/ipc_client.c if (client == NULL) { client 915 lib/common/ipc_client.c } else if (client->ipc == NULL) { client 919 lib/common/ipc_client.c } else if (client->pfd.fd < 0) { client 924 lib/common/ipc_client.c rc = qb_ipcc_is_connected(client->ipc); client 926 lib/common/ipc_client.c client->pfd.fd = -EINVAL; client 939 lib/common/ipc_client.c crm_ipc_ready(crm_ipc_t *client) client 943 lib/common/ipc_client.c CRM_ASSERT(client != NULL); client 945 lib/common/ipc_client.c if (crm_ipc_connected(client) == FALSE) { client 949 lib/common/ipc_client.c client->pfd.revents = 0; client 950 lib/common/ipc_client.c rc = poll(&(client->pfd), 1, 0); client 956 lib/common/ipc_client.c crm_ipc_decompress(crm_ipc_t * client) client 958 lib/common/ipc_client.c pcmk__ipc_header_t *header = (pcmk__ipc_header_t *)(void*)client->buffer; client 964 lib/common/ipc_client.c unsigned int new_buf_size = QB_MAX((sizeof(pcmk__ipc_header_t) + size_u), client->max_buf_size); client 971 lib/common/ipc_client.c client->buffer + sizeof(pcmk__ipc_header_t), header->size_compressed, 1, 0); client 990 lib/common/ipc_client.c memcpy(uncompressed, client->buffer, sizeof(pcmk__ipc_header_t)); /* Preserve the header */ client 993 lib/common/ipc_client.c free(client->buffer); client 994 lib/common/ipc_client.c client->buf_size = new_buf_size; client 995 lib/common/ipc_client.c client->buffer = uncompressed; client 998 lib/common/ipc_client.c CRM_ASSERT(client->buffer[sizeof(pcmk__ipc_header_t) + header->size_uncompressed - 1] == 0); client 1003 lib/common/ipc_client.c crm_ipc_read(crm_ipc_t * client) client 1007 lib/common/ipc_client.c CRM_ASSERT(client != NULL); client 1008 lib/common/ipc_client.c CRM_ASSERT(client->ipc != NULL); client 1009 lib/common/ipc_client.c CRM_ASSERT(client->buffer != NULL); client 1011 lib/common/ipc_client.c client->buffer[0] = 0; client 1012 lib/common/ipc_client.c client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer, client 1013 lib/common/ipc_client.c client->buf_size, 0); client 1014 lib/common/ipc_client.c if (client->msg_size >= 0) { client 1015 lib/common/ipc_client.c int rc = crm_ipc_decompress(client); client 1021 lib/common/ipc_client.c header = (pcmk__ipc_header_t *)(void*)client->buffer; client 1027 lib/common/ipc_client.c client->name, header->qb.id, header->qb.size, client->msg_size, client 1028 lib/common/ipc_client.c client->buffer + sizeof(pcmk__ipc_header_t)); client 1031 lib/common/ipc_client.c crm_trace("No message from %s received: %s", client->name, pcmk_strerror(client->msg_size)); client 1034 lib/common/ipc_client.c if (crm_ipc_connected(client) == FALSE || client->msg_size == -ENOTCONN) { client 1035 lib/common/ipc_client.c crm_err("Connection to %s failed", client->name); client 1046 lib/common/ipc_client.c crm_ipc_buffer(crm_ipc_t * client) client 1048 lib/common/ipc_client.c CRM_ASSERT(client != NULL); client 1049 lib/common/ipc_client.c return client->buffer + sizeof(pcmk__ipc_header_t); client 1053 lib/common/ipc_client.c crm_ipc_buffer_flags(crm_ipc_t * client) client 1057 lib/common/ipc_client.c CRM_ASSERT(client != NULL); client 1058 lib/common/ipc_client.c if (client->buffer == NULL) { client 1062 lib/common/ipc_client.c header = (pcmk__ipc_header_t *)(void*)client->buffer; client 1067 lib/common/ipc_client.c crm_ipc_name(crm_ipc_t * client) client 1069 lib/common/ipc_client.c CRM_ASSERT(client != NULL); client 1070 lib/common/ipc_client.c return client->name; client 1075 lib/common/ipc_client.c internal_ipc_get_reply(crm_ipc_t *client, int request_id, int ms_timeout, client 1082 lib/common/ipc_client.c crm_trace("client %s waiting on reply to msg id %d", client->name, request_id); client 1085 lib/common/ipc_client.c *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000); client 1089 lib/common/ipc_client.c rc = crm_ipc_decompress(client); client 1094 lib/common/ipc_client.c hdr = (pcmk__ipc_header_t *)(void*)client->buffer; client 1099 lib/common/ipc_client.c xmlNode *bad = string2xml(crm_ipc_buffer(client)); client 1105 lib/common/ipc_client.c xmlNode *bad = string2xml(crm_ipc_buffer(client)); client 1111 lib/common/ipc_client.c } else if (crm_ipc_connected(client) == FALSE) { client 1112 lib/common/ipc_client.c crm_err("Server disconnected client %s while waiting for msg id %d", client->name, client 1139 lib/common/ipc_client.c crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags, int32_t ms_timeout, client 1150 lib/common/ipc_client.c if (client == NULL) { client 1155 lib/common/ipc_client.c } else if (crm_ipc_connected(client) == FALSE) { client 1158 lib/common/ipc_client.c client->name); client 1166 lib/common/ipc_client.c if (client->need_reply) { client 1167 lib/common/ipc_client.c qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout); client 1170 lib/common/ipc_client.c client->name); client 1175 lib/common/ipc_client.c client->name); client 1176 lib/common/ipc_client.c client->need_reply = FALSE; client 1182 lib/common/ipc_client.c rc = pcmk__ipc_prepare_iov(id, message, client->max_buf_size, &iov, &bytes); client 1185 lib/common/ipc_client.c client->name, pcmk_rc_str(rc), rc); client 1190 lib/common/ipc_client.c pcmk__set_ipc_flags(header->flags, client->name, flags); client 1198 lib/common/ipc_client.c if(factor < 10 && (client->max_buf_size / 10) < (bytes / factor)) { client 1202 lib/common/ipc_client.c factor, client->max_buf_size, 2 * client->max_buf_size); client 1208 lib/common/ipc_client.c client->name, header->qb.id, header->qb.size, ms_timeout); client 1218 lib/common/ipc_client.c if (!crm_ipc_connected(client)) { client 1222 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv(client->ipc, iov, 2); client 1231 lib/common/ipc_client.c client->name, header->qb.id); client 1235 lib/common/ipc_client.c rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes); client 1243 lib/common/ipc_client.c client->need_reply = TRUE; client 1250 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer, client 1251 lib/common/ipc_client.c client->buf_size, -1); client 1252 lib/common/ipc_client.c } while ((qb_rc == -EAGAIN) && crm_ipc_connected(client)); client 1257 lib/common/ipc_client.c pcmk__ipc_header_t *hdr = (pcmk__ipc_header_t *)(void*)client->buffer; client 1260 lib/common/ipc_client.c rc, hdr->qb.id, client->name, header->qb.id, client 1261 lib/common/ipc_client.c crm_ipc_buffer(client)); client 1264 lib/common/ipc_client.c *reply = string2xml(crm_ipc_buffer(client)); client 1269 lib/common/ipc_client.c client->name, header->qb.id, rc); client 1273 lib/common/ipc_client.c if (crm_ipc_connected(client) == FALSE) { client 1275 lib/common/ipc_client.c CRM_XS " rc=%d", client->name, header->qb.id, rc); client 1279 lib/common/ipc_client.c client->name, header->qb.id, pcmk_strerror(rc), ms_timeout, client 1285 lib/common/ipc_client.c client->name, header->qb.id, client 73 lib/common/ipc_server.c pcmk__client_t *client; client 78 lib/common/ipc_server.c while (g_hash_table_iter_next(&iter, &key, (gpointer *) & client)) { client 79 lib/common/ipc_server.c if (strcmp(client->id, id) == 0) { client 80 lib/common/ipc_server.c return client; client 154 lib/common/ipc_server.c pcmk__client_t *client = calloc(1, sizeof(pcmk__client_t)); client 156 lib/common/ipc_server.c if (client == NULL) { client 163 lib/common/ipc_server.c client->user = pcmk__uid2username(uid_client); client 164 lib/common/ipc_server.c if (client->user == NULL) { client 165 lib/common/ipc_server.c client->user = strdup("#unprivileged"); client 166 lib/common/ipc_server.c CRM_CHECK(client->user != NULL, free(client); return NULL); client 171 lib/common/ipc_server.c client->ipcs = c; client 172 lib/common/ipc_server.c pcmk__set_client_flags(client, pcmk__client_ipc); client 173 lib/common/ipc_server.c client->pid = pcmk__client_pid(c); client 179 lib/common/ipc_server.c client->id = crm_generate_uuid(); client 180 lib/common/ipc_server.c if (client->id == NULL) { client 182 lib/common/ipc_server.c free(client->user); client 183 lib/common/ipc_server.c free(client); client 187 lib/common/ipc_server.c key = client->id; client 193 lib/common/ipc_server.c g_hash_table_insert(client_connections, key, client); client 194 lib/common/ipc_server.c return client; client 207 lib/common/ipc_server.c pcmk__client_t *client = client_from_connection(NULL, key, 0); client 209 lib/common/ipc_server.c CRM_ASSERT(client != NULL); client 210 lib/common/ipc_server.c return client; client 219 lib/common/ipc_server.c pcmk__client_t *client = NULL; client 240 lib/common/ipc_server.c client = client_from_connection(c, NULL, uid_client); client 241 lib/common/ipc_server.c if (client == NULL) { client 247 lib/common/ipc_server.c pcmk__set_client_flags(client, pcmk__client_privileged); client 251 lib/common/ipc_server.c client->id, client->pid, uid_client, gid_client); client 252 lib/common/ipc_server.c return client; client 346 lib/common/ipc_server.c pcmk__set_client_queue_max(pcmk__client_t *client, const char *qmax) client 348 lib/common/ipc_server.c if (pcmk_is_set(client->flags, pcmk__client_privileged)) { client 354 lib/common/ipc_server.c client->queue_max = (unsigned int) qmax_int; client 715 lib/common/mainloop.c mainloop_io_t *client = data; client 717 lib/common/mainloop.c CRM_ASSERT(client->fd == g_io_channel_unix_get_fd(gio)); client 720 lib/common/mainloop.c if (client->ipc) { client 725 lib/common/mainloop.c rc = crm_ipc_read(client->ipc); client 728 lib/common/mainloop.c client->name, client, pcmk_strerror(rc), rc); client 730 lib/common/mainloop.c } else if (client->dispatch_fn_ipc) { client 731 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); client 733 lib/common/mainloop.c crm_trace("New message from %s[%p] = %ld (I/O condition=%d)", client->name, client, rc, condition); client 734 lib/common/mainloop.c if (client->dispatch_fn_ipc(buffer, rc, client->userdata) < 0) { client 735 lib/common/mainloop.c crm_trace("Connection to %s no longer required", client->name); client 743 lib/common/mainloop.c crm_trace("New message from %s[%p] %u", client->name, client, condition); client 744 lib/common/mainloop.c if (client->dispatch_fn_io) { client 745 lib/common/mainloop.c if (client->dispatch_fn_io(client->userdata) < 0) { client 746 lib/common/mainloop.c crm_trace("Connection to %s no longer required", client->name); client 753 lib/common/mainloop.c if (client->ipc && crm_ipc_connected(client->ipc) == FALSE) { client 755 lib/common/mainloop.c client->name, client, condition); client 760 lib/common/mainloop.c client->name, client, condition); client 803 lib/common/mainloop.c mainloop_io_t *client = c; client 804 lib/common/mainloop.c char *c_name = strdup(client->name); client 811 lib/common/mainloop.c if (client->ipc) { client 812 lib/common/mainloop.c crm_ipc_close(client->ipc); client 815 lib/common/mainloop.c if (client->destroy_fn) { client 816 lib/common/mainloop.c void (*destroy_fn) (gpointer userdata) = client->destroy_fn; client 818 lib/common/mainloop.c client->destroy_fn = NULL; client 819 lib/common/mainloop.c destroy_fn(client->userdata); client 822 lib/common/mainloop.c if (client->ipc) { client 823 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; client 825 lib/common/mainloop.c client->ipc = NULL; client 831 lib/common/mainloop.c free(client->name); client->name = NULL; client 832 lib/common/mainloop.c free(client); client 900 lib/common/mainloop.c mainloop_del_ipc_client(mainloop_io_t * client) client 902 lib/common/mainloop.c mainloop_del_fd(client); client 906 lib/common/mainloop.c mainloop_get_ipc_client(mainloop_io_t * client) client 908 lib/common/mainloop.c if (client) { client 909 lib/common/mainloop.c return client->ipc; client 918 lib/common/mainloop.c mainloop_io_t *client = NULL; client 921 lib/common/mainloop.c client = calloc(1, sizeof(mainloop_io_t)); client 922 lib/common/mainloop.c if (client == NULL) { client 925 lib/common/mainloop.c client->name = strdup(name); client 926 lib/common/mainloop.c client->userdata = userdata; client 929 lib/common/mainloop.c client->destroy_fn = callbacks->destroy; client 930 lib/common/mainloop.c client->dispatch_fn_io = callbacks->dispatch; client 933 lib/common/mainloop.c client->fd = fd; client 934 lib/common/mainloop.c client->channel = g_io_channel_unix_new(fd); client 935 lib/common/mainloop.c client->source = client 936 lib/common/mainloop.c g_io_add_watch_full(client->channel, priority, client 938 lib/common/mainloop.c client, mainloop_gio_destroy); client 949 lib/common/mainloop.c g_io_channel_unref(client->channel); client 950 lib/common/mainloop.c crm_trace("Added connection %d for %s[%p].%d", client->source, client->name, client, fd); client 955 lib/common/mainloop.c return client; client 959 lib/common/mainloop.c mainloop_del_fd(mainloop_io_t * client) client 961 lib/common/mainloop.c if (client != NULL) { client 962 lib/common/mainloop.c crm_trace("Removing client %s[%p]", client->name, client); client 963 lib/common/mainloop.c if (client->source) { client 967 lib/common/mainloop.c g_source_remove(client->source); client 358 lib/common/remote.c pcmk__read_handshake_data(pcmk__client_t *client) client 362 lib/common/remote.c CRM_ASSERT(client && client->remote && client->remote->tls_session); client 365 lib/common/remote.c rc = gnutls_handshake(*client->remote->tls_session); client 1146 lib/fencing/st_client.c kvp->client = crm_element_value_copy(op, F_STONITH_CLIENTNAME); client 1174 lib/fencing/st_client.c free(hp->client); client 242 lib/fencing/st_output.c event->client, event->origin, client 256 lib/fencing/st_output.c event->client, event->origin, client 268 lib/fencing/st_output.c event->client, event->origin); client 289 lib/fencing/st_output.c event->client, event->origin, client 298 lib/fencing/st_output.c event->client, event->origin, client 305 lib/fencing/st_output.c event->client, event->origin); client 347 lib/fencing/st_output.c xmlSetProp(node, (pcmkXmlStr) "client", (pcmkXmlStr) event->client); client 70 lib/pengine/pe_output.c const char *client, const char *origin) { client 71 lib/pengine/pe_output.c if (last_written != NULL || user != NULL || client != NULL || origin != NULL) { client 76 lib/pengine/pe_output.c client ? " via " : "", client 77 lib/pengine/pe_output.c client ? client : "", client 245 lib/pengine/pe_output.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); client 249 lib/pengine/pe_output.c out->message(out, "cluster-times", last_written, user, client, origin); client 311 lib/pengine/pe_output.c const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT); client 315 lib/pengine/pe_output.c out->message(out, "cluster-times", last_written, user, client, origin); client 897 lib/pengine/pe_output.c const char *client = va_arg(args, const char *); client 900 lib/pengine/pe_output.c char *buf = last_changed_string(last_written, user, client, origin); client 921 lib/pengine/pe_output.c const char *client = va_arg(args, const char *); client 928 lib/pengine/pe_output.c xmlSetProp(changed_node, (pcmkXmlStr) "client", (pcmkXmlStr) (client ? client : "")); client 939 lib/pengine/pe_output.c const char *client = va_arg(args, const char *); client 942 lib/pengine/pe_output.c char *buf = last_changed_string(last_written, user, client, origin); client 158 lib/services/dbus.c mainloop_io_t *client = mainloop_add_fd("dbus", G_PRIORITY_DEFAULT, fd, client 162 lib/services/dbus.c dbus_watch_set_data(watch, client, NULL); client 45 maint/mocked/based-notifyfenced.c mock_based_cib_notify_send_one(pcmk__client_t *client, xmlNode *xml) client 55 maint/mocked/based-notifyfenced.c CRM_CHECK(client != NULL, return true); client 59 maint/mocked/based-notifyfenced.c if (client->ipcs == NULL && client->remote == NULL) { client 66 maint/mocked/based-notifyfenced.c if (pcmk_is_set(client->options, cib_notify_diff) client 69 maint/mocked/based-notifyfenced.c if (pcmk__ipc_send_iov(client, update.iov, client 71 maint/mocked/based-notifyfenced.c crm_warn("Notification of client %s/%s failed", client->name, client->id); client 64 maint/mocked/based.c pcmk__client_t *client = pcmk__find_client(c); client 66 maint/mocked/based.c if (client != NULL) { client 68 maint/mocked/based.c pcmk__free_client(client); client 337 tools/crm_mon_curses.c event->client, event->origin, client 346 tools/crm_mon_curses.c event->client, event->origin, client 353 tools/crm_mon_curses.c event->client, event->origin);