client 518 daemons/attrd/attrd_ipc.c pcmk__client_t *client = pcmk__find_client(c); client 520 daemons/attrd/attrd_ipc.c if (client == NULL) { client 526 daemons/attrd/attrd_ipc.c attrd_remove_client_from_waitlist(client); client 529 daemons/attrd/attrd_ipc.c attrd_do_not_wait_for_client(client); client 531 daemons/attrd/attrd_ipc.c pcmk__free_client(client); client 559 daemons/attrd/attrd_ipc.c pcmk__client_t *client = pcmk__find_client(c); client 563 daemons/attrd/attrd_ipc.c CRM_CHECK((c != NULL) && (client != NULL), return 0); client 569 daemons/attrd/attrd_ipc.c rc = pcmk__ipc_msg_append(&client->buffer, data); client 579 daemons/attrd/attrd_ipc.c xml = pcmk__client_data2xml(client, &id, &flags); client 580 daemons/attrd/attrd_ipc.c g_byte_array_free(client->buffer, TRUE); client 581 daemons/attrd/attrd_ipc.c client->buffer = NULL; client 589 daemons/attrd/attrd_ipc.c if (client->buffer != NULL) { client 590 daemons/attrd/attrd_ipc.c g_byte_array_free(client->buffer, TRUE); client 591 daemons/attrd/attrd_ipc.c client->buffer = NULL; client 599 daemons/attrd/attrd_ipc.c pcmk__ipc_send_ack(client, id, flags, PCMK__XE_ACK, NULL, client 605 daemons/attrd/attrd_ipc.c .ipc_client = client, client 614 daemons/attrd/attrd_ipc.c pcmk__assert(client->user != NULL); client 615 daemons/attrd/attrd_ipc.c pcmk__update_acl_user(xml, PCMK__XA_ATTR_USER, client->user); client 200 daemons/attrd/attrd_sync.c attrd_remove_client_from_waitlist(pcmk__client_t *client) client 214 daemons/attrd/attrd_sync.c if (pcmk__str_eq(wl->client_id, client->id, pcmk__str_none)) { client 251 daemons/attrd/attrd_sync.c pcmk__client_t *client = NULL; client 260 daemons/attrd/attrd_sync.c client = pcmk__find_client_by_id(wl->client_id); client 261 daemons/attrd/attrd_sync.c if (client == NULL) { client 265 daemons/attrd/attrd_sync.c attrd_send_ack(client, wl->ipc_id, wl->flags | crm_ipc_client_response); client 374 daemons/attrd/attrd_sync.c pcmk__client_t *client = pcmk__find_client_by_id(action->client_id); client 375 daemons/attrd/attrd_sync.c if (client == NULL) { client 379 daemons/attrd/attrd_sync.c crm_trace("Timed out waiting for confirmations for client %s", client->id); client 380 daemons/attrd/attrd_sync.c pcmk__ipc_send_ack(client, action->ipc_id, client 433 daemons/attrd/attrd_sync.c attrd_do_not_wait_for_client(pcmk__client_t *client) client 447 daemons/attrd/attrd_sync.c if (pcmk__str_eq(action->client_id, client->id, pcmk__str_none)) { client 448 daemons/attrd/attrd_sync.c crm_trace("Removing client %s from expected confirmations", client->id); client 52 daemons/attrd/pacemaker-attrd.h #define attrd_send_ack(client, id, flags) \ client 53 daemons/attrd/pacemaker-attrd.h pcmk__ipc_send_ack((client), (id), (flags), PCMK__XE_ACK, \ client 244 daemons/attrd/pacemaker-attrd.h void attrd_do_not_wait_for_client(pcmk__client_t *client); client 248 daemons/attrd/pacemaker-attrd.h void attrd_remove_client_from_waitlist(pcmk__client_t *client); client 68 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); client 70 daemons/based/based_callbacks.c crm_trace("%p message from %s", c, client->id); client 77 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); client 79 daemons/based/based_callbacks.c crm_trace("%p message from %s", c, client->id); client 87 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); client 89 daemons/based/based_callbacks.c if (client == NULL) { client 93 daemons/based/based_callbacks.c pcmk__free_client(client); client 471 daemons/based/based_messages.c pcmk__client_t *client = pcmk__find_client_by_id(client_id); client 473 daemons/based/based_messages.c rc = based_commit_transaction(input, client, origin, result_cib); client 476 daemons/based/based_messages.c char *source = based_transaction_source_str(client, origin); client 47 daemons/based/based_notify.c pcmk__client_t *client = value; client 50 daemons/based/based_notify.c if (client->ipcs == NULL && client->remote == NULL) { client 58 daemons/based/based_notify.c if (pcmk_is_set(client->flags, cib_notify_diff) client 63 daemons/based/based_notify.c } else if (pcmk_is_set(client->flags, cib_notify_confirm) client 68 daemons/based/based_notify.c } else if (pcmk_is_set(client->flags, cib_notify_pre) client 73 daemons/based/based_notify.c } else if (pcmk_is_set(client->flags, cib_notify_post) client 80 daemons/based/based_notify.c switch (PCMK__CLIENT_TYPE(client)) { client 82 daemons/based/based_notify.c rc = pcmk__ipc_send_iov(client, update->iov, client 92 daemons/based/based_notify.c pcmk__client_name(client), pcmk_rc_str(rc), client 93 daemons/based/based_notify.c client->id); client 99 daemons/based/based_notify.c type, pcmk__client_name(client), client->id); client 100 daemons/based/based_notify.c pcmk__remote_send_xml(client->remote, update->msg); client 105 daemons/based/based_notify.c pcmk__client_name(client), client->flags); client 234 daemons/based/based_remote.c pcmk__client_t *client = data; client 236 daemons/based/based_remote.c client->remote->auth_timeout = 0; client 238 daemons/based/based_remote.c if (pcmk_is_set(client->flags, pcmk__client_authenticated)) { client 242 daemons/based/based_remote.c mainloop_del_fd(client->remote->source); client 322 daemons/based/based_remote.c pcmk__client_t *client = user_data; client 325 daemons/based/based_remote.c if (client == NULL) { client 330 daemons/based/based_remote.c pcmk__client_name(client)); client 335 daemons/based/based_remote.c switch (PCMK__CLIENT_TYPE(client)) { client 337 daemons/based/based_remote.c csock = client->remote->tcp_socket; client 340 daemons/based/based_remote.c if (client->remote->tls_session) { client 341 daemons/based/based_remote.c csock = pcmk__tls_get_client_sock(client->remote); client 343 daemons/based/based_remote.c if (pcmk_is_set(client->flags, client 345 daemons/based/based_remote.c gnutls_bye(client->remote->tls_session, GNUTLS_SHUT_WR); client 347 daemons/based/based_remote.c gnutls_deinit(client->remote->tls_session); client 348 daemons/based/based_remote.c client->remote->tls_session = NULL; client 354 daemons/based/based_remote.c pcmk__client_name(client), client->flags); client 361 daemons/based/based_remote.c pcmk__free_client(client); client 372 daemons/based/based_remote.c cib_handle_remote_msg(pcmk__client_t *client, xmlNode *command) client 379 daemons/based/based_remote.c if (client->name == NULL) { client 380 daemons/based/based_remote.c client->name = pcmk__str_copy(client->id); client 389 daemons/based/based_remote.c crm_xml_add(command, PCMK__XA_CIB_CLIENTID, client->id); client 390 daemons/based/based_remote.c crm_xml_add(command, PCMK__XA_CIB_CLIENTNAME, client->name); client 391 daemons/based/based_remote.c crm_xml_add(command, PCMK__XA_CIB_USER, client->user); client 406 daemons/based/based_remote.c cib_common_callback_worker(0, 0, command, client, TRUE); client 413 daemons/based/based_remote.c pcmk__client_t *client = data; client 415 daemons/based/based_remote.c const char *client_name = pcmk__client_name(client); client 418 daemons/based/based_remote.c pcmk__client_type_str(PCMK__CLIENT_TYPE(client)), client_name); client 420 daemons/based/based_remote.c if ((PCMK__CLIENT_TYPE(client) == pcmk__client_tls) client 421 daemons/based/based_remote.c && !pcmk_is_set(client->flags, pcmk__client_tls_handshake_complete)) { client 423 daemons/based/based_remote.c int rc = pcmk__read_handshake_data(client); client 435 daemons/based/based_remote.c pcmk__set_client_flags(client, pcmk__client_tls_handshake_complete); client 436 daemons/based/based_remote.c if (client->remote->auth_timeout) { client 437 daemons/based/based_remote.c g_source_remove(client->remote->auth_timeout); client 445 daemons/based/based_remote.c pcmk__tls_check_cert_expiration(client->remote->tls_session); client 448 daemons/based/based_remote.c client->remote->auth_timeout = pcmk__create_timer(REMOTE_AUTH_TIMEOUT, client 450 daemons/based/based_remote.c client); client 454 daemons/based/based_remote.c rc = pcmk__read_available_remote_data(client->remote); client 470 daemons/based/based_remote.c if (!pcmk_is_set(client->flags, pcmk__client_authenticated)) { client 474 daemons/based/based_remote.c command = pcmk__remote_message_xml(client->remote); client 480 daemons/based/based_remote.c pcmk__set_client_flags(client, pcmk__client_authenticated); client 481 daemons/based/based_remote.c g_source_remove(client->remote->auth_timeout); client 482 daemons/based/based_remote.c client->remote->auth_timeout = 0; client 483 daemons/based/based_remote.c client->name = crm_element_value_copy(command, PCMK_XA_NAME); client 487 daemons/based/based_remote.c client->user = pcmk__str_copy(user); client 497 daemons/based/based_remote.c crm_xml_add(reg, PCMK__XA_CIB_CLIENTID, client->id); client 498 daemons/based/based_remote.c pcmk__remote_send_xml(client->remote, reg); client 503 daemons/based/based_remote.c command = pcmk__remote_message_xml(client->remote); client 506 daemons/based/based_remote.c cib_handle_remote_msg(client, command); client 29 daemons/based/based_transaction.c based_transaction_source_str(const pcmk__client_t *client, const char *origin) client 31 daemons/based/based_transaction.c if (client != NULL) { client 33 daemons/based/based_transaction.c pcmk__client_name(client), client 34 daemons/based/based_transaction.c pcmk__s(client->id, "unidentified"), client 56 daemons/based/based_transaction.c const pcmk__client_t *client, const char *source) client 78 daemons/based/based_transaction.c rc = cib_process_request(request, TRUE, client); client 118 daemons/based/based_transaction.c based_commit_transaction(xmlNodePtr transaction, const pcmk__client_t *client, client 140 daemons/based/based_transaction.c source = based_transaction_source_str(client, origin); client 146 daemons/based/based_transaction.c rc = process_transaction_requests(transaction, client, origin); client 17 daemons/based/based_transaction.h char *based_transaction_source_str(const pcmk__client_t *client, client 21 daemons/based/based_transaction.h const pcmk__client_t *client, client 384 daemons/controld/controld_control.c pcmk__client_t *client = pcmk__find_client(c); client 387 daemons/controld/controld_control.c rc = pcmk__ipc_msg_append(&client->buffer, data); client 397 daemons/controld/controld_control.c msg = pcmk__client_data2xml(client, &id, &flags); client 398 daemons/controld/controld_control.c g_byte_array_free(client->buffer, TRUE); client 399 daemons/controld/controld_control.c client->buffer = NULL; client 407 daemons/controld/controld_control.c if (client->buffer != NULL) { client 408 daemons/controld/controld_control.c g_byte_array_free(client->buffer, TRUE); client 409 daemons/controld/controld_control.c client->buffer = NULL; client 416 daemons/controld/controld_control.c pcmk__ipc_send_ack(client, id, flags, PCMK__XE_ACK, NULL, client 420 daemons/controld/controld_control.c pcmk__ipc_send_ack(client, id, flags, PCMK__XE_ACK, NULL, client 423 daemons/controld/controld_control.c pcmk__assert(client->user != NULL); client 424 daemons/controld/controld_control.c pcmk__update_acl_user(msg, PCMK__XA_CRM_USER, client->user); client 426 daemons/controld/controld_control.c crm_xml_add(msg, PCMK__XA_CRM_SYS_FROM, client->id); client 427 daemons/controld/controld_control.c if (controld_authorize_ipc_message(msg, client, NULL)) { client 429 daemons/controld/controld_control.c pcmk__client_name(client)); client 441 daemons/controld/controld_control.c pcmk__client_t *client = pcmk__find_client(c); client 443 daemons/controld/controld_control.c if (client) { client 445 daemons/controld/controld_control.c (client->userdata? "" : "un"), pcmk__client_name(client), client 446 daemons/controld/controld_control.c c, client); client 447 daemons/controld/controld_control.c free(client->userdata); client 448 daemons/controld/controld_control.c pcmk__free_client(client); client 487 daemons/controld/controld_fencing.c const char *client = "a client"; client 505 daemons/controld/controld_fencing.c client = event->client_origin; client 524 daemons/controld/controld_fencing.c event->target, executioner, client, event->origin); client 571 daemons/controld/controld_fencing.c event->action, executioner, client, event->origin, client 604 daemons/controld/controld_fencing.c if (!pcmk__str_eq(client, te_client_id, pcmk__str_casei)) { client 609 daemons/controld/controld_fencing.c client, event->target); client 105 daemons/execd/execd_alerts.c process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id, xmlNode *request) client 122 daemons/execd/execd_alerts.c (client == NULL) || (client->id == NULL)) { /* hint static analyzer */ client 132 daemons/execd/execd_alerts.c crm_info("Executing alert %s for %s", alert_id, client->id); client 140 daemons/execd/execd_alerts.c cb_data->client_id = pcmk__str_copy(client->id); client 306 daemons/execd/execd_commands.c create_lrmd_cmd(xmlNode *msg, pcmk__client_t *client) client 317 daemons/execd/execd_commands.c cmd->client_id = pcmk__str_copy(client->id); client 565 daemons/execd/execd_commands.c pcmk__client_t *client = value; client 570 daemons/execd/execd_commands.c CRM_CHECK(client != NULL, return); client 571 daemons/execd/execd_commands.c if (client->name == NULL) { client 575 daemons/execd/execd_commands.c if (pcmk_is_set(client->flags, pcmk__client_to_proxy)) { client 581 daemons/execd/execd_commands.c pcmk__client_name(client)); client 585 daemons/execd/execd_commands.c rc = lrmd_server_send_notify(client, update_msg); client 602 daemons/execd/execd_commands.c pcmk__client_name(client), msg, rc); client 687 daemons/execd/execd_commands.c pcmk__client_t *client = pcmk__find_client_by_id(cmd->client_id); client 689 daemons/execd/execd_commands.c if (client != NULL) { client 690 daemons/execd/execd_commands.c send_client_notify(client->id, client, notify); client 787 daemons/execd/execd_commands.c pcmk__client_t *client = value; client 790 daemons/execd/execd_commands.c if (!pcmk__str_eq(client->id, data->new_client->id, pcmk__str_casei)) { client 791 daemons/execd/execd_commands.c send_client_notify(key, (gpointer) client, (gpointer) data->notify); client 1516 daemons/execd/execd_commands.c process_lrmd_signon(pcmk__client_t *client, xmlNode *request, int call_id, client 1533 daemons/execd/execd_commands.c if ((client->remote != NULL) client 1534 daemons/execd/execd_commands.c && pcmk_is_set(client->flags, client 1539 daemons/execd/execd_commands.c ipc_proxy_add_provider(client); client 1567 daemons/execd/execd_commands.c crm_xml_add(*reply, PCMK__XA_LRMD_CLIENTID, client->id); client 1579 daemons/execd/execd_commands.c process_lrmd_rsc_register(pcmk__client_t *client, uint32_t id, xmlNode *request) client 1631 daemons/execd/execd_commands.c process_lrmd_rsc_unregister(pcmk__client_t *client, uint32_t id, client 1665 daemons/execd/execd_commands.c process_lrmd_rsc_exec(pcmk__client_t *client, uint32_t id, xmlNode *request) client 1684 daemons/execd/execd_commands.c cmd = create_lrmd_cmd(request, client); client 1792 daemons/execd/execd_commands.c process_lrmd_rsc_cancel(pcmk__client_t *client, uint32_t id, xmlNode *request) client 1874 daemons/execd/execd_commands.c process_lrmd_message(pcmk__client_t *client, uint32_t id, xmlNode *request) client 1887 daemons/execd/execd_commands.c bool allowed = pcmk_is_set(client->flags, pcmk__client_privileged); client 1889 daemons/execd/execd_commands.c crm_trace("Processing %s operation from %s", op, client->id); client 1895 daemons/execd/execd_commands.c ipc_proxy_forward_client(client, request); client 1904 daemons/execd/execd_commands.c rc = process_lrmd_signon(client, request, call_id, &reply); client 1908 daemons/execd/execd_commands.c rc = process_lrmd_rsc_register(client, id, request); client 1923 daemons/execd/execd_commands.c rc = process_lrmd_rsc_unregister(client, id, request); client 1934 daemons/execd/execd_commands.c rc = process_lrmd_rsc_exec(client, id, request); client 1941 daemons/execd/execd_commands.c rc = process_lrmd_rsc_cancel(client, id, request); client 1966 daemons/execd/execd_commands.c rc = process_lrmd_alert_exec(client, id, request); client 1982 daemons/execd/execd_commands.c op, pcmk__client_name(client)); client 1987 daemons/execd/execd_commands.c op, pcmk__client_name(client)); client 1991 daemons/execd/execd_commands.c op, client->id, rc, do_reply, do_notify); client 1999 daemons/execd/execd_commands.c send_rc = lrmd_server_send_reply(client, id, reply); client 2003 daemons/execd/execd_commands.c pcmk__client_name(client), pcmk_rc_str(send_rc), send_rc); client 129 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); client 132 daemons/execd/pacemaker-execd.c CRM_CHECK(client != NULL, crm_err("Invalid client"); client 134 daemons/execd/pacemaker-execd.c CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p", client); client 137 daemons/execd/pacemaker-execd.c rc = pcmk__ipc_msg_append(&client->buffer, data); client 147 daemons/execd/pacemaker-execd.c request = pcmk__client_data2xml(client, &id, &flags); client 148 daemons/execd/pacemaker-execd.c g_byte_array_free(client->buffer, TRUE); client 149 daemons/execd/pacemaker-execd.c client->buffer = NULL; client 157 daemons/execd/pacemaker-execd.c if (client->buffer != NULL) { client 158 daemons/execd/pacemaker-execd.c g_byte_array_free(client->buffer, TRUE); client 159 daemons/execd/pacemaker-execd.c client->buffer = NULL; client 165 daemons/execd/pacemaker-execd.c CRM_CHECK(flags & crm_ipc_client_response, crm_err("Invalid client request: %p", client); client 176 daemons/execd/pacemaker-execd.c if (!client->name) { client 181 daemons/execd/pacemaker-execd.c client->name = pcmk__itoa(pcmk__client_pid(c)); client 183 daemons/execd/pacemaker-execd.c client->name = pcmk__str_copy(value); client 192 daemons/execd/pacemaker-execd.c crm_xml_add(request, PCMK__XA_LRMD_CLIENTID, client->id); client 193 daemons/execd/pacemaker-execd.c crm_xml_add(request, PCMK__XA_LRMD_CLIENTNAME, client->name); client 196 daemons/execd/pacemaker-execd.c process_lrmd_message(client, id, request); client 209 daemons/execd/pacemaker-execd.c lrmd_client_destroy(pcmk__client_t *client) client 211 daemons/execd/pacemaker-execd.c pcmk__free_client(client); client 226 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); client 228 daemons/execd/pacemaker-execd.c if (client == NULL) { client 233 daemons/execd/pacemaker-execd.c client_disconnect_cleanup(client->id); client 235 daemons/execd/pacemaker-execd.c ipc_proxy_remove_provider(client); client 237 daemons/execd/pacemaker-execd.c lrmd_client_destroy(client); client 258 daemons/execd/pacemaker-execd.c lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply) client 260 daemons/execd/pacemaker-execd.c crm_trace("Sending reply (%d) to client (%s)", id, client->id); client 261 daemons/execd/pacemaker-execd.c switch (PCMK__CLIENT_TYPE(client)) { client 263 daemons/execd/pacemaker-execd.c return pcmk__ipc_send_xml(client, id, reply, crm_ipc_flags_none); client 266 daemons/execd/pacemaker-execd.c return lrmd__remote_send_xml(client->remote, reply, id, "reply"); client 271 daemons/execd/pacemaker-execd.c pcmk__client_name(client), client->flags); client 278 daemons/execd/pacemaker-execd.c lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg) client 280 daemons/execd/pacemaker-execd.c crm_trace("Sending notification to client (%s)", client->id); client 281 daemons/execd/pacemaker-execd.c switch (PCMK__CLIENT_TYPE(client)) { client 283 daemons/execd/pacemaker-execd.c if (client->ipcs == NULL) { client 287 daemons/execd/pacemaker-execd.c return pcmk__ipc_send_xml(client, 0, msg, crm_ipc_server_event); client 290 daemons/execd/pacemaker-execd.c if (client->remote == NULL) { client 294 daemons/execd/pacemaker-execd.c return lrmd__remote_send_xml(client->remote, msg, 0, "notify"); client 300 daemons/execd/pacemaker-execd.c pcmk__client_name(client), client->flags); client 59 daemons/execd/pacemaker-execd.h int lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply); client 61 daemons/execd/pacemaker-execd.h int lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg); client 65 daemons/execd/pacemaker-execd.h void process_lrmd_message(pcmk__client_t *client, uint32_t id, client 74 daemons/execd/pacemaker-execd.h void lrmd_client_destroy(pcmk__client_t *client); client 94 daemons/execd/pacemaker-execd.h void ipc_proxy_add_provider(pcmk__client_t *client); client 95 daemons/execd/pacemaker-execd.h void ipc_proxy_remove_provider(pcmk__client_t *client); client 96 daemons/execd/pacemaker-execd.h void ipc_proxy_forward_client(pcmk__client_t *client, xmlNode *xml); client 103 daemons/execd/pacemaker-execd.h int process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id, client 75 daemons/execd/remoted_proxy.c pcmk__client_t *client; client 88 daemons/execd/remoted_proxy.c client = pcmk__new_client(c, uid, gid); client 89 daemons/execd/remoted_proxy.c if (client == NULL) { client 95 daemons/execd/remoted_proxy.c client->userdata = pcmk__str_copy(ipc_proxy->id); client 96 daemons/execd/remoted_proxy.c client->name = crm_strdup_printf("proxy-%s-%d-%.8s", ipc_channel, client->pid, client->id); client 101 daemons/execd/remoted_proxy.c pcmk__set_client_flags(client, pcmk__client_to_proxy); client 103 daemons/execd/remoted_proxy.c g_hash_table_insert(ipc_clients, client->id, client); client 108 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_SESSION, client->id); client 113 daemons/execd/remoted_proxy.c client->id, uid, gid, ipc_channel); client 233 daemons/execd/remoted_proxy.c pcmk__client_t *client = pcmk__find_client(c); client 234 daemons/execd/remoted_proxy.c pcmk__client_t *ipc_proxy = pcmk__find_client_by_id(client->userdata); client 240 daemons/execd/remoted_proxy.c qb_ipcs_disconnect(client->ipcs); client 257 daemons/execd/remoted_proxy.c rc = pcmk__ipc_msg_append(&client->buffer, data); client 267 daemons/execd/remoted_proxy.c request = pcmk__client_data2xml(client, &id, &flags); client 268 daemons/execd/remoted_proxy.c g_byte_array_free(client->buffer, TRUE); client 269 daemons/execd/remoted_proxy.c client->buffer = NULL; client 277 daemons/execd/remoted_proxy.c if (client->buffer != NULL) { client 278 daemons/execd/remoted_proxy.c g_byte_array_free(client->buffer, TRUE); client 279 daemons/execd/remoted_proxy.c client->buffer = NULL; client 289 daemons/execd/remoted_proxy.c CRM_CHECK(client != NULL, crm_err("Invalid client"); client 291 daemons/execd/remoted_proxy.c CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p", client); client 297 daemons/execd/remoted_proxy.c pcmk__set_ipc_flags(flags, pcmk__client_name(client), crm_ipc_proxied); client 298 daemons/execd/remoted_proxy.c client->request_id = id; client 302 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_SESSION, client->id); client 303 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_CLIENT, pcmk__client_name(client)); client 304 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_USER, client->user); client 348 daemons/execd/remoted_proxy.c pcmk__client_t *client = pcmk__find_client(c); client 351 daemons/execd/remoted_proxy.c if (client == NULL) { client 355 daemons/execd/remoted_proxy.c ipc_proxy = pcmk__find_client_by_id(client->userdata); client 362 daemons/execd/remoted_proxy.c crm_xml_add(msg, PCMK__XA_LRMD_IPC_SESSION, client->id); client 367 daemons/execd/remoted_proxy.c g_hash_table_remove(ipc_clients, client->id); client 369 daemons/execd/remoted_proxy.c free(client->userdata); client 370 daemons/execd/remoted_proxy.c client->userdata = NULL; client 371 daemons/execd/remoted_proxy.c pcmk__free_client(client); client 47 daemons/execd/remoted_tls.c remoted__read_handshake_data(pcmk__client_t *client) client 49 daemons/execd/remoted_tls.c int rc = pcmk__read_handshake_data(client); client 60 daemons/execd/remoted_tls.c if (client->remote->auth_timeout) { client 61 daemons/execd/remoted_tls.c g_source_remove(client->remote->auth_timeout); client 63 daemons/execd/remoted_tls.c client->remote->auth_timeout = 0; client 65 daemons/execd/remoted_tls.c pcmk__set_client_flags(client, pcmk__client_tls_handshake_complete); client 73 daemons/execd/remoted_tls.c pcmk__tls_check_cert_expiration(client->remote->tls_session); 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 (!pcmk_is_set(client->flags, pcmk__client_tls_handshake_complete)) { client 94 daemons/execd/remoted_tls.c return remoted__read_handshake_data(client); client 97 daemons/execd/remoted_tls.c rc = pcmk__remote_ready(client->remote, 0); client 112 daemons/execd/remoted_tls.c rc = pcmk__read_available_remote_data(client->remote); client 127 daemons/execd/remoted_tls.c request = pcmk__remote_message_xml(client->remote); client 134 daemons/execd/remoted_tls.c if (!client->name) { client 135 daemons/execd/remoted_tls.c client->name = crm_element_value_copy(request, client 144 daemons/execd/remoted_tls.c crm_xml_add(request, PCMK__XA_LRMD_CLIENTID, client->id); client 145 daemons/execd/remoted_tls.c crm_xml_add(request, PCMK__XA_LRMD_CLIENTNAME, client->name); client 148 daemons/execd/remoted_tls.c process_lrmd_message(client, id, request); client 157 daemons/execd/remoted_tls.c pcmk__client_t *client = user_data; client 159 daemons/execd/remoted_tls.c if (client == NULL) { client 164 daemons/execd/remoted_tls.c pcmk__client_name(client)); client 166 daemons/execd/remoted_tls.c ipc_proxy_remove_provider(client); client 174 daemons/execd/remoted_tls.c if (client->remote->tls_session) { client 175 daemons/execd/remoted_tls.c int csock = pcmk__tls_get_client_sock(client->remote); client 177 daemons/execd/remoted_tls.c gnutls_bye(client->remote->tls_session, GNUTLS_SHUT_RDWR); client 178 daemons/execd/remoted_tls.c gnutls_deinit(client->remote->tls_session); client 179 daemons/execd/remoted_tls.c client->remote->tls_session = NULL; client 183 daemons/execd/remoted_tls.c lrmd_client_destroy(client); client 190 daemons/execd/remoted_tls.c pcmk__client_t *client = data; client 192 daemons/execd/remoted_tls.c client->remote->auth_timeout = 0; client 194 daemons/execd/remoted_tls.c if (pcmk_is_set(client->flags, client 199 daemons/execd/remoted_tls.c mainloop_del_fd(client->remote->source); client 200 daemons/execd/remoted_tls.c client->remote->source = NULL; client 95 daemons/fenced/fenced_commands.c char *client; client 378 daemons/fenced/fenced_commands.c free(cmd->client); client 418 daemons/fenced/fenced_commands.c cmd->client = crm_element_value_copy(msg, PCMK__XA_ST_CLIENTID); client 419 daemons/fenced/fenced_commands.c if ((cmd->action == NULL) || (cmd->op == NULL) || (cmd->client == NULL)) { client 721 daemons/fenced/fenced_commands.c device->id, cmd->client, cmd->timeout); client 1142 daemons/fenced/fenced_commands.c cmd->client = pcmk__str_copy(crm_system_name); client 2366 daemons/fenced/fenced_commands.c const char *remote_peer, pcmk__client_t *client) client 2368 daemons/fenced/fenced_commands.c CRM_CHECK((reply != NULL) && ((remote_peer != NULL) || (client != NULL)), client 2372 daemons/fenced/fenced_commands.c do_local_reply(reply, client, call_options); client 2390 daemons/fenced/fenced_commands.c pcmk__client_t *client = NULL; client 2393 daemons/fenced/fenced_commands.c client = pcmk__find_client_by_id(query->client_id); client 2394 daemons/fenced/fenced_commands.c if ((client == NULL) && (query->remote_peer == NULL)) { client 2485 daemons/fenced/fenced_commands.c client); client 2599 daemons/fenced/fenced_commands.c pcmk__client_t *client = NULL; client 2605 daemons/fenced/fenced_commands.c if (cmd->client != NULL) { client 2606 daemons/fenced/fenced_commands.c client = pcmk__find_client_by_id(cmd->client); client 2607 daemons/fenced/fenced_commands.c if ((client == NULL) && (cmd->origin == NULL)) { client 2608 daemons/fenced/fenced_commands.c crm_trace("Skipping reply to %s: no longer a client", cmd->client); client 2630 daemons/fenced/fenced_commands.c stonith_send_reply(reply, cmd->options, cmd->origin, client); client 2689 daemons/fenced/fenced_commands.c if (pcmk__str_eq(cmd->client, cmd_other->client, pcmk__str_casei) || client 2974 daemons/fenced/fenced_commands.c crm_xml_add(reply, PCMK__XA_ST_CLIENTID, cmd->client); client 3560 daemons/fenced/fenced_commands.c handle_reply(pcmk__client_t *client, xmlNode *request, const char *remote_peer) client 3574 daemons/fenced/fenced_commands.c pcmk__s(op, "untyped"), ((client == NULL)? "peer" : "client"), client 3575 daemons/fenced/fenced_commands.c ((client == NULL)? remote_peer : pcmk__client_name(client))); client 3581 daemons/fenced/fenced_commands.c op, ((client == NULL)? "peer" : "client"), client 3582 daemons/fenced/fenced_commands.c ((client == NULL)? remote_peer : pcmk__client_name(client))); client 3597 daemons/fenced/fenced_commands.c stonith_command(pcmk__client_t *client, uint32_t id, uint32_t flags, client 3621 daemons/fenced/fenced_commands.c ((client == NULL)? "peer" : "client"), client 3622 daemons/fenced/fenced_commands.c ((client == NULL)? remote_peer : pcmk__client_name(client))); client 3625 daemons/fenced/fenced_commands.c pcmk__assert((client == NULL) || (client->request_id == id)); client 3629 daemons/fenced/fenced_commands.c handle_reply(client, message, remote_peer); client 3632 daemons/fenced/fenced_commands.c .ipc_client = client, client 454 daemons/fenced/fenced_remote.c pcmk__client_t *client = NULL; client 470 daemons/fenced/fenced_remote.c client = pcmk__find_client_by_id(op->client_id); client 471 daemons/fenced/fenced_remote.c if (client == NULL) { client 474 daemons/fenced/fenced_remote.c do_local_reply(reply, client, op->call_options); client 1122 daemons/fenced/fenced_remote.c fenced_handle_manual_confirmation(const pcmk__client_t *client, xmlNode *msg) client 1134 daemons/fenced/fenced_remote.c op = initiate_remote_stonith_op(client, msg, TRUE); client 1163 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode *request, gboolean peer) client 1184 daemons/fenced/fenced_remote.c op_id, ((client == NULL)? "unknown client" : client)); client 1223 daemons/fenced/fenced_remote.c CRM_LOG_ASSERT(client != NULL); client 1224 daemons/fenced/fenced_remote.c op->client_id = pcmk__str_copy(client); client 1303 daemons/fenced/fenced_remote.c initiate_remote_stonith_op(const pcmk__client_t *client, xmlNode *request, client 1313 daemons/fenced/fenced_remote.c if (client) { client 1314 daemons/fenced/fenced_remote.c client_id = client->id; client 186 daemons/fenced/pacemaker-fenced.c pcmk__client_t *client = pcmk__find_client(c); client 188 daemons/fenced/pacemaker-fenced.c if (client == NULL) { client 193 daemons/fenced/pacemaker-fenced.c pcmk__free_client(client); client 255 daemons/fenced/pacemaker-fenced.c do_local_reply(const xmlNode *notify_src, pcmk__client_t *client, client 264 daemons/fenced/pacemaker-fenced.c CRM_LOG_ASSERT(client->request_id); client 265 daemons/fenced/pacemaker-fenced.c rid = client->request_id; client 266 daemons/fenced/pacemaker-fenced.c client->request_id = 0; client 270 daemons/fenced/pacemaker-fenced.c local_rc = pcmk__ipc_send_xml(client, rid, notify_src, ipc_flags); client 273 daemons/fenced/pacemaker-fenced.c rid, pcmk__client_name(client)); client 277 daemons/fenced/pacemaker-fenced.c pcmk__client_name(client), pcmk_rc_str(local_rc)); client 316 daemons/fenced/pacemaker-fenced.c pcmk__client_t *client = value; client 319 daemons/fenced/pacemaker-fenced.c CRM_CHECK(client != NULL, return); client 325 daemons/fenced/pacemaker-fenced.c if (client->ipcs == NULL) { client 330 daemons/fenced/pacemaker-fenced.c if (pcmk_is_set(client->flags, fenced_parse_notify_flag(type))) { client 331 daemons/fenced/pacemaker-fenced.c int rc = pcmk__ipc_send_xml(client, 0, update_msg, client 336 daemons/fenced/pacemaker-fenced.c QB_XS " id=%.8s rc=%d", type, pcmk__client_name(client), client 337 daemons/fenced/pacemaker-fenced.c pcmk_rc_str(rc), client->id, rc); client 340 daemons/fenced/pacemaker-fenced.c type, pcmk__client_name(client)); client 348 daemons/fenced/pacemaker-fenced.c pcmk__client_t *client = NULL; client 355 daemons/fenced/pacemaker-fenced.c client = pcmk__find_client_by_id(client_id); client 356 daemons/fenced/pacemaker-fenced.c if (!client) { client 367 daemons/fenced/pacemaker-fenced.c if (client) { client 368 daemons/fenced/pacemaker-fenced.c pcmk__ipc_send_xml(client, 0, notify_data, crm_ipc_server_event); client 312 daemons/fenced/pacemaker-fenced.h void stonith_command(pcmk__client_t *client, uint32_t id, uint32_t flags, client 325 daemons/fenced/pacemaker-fenced.h void do_local_reply(const xmlNode *notify_src, pcmk__client_t *client, client 332 daemons/fenced/pacemaker-fenced.h do_stonith_async_timeout_update(const char *client, const char *call_id, int timeout); client 341 daemons/fenced/pacemaker-fenced.h remote_fencing_op_t *initiate_remote_stonith_op(const pcmk__client_t *client, client 349 daemons/fenced/pacemaker-fenced.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer); client 360 daemons/fenced/pacemaker-fenced.h int fenced_handle_manual_confirmation(const pcmk__client_t *client, client 183 daemons/pacemakerd/pcmkd_messages.c pcmk__client_t *client = pcmk__find_client(c); client 185 daemons/pacemakerd/pcmkd_messages.c if (client == NULL) { client 189 daemons/pacemakerd/pcmkd_messages.c if (shutdown_complete_state_reported_to == client->pid) { client 195 daemons/pacemakerd/pcmkd_messages.c pcmk__free_client(client); client 339 daemons/schedulerd/schedulerd_messages.c pcmk__client_t *client = pcmk__find_client(c); client 341 daemons/schedulerd/schedulerd_messages.c if (client == NULL) { client 345 daemons/schedulerd/schedulerd_messages.c pcmk__free_client(client); client 162 include/crm/common/ipc.h void crm_ipc_close(crm_ipc_t * client); client 163 include/crm/common/ipc.h void crm_ipc_destroy(crm_ipc_t * client); client 166 include/crm/common/ipc.h int crm_ipc_send(crm_ipc_t *client, const xmlNode *message, client 169 include/crm/common/ipc.h int crm_ipc_get_fd(crm_ipc_t * client); client 170 include/crm/common/ipc.h bool crm_ipc_connected(crm_ipc_t * client); client 171 include/crm/common/ipc.h int crm_ipc_ready(crm_ipc_t * client); client 172 include/crm/common/ipc.h long crm_ipc_read(crm_ipc_t * client); client 173 include/crm/common/ipc.h const char *crm_ipc_buffer(crm_ipc_t * client); client 174 include/crm/common/ipc.h uint32_t crm_ipc_buffer_flags(crm_ipc_t * client); client 175 include/crm/common/ipc.h const char *crm_ipc_name(crm_ipc_t * client); client 30 include/crm/common/ipc_client_compat.h bool crm_ipc_connect(crm_ipc_t *client); client 161 include/crm/common/ipc_internal.h #define PCMK__CLIENT_TYPE(client) ((client)->flags & UINT64_C(0xff00000000)) client 194 include/crm/common/ipc_internal.h #define pcmk__set_client_flags(client, flags_to_set) do { \ client 195 include/crm/common/ipc_internal.h (client)->flags = pcmk__set_flags_as(__func__, __LINE__, \ client 197 include/crm/common/ipc_internal.h "Client", pcmk__client_name(client), \ client 198 include/crm/common/ipc_internal.h (client)->flags, (flags_to_set), #flags_to_set); \ client 201 include/crm/common/ipc_internal.h #define pcmk__clear_client_flags(client, flags_to_clear) do { \ client 202 include/crm/common/ipc_internal.h (client)->flags = pcmk__clear_flags_as(__func__, __LINE__, \ client 204 include/crm/common/ipc_internal.h "Client", pcmk__client_name(client), \ client 205 include/crm/common/ipc_internal.h (client)->flags, (flags_to_clear), #flags_to_clear); \ client 236 include/crm/common/ipc_internal.h void pcmk__set_client_queue_max(pcmk__client_t *client, const char *qmax); client 254 include/crm/common/ipc_internal.h void pcmk__ipc_free_client_buffer(crm_ipc_t *client); client 139 include/crm/common/mainloop.h void mainloop_del_ipc_client(mainloop_io_t * client); client 141 include/crm/common/mainloop.h crm_ipc_t *mainloop_get_ipc_client(mainloop_io_t * client); client 164 include/crm/common/mainloop.h void mainloop_del_fd(mainloop_io_t * client); client 132 include/crm/common/tls_internal.h int pcmk__read_handshake_data(const pcmk__client_t *client); client 178 include/crm/stonith-ng.h char *client; client 97 lib/cib/cib_client.c cib_notify_client_t *client = (cib_notify_client_t *) iter->data; client 99 lib/cib/cib_client.c if (strcmp(client->event, event) == 0) { client 693 lib/cib/cib_client.c cib_notify_client_t *client = g_list_nth_data(list, 0); client 695 lib/cib/cib_client.c list = g_list_remove(list, client); client 696 lib/cib/cib_client.c free(client); client 501 lib/cib/cib_utils.c const char *client = crm_element_value(req, client 510 lib/cib/cib_utils.c if (client != NULL) { client 775 lib/common/ipc_client.c const char *client = crm_system_name? crm_system_name : "client"; client 793 lib/common/ipc_client.c request = pcmk__new_request(api->server, client, NULL, client 879 lib/common/ipc_client.c crm_ipc_t *client = NULL; client 881 lib/common/ipc_client.c client = calloc(1, sizeof(crm_ipc_t)); client 882 lib/common/ipc_client.c if (client == NULL) { client 887 lib/common/ipc_client.c client->server_name = strdup(name); client 888 lib/common/ipc_client.c if (client->server_name == NULL) { client 891 lib/common/ipc_client.c free(client); client 895 lib/common/ipc_client.c client->buffer = NULL; client 896 lib/common/ipc_client.c client->pfd.fd = -1; client 897 lib/common/ipc_client.c client->pfd.events = POLLIN; client 898 lib/common/ipc_client.c client->pfd.revents = 0; client 900 lib/common/ipc_client.c return client; client 963 lib/common/ipc_client.c crm_ipc_close(crm_ipc_t * client) client 965 lib/common/ipc_client.c if (client) { client 966 lib/common/ipc_client.c if (client->ipc) { client 967 lib/common/ipc_client.c qb_ipcc_connection_t *ipc = client->ipc; client 969 lib/common/ipc_client.c client->ipc = NULL; client 976 lib/common/ipc_client.c crm_ipc_destroy(crm_ipc_t * client) client 978 lib/common/ipc_client.c if (client) { client 979 lib/common/ipc_client.c if (client->ipc && qb_ipcc_is_connected(client->ipc)) { client 981 lib/common/ipc_client.c client->server_name); client 993 lib/common/ipc_client.c client->server_name); client 996 lib/common/ipc_client.c if (client->buffer != NULL) { client 997 lib/common/ipc_client.c pcmk__ipc_free_client_buffer(client); client 1000 lib/common/ipc_client.c free(client->server_name); client 1001 lib/common/ipc_client.c free(client); client 1028 lib/common/ipc_client.c crm_ipc_get_fd(crm_ipc_t * client) client 1032 lib/common/ipc_client.c if (pcmk__ipc_fd(client, &fd) != pcmk_rc_ok) { client 1034 lib/common/ipc_client.c ((client == NULL)? "unspecified" : client->server_name)); client 1042 lib/common/ipc_client.c crm_ipc_connected(crm_ipc_t * client) client 1046 lib/common/ipc_client.c if (client == NULL) { client 1050 lib/common/ipc_client.c } else if (client->ipc == NULL) { client 1054 lib/common/ipc_client.c } else if (client->pfd.fd < 0) { client 1059 lib/common/ipc_client.c rc = qb_ipcc_is_connected(client->ipc); client 1061 lib/common/ipc_client.c client->pfd.fd = -EINVAL; client 1074 lib/common/ipc_client.c crm_ipc_ready(crm_ipc_t *client) client 1078 lib/common/ipc_client.c pcmk__assert(client != NULL); client 1080 lib/common/ipc_client.c if (!crm_ipc_connected(client)) { client 1084 lib/common/ipc_client.c client->pfd.revents = 0; client 1085 lib/common/ipc_client.c rc = poll(&(client->pfd), 1, 0); client 1090 lib/common/ipc_client.c crm_ipc_read(crm_ipc_t *client) client 1095 lib/common/ipc_client.c pcmk__assert((client != NULL) && (client->ipc != NULL)); client 1100 lib/common/ipc_client.c ssize_t bytes = qb_ipcc_event_recv(client->ipc, buffer, client 1107 lib/common/ipc_client.c client->server_name, strerror(-bytes)); client 1109 lib/common/ipc_client.c if (!crm_ipc_connected(client) || bytes == -ENOTCONN) { client 1110 lib/common/ipc_client.c crm_err("Connection to %s IPC failed", client->server_name); client 1112 lib/common/ipc_client.c pcmk__ipc_free_client_buffer(client); client 1122 lib/common/ipc_client.c pcmk__ipc_free_client_buffer(client); client 1127 lib/common/ipc_client.c client->server_name, header->qb.id, header->qb.size, client 1130 lib/common/ipc_client.c rc = pcmk__ipc_msg_append(&client->buffer, buffer); client 1137 lib/common/ipc_client.c pcmk__ipc_free_client_buffer(client); client 1143 lib/common/ipc_client.c if (client->buffer->len > 0) { client 1145 lib/common/ipc_client.c rc = client->buffer->len - sizeof(pcmk__ipc_header_t); client 1154 lib/common/ipc_client.c pcmk__ipc_free_client_buffer(crm_ipc_t *client) client 1156 lib/common/ipc_client.c pcmk__assert(client != NULL); client 1158 lib/common/ipc_client.c if (client->buffer != NULL) { client 1159 lib/common/ipc_client.c g_byte_array_free(client->buffer, TRUE); client 1160 lib/common/ipc_client.c client->buffer = NULL; client 1165 lib/common/ipc_client.c crm_ipc_buffer(crm_ipc_t * client) client 1167 lib/common/ipc_client.c pcmk__assert(client != NULL); client 1168 lib/common/ipc_client.c CRM_CHECK(client->buffer != NULL, return NULL); client 1169 lib/common/ipc_client.c return (const char *) (client->buffer->data + sizeof(pcmk__ipc_header_t)); client 1173 lib/common/ipc_client.c crm_ipc_buffer_flags(crm_ipc_t * client) client 1177 lib/common/ipc_client.c pcmk__assert(client != NULL); client 1178 lib/common/ipc_client.c if (client->buffer == NULL) { client 1182 lib/common/ipc_client.c header = (pcmk__ipc_header_t *)(void*) client->buffer->data; client 1187 lib/common/ipc_client.c crm_ipc_name(crm_ipc_t * client) client 1189 lib/common/ipc_client.c pcmk__assert(client != NULL); client 1190 lib/common/ipc_client.c return client->server_name; client 1195 lib/common/ipc_client.c internal_ipc_get_reply(crm_ipc_t *client, int request_id, int ms_timeout, client 1211 lib/common/ipc_client.c crm_trace("Expecting reply to %s IPC message %d", client->server_name, client 1220 lib/common/ipc_client.c *bytes = qb_ipcc_recv(client->ipc, buffer, crm_ipc_default_buffer_size(), client 1226 lib/common/ipc_client.c if (!crm_ipc_connected(client)) { client 1228 lib/common/ipc_client.c client->server_name, request_id); client 1244 lib/common/ipc_client.c rc = pcmk__ipc_msg_append(&client->buffer, buffer); client 1268 lib/common/ipc_client.c if (client->buffer->len > 0) { client 1270 lib/common/ipc_client.c client->buffer->len, reply_id, client->server_name, client 1271 lib/common/ipc_client.c request_id, crm_ipc_buffer(client)); client 1274 lib/common/ipc_client.c *reply = pcmk__xml_parse(crm_ipc_buffer(client)); client 1279 lib/common/ipc_client.c client->server_name, request_id, pcmk_rc_str(rc), rc); client 1292 lib/common/ipc_client.c pcmk__ipc_free_client_buffer(client); client 1298 lib/common/ipc_client.c discard_old_replies(crm_ipc_t *client, int32_t ms_timeout) client 1306 lib/common/ipc_client.c qb_rc = qb_ipcc_recv(client->ipc, buffer, crm_ipc_default_buffer_size(), client 1311 lib/common/ipc_client.c client->server_name); client 1324 lib/common/ipc_client.c client->server_name); client 1325 lib/common/ipc_client.c client->need_reply = FALSE; client 1329 lib/common/ipc_client.c "reply received", client->server_name); client 1352 lib/common/ipc_client.c crm_ipc_send(crm_ipc_t *client, const xmlNode *message, client 1364 lib/common/ipc_client.c if (client == NULL) { client 1369 lib/common/ipc_client.c } else if (!crm_ipc_connected(client)) { client 1372 lib/common/ipc_client.c client->server_name); client 1384 lib/common/ipc_client.c if (client->need_reply) { client 1385 lib/common/ipc_client.c int discard_rc = discard_old_replies(client, ms_timeout); client 1406 lib/common/ipc_client.c client->server_name, pcmk_rc_str(rc), rc); client 1412 lib/common/ipc_client.c pcmk__set_ipc_flags(header->flags, client->server_name, flags); client 1423 lib/common/ipc_client.c client->server_name, header->qb.id, is_end ? "final " : "", client 1429 lib/common/ipc_client.c client->server_name, header->qb.id, header->qb.size, client 1440 lib/common/ipc_client.c qb_rc = qb_ipcc_sendv(client->ipc, iov, 2); client 1477 lib/common/ipc_client.c client->server_name, header->qb.id); client 1481 lib/common/ipc_client.c pcmk__ipc_free_client_buffer(client); client 1482 lib/common/ipc_client.c rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes, reply); client 1499 lib/common/ipc_client.c client->need_reply = TRUE; client 1504 lib/common/ipc_client.c if (!crm_ipc_connected(client)) { client 1506 lib/common/ipc_client.c QB_XS " rc=%d", client->server_name, header->qb.id, rc); client 1510 lib/common/ipc_client.c client->server_name, header->qb.id, pcmk_strerror(rc), client 1516 lib/common/ipc_client.c client->server_name, header->qb.id, client 1766 lib/common/ipc_client.c crm_ipc_connect(crm_ipc_t *client) client 1768 lib/common/ipc_client.c int rc = pcmk__connect_generic_ipc(client); client 1773 lib/common/ipc_client.c if ((client != NULL) && (client->ipc == NULL)) { client 1776 lib/common/ipc_client.c client->server_name, pcmk_rc_str(errno), errno); client 1779 lib/common/ipc_client.c (client == NULL)? "Pacemaker" : client->server_name); client 1783 lib/common/ipc_client.c (client == NULL)? "Pacemaker" : client->server_name); client 74 lib/common/ipc_server.c pcmk__client_t *client = NULL; 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 166 lib/common/ipc_server.c pcmk__client_t *client = pcmk__assert_alloc(1, sizeof(pcmk__client_t)); client 169 lib/common/ipc_server.c client->user = pcmk__uid2username(uid_client); client 170 lib/common/ipc_server.c if (client->user == NULL) { client 171 lib/common/ipc_server.c client->user = pcmk__str_copy("#unprivileged"); client 175 lib/common/ipc_server.c client->ipcs = c; client 176 lib/common/ipc_server.c pcmk__set_client_flags(client, pcmk__client_ipc); client 177 lib/common/ipc_server.c client->pid = pcmk__client_pid(c); client 183 lib/common/ipc_server.c client->id = crm_generate_uuid(); client 185 lib/common/ipc_server.c key = client->id; client 191 lib/common/ipc_server.c g_hash_table_insert(client_connections, key, client); client 192 lib/common/ipc_server.c return client; client 214 lib/common/ipc_server.c pcmk__client_t *client = NULL; client 235 lib/common/ipc_server.c client = client_from_connection(c, NULL, uid_client); client 239 lib/common/ipc_server.c pcmk__set_client_flags(client, pcmk__client_privileged); client 243 lib/common/ipc_server.c client->id, client->pid, uid_client, gid_client); client 244 lib/common/ipc_server.c return client; client 345 lib/common/ipc_server.c pcmk__set_client_queue_max(pcmk__client_t *client, const char *qmax) client 351 lib/common/ipc_server.c CRM_CHECK(client != NULL, return); client 353 lib/common/ipc_server.c orig_value = client->queue_max; client 355 lib/common/ipc_server.c if (pcmk_is_set(client->flags, pcmk__client_privileged)) { client 361 lib/common/ipc_server.c client->queue_max = (unsigned int) qmax_ll; client 370 lib/common/ipc_server.c pcmk__client_name(client), client->pid, client 373 lib/common/ipc_server.c } else if (client->queue_max != orig_value) { client 375 lib/common/ipc_server.c pcmk__client_name(client), client->pid, client 376 lib/common/ipc_server.c client->queue_max, orig_value); client 717 lib/common/mainloop.c mainloop_io_t *client = data; client 719 lib/common/mainloop.c pcmk__assert(client->fd == g_io_channel_unix_get_fd(gio)); client 722 lib/common/mainloop.c if (client->ipc) { client 727 lib/common/mainloop.c read_rc = crm_ipc_read(client->ipc); client 730 lib/common/mainloop.c client->name, pcmk_strerror(read_rc), read_rc); client 736 lib/common/mainloop.c } else if (client->dispatch_fn_ipc) { client 737 lib/common/mainloop.c const char *buffer = crm_ipc_buffer(client->ipc); client 741 lib/common/mainloop.c read_rc, client->name, (int) condition); client 742 lib/common/mainloop.c if (client->dispatch_fn_ipc(buffer, read_rc, client->userdata) < 0) { client 743 lib/common/mainloop.c crm_trace("Connection to %s no longer required", client->name); client 748 lib/common/mainloop.c pcmk__ipc_free_client_buffer(client->ipc); client 754 lib/common/mainloop.c client->name, (int) condition); client 755 lib/common/mainloop.c if (client->dispatch_fn_io) { client 756 lib/common/mainloop.c if (client->dispatch_fn_io(client->userdata) < 0) { client 757 lib/common/mainloop.c crm_trace("Connection to %s no longer required", client->name); client 764 lib/common/mainloop.c if (client->ipc && !crm_ipc_connected(client->ipc)) { client 766 lib/common/mainloop.c client->name, client, condition); client 771 lib/common/mainloop.c client->name, client, condition); client 814 lib/common/mainloop.c mainloop_io_t *client = c; client 815 lib/common/mainloop.c char *c_name = strdup(client->name); client 822 lib/common/mainloop.c if (client->ipc) { client 823 lib/common/mainloop.c crm_ipc_close(client->ipc); client 826 lib/common/mainloop.c if (client->destroy_fn) { client 827 lib/common/mainloop.c void (*destroy_fn) (gpointer userdata) = client->destroy_fn; client 829 lib/common/mainloop.c client->destroy_fn = NULL; client 830 lib/common/mainloop.c destroy_fn(client->userdata); client 833 lib/common/mainloop.c if (client->ipc) { client 834 lib/common/mainloop.c crm_ipc_t *ipc = client->ipc; client 836 lib/common/mainloop.c client->ipc = NULL; client 842 lib/common/mainloop.c free(client->name); client->name = NULL; client 843 lib/common/mainloop.c free(client); client 947 lib/common/mainloop.c mainloop_del_ipc_client(mainloop_io_t * client) client 949 lib/common/mainloop.c mainloop_del_fd(client); client 953 lib/common/mainloop.c mainloop_get_ipc_client(mainloop_io_t * client) client 955 lib/common/mainloop.c if (client) { client 956 lib/common/mainloop.c return client->ipc; client 965 lib/common/mainloop.c mainloop_io_t *client = NULL; client 968 lib/common/mainloop.c client = calloc(1, sizeof(mainloop_io_t)); client 969 lib/common/mainloop.c if (client == NULL) { client 972 lib/common/mainloop.c client->name = strdup(name); client 973 lib/common/mainloop.c client->userdata = userdata; client 976 lib/common/mainloop.c client->destroy_fn = callbacks->destroy; client 977 lib/common/mainloop.c client->dispatch_fn_io = callbacks->dispatch; client 980 lib/common/mainloop.c client->fd = fd; client 981 lib/common/mainloop.c client->channel = g_io_channel_unix_new(fd); client 982 lib/common/mainloop.c client->source = client 983 lib/common/mainloop.c g_io_add_watch_full(client->channel, priority, client 985 lib/common/mainloop.c client, mainloop_gio_destroy); client 996 lib/common/mainloop.c g_io_channel_unref(client->channel); client 997 lib/common/mainloop.c crm_trace("Added connection %d for %s[%p].%d", client->source, client->name, client, fd); client 1002 lib/common/mainloop.c return client; client 1006 lib/common/mainloop.c mainloop_del_fd(mainloop_io_t * client) client 1008 lib/common/mainloop.c if (client != NULL) { client 1009 lib/common/mainloop.c crm_trace("Removing client %s[%p]", client->name, client); client 1010 lib/common/mainloop.c if (client->source) { client 1014 lib/common/mainloop.c g_source_remove(client->source); client 429 lib/common/tls.c pcmk__read_handshake_data(const pcmk__client_t *client) client 433 lib/common/tls.c pcmk__assert((client != NULL) && (client->remote != NULL) client 434 lib/common/tls.c && (client->remote->tls_session != NULL)); client 437 lib/common/tls.c rc = gnutls_handshake(client->remote->tls_session); client 747 lib/fencing/st_client.c kvp->client = crm_element_value_copy(op, PCMK__XA_ST_CLIENTNAME); client 789 lib/fencing/st_client.c free(head->client); client 131 lib/fencing/st_output.c pcmk__g_strcat(str, " for ", history->client, "@", history->origin, client 159 lib/fencing/st_output.c PCMK_XA_CLIENT "=", history->client, ", " client 483 lib/fencing/st_output.c PCMK_XA_CLIENT, event->client, client 216 lib/pengine/pe_output.c const char *client, const char *origin) { client 217 lib/pengine/pe_output.c if (last_written != NULL || user != NULL || client != NULL || origin != NULL) { client 222 lib/pengine/pe_output.c client ? " via " : "", client 223 lib/pengine/pe_output.c client ? client : "", client 445 lib/pengine/pe_output.c const char *client = crm_element_value(scheduler->input, client 452 lib/pengine/pe_output.c last_written, user, client, origin); client 521 lib/pengine/pe_output.c const char *client = crm_element_value(scheduler->input, client 528 lib/pengine/pe_output.c last_written, user, client, origin); client 1310 lib/pengine/pe_output.c const char *client = va_arg(args, const char *); client 1341 lib/pengine/pe_output.c time_s = last_changed_string(last_written, user, client, origin); client 1355 lib/pengine/pe_output.c const char *client = va_arg(args, const char *); client 1368 lib/pengine/pe_output.c PCMK_XA_CLIENT, pcmk__s(client, ""), client 1383 lib/pengine/pe_output.c const char *client = va_arg(args, const char *); client 1393 lib/pengine/pe_output.c time_s = last_changed_string(last_written, user, client, origin); client 157 lib/services/dbus.c mainloop_io_t *client = mainloop_add_fd("dbus", G_PRIORITY_DEFAULT, fd, client 161 lib/services/dbus.c dbus_watch_set_data(watch, client, NULL);