client            520 daemons/attrd/attrd_ipc.c     pcmk__client_t *client = pcmk__find_client(c);
client            522 daemons/attrd/attrd_ipc.c     if (client == NULL) {
client            528 daemons/attrd/attrd_ipc.c         attrd_remove_client_from_waitlist(client);
client            531 daemons/attrd/attrd_ipc.c         attrd_do_not_wait_for_client(client);
client            533 daemons/attrd/attrd_ipc.c         pcmk__free_client(client);
client            560 daemons/attrd/attrd_ipc.c     pcmk__client_t *client = pcmk__find_client(c);
client            564 daemons/attrd/attrd_ipc.c     CRM_CHECK((c != NULL) && (client != NULL), return 0);
client            570 daemons/attrd/attrd_ipc.c     xml = pcmk__client_data2xml(client, data, &id, &flags);
client            574 daemons/attrd/attrd_ipc.c         pcmk__ipc_send_ack(client, id, flags, "ack", NULL, CRM_EX_PROTOCOL);
client            579 daemons/attrd/attrd_ipc.c             .ipc_client     = client,
client            588 daemons/attrd/attrd_ipc.c         CRM_ASSERT(client->user != NULL);
client            589 daemons/attrd/attrd_ipc.c         pcmk__update_acl_user(xml, PCMK__XA_ATTR_USER, client->user);
client            205 daemons/attrd/attrd_sync.c attrd_remove_client_from_waitlist(pcmk__client_t *client)
client            219 daemons/attrd/attrd_sync.c         if (pcmk__str_eq(wl->client_id, client->id, pcmk__str_none)) {
client            256 daemons/attrd/attrd_sync.c         pcmk__client_t *client = NULL;
client            265 daemons/attrd/attrd_sync.c         client = pcmk__find_client_by_id(wl->client_id);
client            266 daemons/attrd/attrd_sync.c         if (client == NULL) {
client            270 daemons/attrd/attrd_sync.c         attrd_send_ack(client, wl->ipc_id, wl->flags | crm_ipc_client_response);
client            376 daemons/attrd/attrd_sync.c             pcmk__client_t *client = pcmk__find_client_by_id(action->client_id);
client            377 daemons/attrd/attrd_sync.c             if (client == NULL) {
client            381 daemons/attrd/attrd_sync.c             crm_trace("Timed out waiting for confirmations for client %s", client->id);
client            382 daemons/attrd/attrd_sync.c             pcmk__ipc_send_ack(client, action->ipc_id, action->flags | crm_ipc_client_response,
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             51 daemons/attrd/pacemaker-attrd.h #define attrd_send_ack(client, id, flags) \
client             52 daemons/attrd/pacemaker-attrd.h     pcmk__ipc_send_ack((client), (id), (flags), "ack", ATTRD_PROTOCOL_VERSION, CRM_EX_INDETERMINATE)
client            204 daemons/attrd/pacemaker-attrd.h void attrd_do_not_wait_for_client(pcmk__client_t *client);
client            208 daemons/attrd/pacemaker-attrd.h void attrd_remove_client_from_waitlist(pcmk__client_t *client);
client             86 daemons/based/based_callbacks.c     pcmk__client_t *client = pcmk__find_client(c);
client             88 daemons/based/based_callbacks.c     crm_trace("%p message from %s", c, client->id);
client             95 daemons/based/based_callbacks.c     pcmk__client_t *client = pcmk__find_client(c);
client             97 daemons/based/based_callbacks.c     crm_trace("%p message from %s", c, client->id);
client            105 daemons/based/based_callbacks.c     pcmk__client_t *client = pcmk__find_client(c);
client            107 daemons/based/based_callbacks.c     if (client == NULL) {
client            111 daemons/based/based_callbacks.c     pcmk__free_client(client);
client             45 daemons/based/based_notify.c     pcmk__client_t *client = value;
client             48 daemons/based/based_notify.c     if (client->ipcs == NULL && client->remote == NULL) {
client             56 daemons/based/based_notify.c     if (pcmk_is_set(client->flags, cib_notify_diff)
client             61 daemons/based/based_notify.c     } else if (pcmk_is_set(client->flags, cib_notify_replace)
client             65 daemons/based/based_notify.c     } else if (pcmk_is_set(client->flags, cib_notify_confirm)
client             69 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             86 daemons/based/based_notify.c                              pcmk__client_name(client), pcmk_rc_str(rc),
client             87 daemons/based/based_notify.c                              client->id);
client             95 daemons/based/based_notify.c                           type, pcmk__client_name(client), client->id);
client             96 daemons/based/based_notify.c                 pcmk__remote_send_xml(client->remote, update->msg);
client            101 daemons/based/based_notify.c                         pcmk__client_name(client), client->flags);
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 (pcmk_is_set(client->flags, pcmk__client_authenticated)) {
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            364 daemons/based/based_remote.c               pcmk__client_name(client));
client            369 daemons/based/based_remote.c     switch (PCMK__CLIENT_TYPE(client)) {
client            371 daemons/based/based_remote.c             csock = client->remote->tcp_socket;
client            375 daemons/based/based_remote.c             if (client->remote->tls_session) {
client            376 daemons/based/based_remote.c                 void *sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session);
client            379 daemons/based/based_remote.c                 if (pcmk_is_set(client->flags,
client            381 daemons/based/based_remote.c                     gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_WR);
client            383 daemons/based/based_remote.c                 gnutls_deinit(*client->remote->tls_session);
client            384 daemons/based/based_remote.c                 gnutls_free(client->remote->tls_session);
client            385 daemons/based/based_remote.c                 client->remote->tls_session = NULL;
client            392 daemons/based/based_remote.c                      pcmk__client_name(client), client->flags);
client            399 daemons/based/based_remote.c     pcmk__free_client(client);
client            410 daemons/based/based_remote.c cib_handle_remote_msg(pcmk__client_t *client, xmlNode *command)
client            420 daemons/based/based_remote.c     if (client->name == NULL) {
client            423 daemons/based/based_remote.c             client->name = strdup(client->id);
client            425 daemons/based/based_remote.c             client->name = strdup(value);
client            435 daemons/based/based_remote.c     crm_xml_add(command, F_CIB_CLIENTID, client->id);
client            436 daemons/based/based_remote.c     crm_xml_add(command, F_CIB_CLIENTNAME, client->name);
client            437 daemons/based/based_remote.c     crm_xml_add(command, F_CIB_USER, client->user);
client            452 daemons/based/based_remote.c     cib_common_callback_worker(0, 0, command, client, TRUE);
client            459 daemons/based/based_remote.c     pcmk__client_t *client = data;
client            463 daemons/based/based_remote.c     if (pcmk_is_set(client->flags, pcmk__client_authenticated)) {
client            468 daemons/based/based_remote.c               pcmk__client_type_str(PCMK__CLIENT_TYPE(client)),
client            469 daemons/based/based_remote.c               pcmk__client_name(client));
client            472 daemons/based/based_remote.c     if ((PCMK__CLIENT_TYPE(client) == pcmk__client_tls)
client            473 daemons/based/based_remote.c         && !pcmk_is_set(client->flags, pcmk__client_tls_handshake_complete)) {
client            475 daemons/based/based_remote.c         int rc = pcmk__read_handshake_data(client);
client            487 daemons/based/based_remote.c         pcmk__set_client_flags(client, pcmk__client_tls_handshake_complete);
client            488 daemons/based/based_remote.c         if (client->remote->auth_timeout) {
client            489 daemons/based/based_remote.c             g_source_remove(client->remote->auth_timeout);
client            493 daemons/based/based_remote.c         client->remote->auth_timeout = g_timeout_add(REMOTE_AUTH_TIMEOUT,
client            495 daemons/based/based_remote.c                                                      client);
client            500 daemons/based/based_remote.c     rc = pcmk__read_remote_message(client->remote, timeout);
client            503 daemons/based/based_remote.c     if (!pcmk_is_set(client->flags, pcmk__client_authenticated)) {
client            507 daemons/based/based_remote.c         command = pcmk__remote_message_xml(client->remote);
client            514 daemons/based/based_remote.c         pcmk__set_client_flags(client, pcmk__client_authenticated);
client            515 daemons/based/based_remote.c         g_source_remove(client->remote->auth_timeout);
client            516 daemons/based/based_remote.c         client->remote->auth_timeout = 0;
client            517 daemons/based/based_remote.c         client->name = crm_element_value_copy(command, "name");
client            521 daemons/based/based_remote.c             client->user = strdup(user);
client            527 daemons/based/based_remote.c         crm_xml_add(reg, F_CIB_CLIENTID, client->id);
client            528 daemons/based/based_remote.c         pcmk__remote_send_xml(client->remote, reg);
client            533 daemons/based/based_remote.c     command = pcmk__remote_message_xml(client->remote);
client            536 daemons/based/based_remote.c         cib_handle_remote_msg(client, command);
client            538 daemons/based/based_remote.c         command = pcmk__remote_message_xml(client->remote);
client            387 daemons/controld/controld_control.c     pcmk__client_t *client = pcmk__find_client(c);
client            389 daemons/controld/controld_control.c     xmlNode *msg = pcmk__client_data2xml(client, data, &id, &flags);
client            392 daemons/controld/controld_control.c         pcmk__ipc_send_ack(client, id, flags, "ack", NULL, CRM_EX_PROTOCOL);
client            395 daemons/controld/controld_control.c     pcmk__ipc_send_ack(client, id, flags, "ack", NULL, CRM_EX_INDETERMINATE);
client            397 daemons/controld/controld_control.c     CRM_ASSERT(client->user != NULL);
client            398 daemons/controld/controld_control.c     pcmk__update_acl_user(msg, F_CRM_USER, client->user);
client            400 daemons/controld/controld_control.c     crm_xml_add(msg, F_CRM_SYS_FROM, client->id);
client            401 daemons/controld/controld_control.c     if (controld_authorize_ipc_message(msg, client, NULL)) {
client            403 daemons/controld/controld_control.c                   pcmk__client_name(client));
client            415 daemons/controld/controld_control.c     pcmk__client_t *client = pcmk__find_client(c);
client            417 daemons/controld/controld_control.c     if (client) {
client            419 daemons/controld/controld_control.c                   (client->userdata? "" : "un"), pcmk__client_name(client),
client            420 daemons/controld/controld_control.c                   c, client);
client            421 daemons/controld/controld_control.c         free(client->userdata);
client            422 daemons/controld/controld_control.c         pcmk__free_client(client);
client            485 daemons/controld/controld_fencing.c     const char *client = "a client";
client            503 daemons/controld/controld_fencing.c         client = event->client_origin;
client            522 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            601 daemons/controld/controld_fencing.c             if (!pcmk__str_eq(client, te_client_id, pcmk__str_casei)) {
client            606 daemons/controld/controld_fencing.c                          client, event->target);
client            104 daemons/execd/execd_alerts.c process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id, xmlNode *request)
client            118 daemons/execd/execd_alerts.c         (client == NULL) || (client->id == NULL)) { /* hint static analyzer */
client            127 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 = strdup(client->id);
client            298 daemons/execd/execd_commands.c create_lrmd_cmd(xmlNode *msg, pcmk__client_t *client)
client            308 daemons/execd/execd_commands.c     cmd->client_id = strdup(client->id);
client            550 daemons/execd/execd_commands.c     pcmk__client_t *client = value;
client            555 daemons/execd/execd_commands.c     CRM_CHECK(client != NULL, return);
client            556 daemons/execd/execd_commands.c     if (client->name == NULL) {
client            560 daemons/execd/execd_commands.c     if (pcmk_is_set(client->flags, pcmk__client_to_proxy)) {
client            566 daemons/execd/execd_commands.c                   pcmk__client_name(client));
client            570 daemons/execd/execd_commands.c     rc = lrmd_server_send_notify(client, update_msg);
client            587 daemons/execd/execd_commands.c                pcmk__client_name(client), msg, rc);
client            669 daemons/execd/execd_commands.c         pcmk__client_t *client = pcmk__find_client_by_id(cmd->client_id);
client            671 daemons/execd/execd_commands.c         if (client != NULL) {
client            672 daemons/execd/execd_commands.c             send_client_notify(client->id, client, notify);
client            767 daemons/execd/execd_commands.c     pcmk__client_t *client = value;
client            770 daemons/execd/execd_commands.c     if (!pcmk__str_eq(client->id, data->new_client->id, pcmk__str_casei)) {
client            771 daemons/execd/execd_commands.c         send_client_notify(key, (gpointer) client, (gpointer) data->notify);
client           1471 daemons/execd/execd_commands.c process_lrmd_signon(pcmk__client_t *client, xmlNode *request, int call_id,
client           1486 daemons/execd/execd_commands.c         if ((client->remote != NULL)
client           1487 daemons/execd/execd_commands.c             && pcmk_is_set(client->flags,
client           1491 daemons/execd/execd_commands.c             ipc_proxy_add_provider(client);
client           1502 daemons/execd/execd_commands.c     crm_xml_add(*reply, F_LRMD_CLIENTID, client->id);
client           1510 daemons/execd/execd_commands.c process_lrmd_rsc_register(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1560 daemons/execd/execd_commands.c process_lrmd_rsc_unregister(pcmk__client_t *client, uint32_t id,
client           1592 daemons/execd/execd_commands.c process_lrmd_rsc_exec(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1609 daemons/execd/execd_commands.c     cmd = create_lrmd_cmd(request, client);
client           1717 daemons/execd/execd_commands.c process_lrmd_rsc_cancel(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1797 daemons/execd/execd_commands.c process_lrmd_message(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1810 daemons/execd/execd_commands.c     bool allowed = pcmk_is_set(client->flags, pcmk__client_privileged);
client           1812 daemons/execd/execd_commands.c     crm_trace("Processing %s operation from %s", op, client->id);
client           1818 daemons/execd/execd_commands.c             ipc_proxy_forward_client(client, request);
client           1827 daemons/execd/execd_commands.c         rc = process_lrmd_signon(client, request, call_id, &reply);
client           1831 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_register(client, id, request);
client           1846 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_unregister(client, id, request);
client           1857 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_exec(client, id, request);
client           1864 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_cancel(client, id, request);
client           1883 daemons/execd/execd_commands.c             rc = process_lrmd_alert_exec(client, id, request);
client           1899 daemons/execd/execd_commands.c                 op, pcmk__client_name(client));
client           1904 daemons/execd/execd_commands.c                  op, pcmk__client_name(client));
client           1908 daemons/execd/execd_commands.c               op, client->id, rc, do_reply, do_notify);
client           1916 daemons/execd/execd_commands.c         send_rc = lrmd_server_send_reply(client, id, reply);
client           1920 daemons/execd/execd_commands.c                      pcmk__client_name(client), pcmk_rc_str(send_rc), send_rc);
client            128 daemons/execd/pacemaker-execd.c     pcmk__client_t *client = pcmk__find_client(c);
client            129 daemons/execd/pacemaker-execd.c     xmlNode *request = pcmk__client_data2xml(client, data, &id, &flags);
client            131 daemons/execd/pacemaker-execd.c     CRM_CHECK(client != NULL, crm_err("Invalid client");
client            133 daemons/execd/pacemaker-execd.c     CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p", client);
client            136 daemons/execd/pacemaker-execd.c     CRM_CHECK(flags & crm_ipc_client_response, crm_err("Invalid client request: %p", client);
client            143 daemons/execd/pacemaker-execd.c     if (!client->name) {
client            147 daemons/execd/pacemaker-execd.c             client->name = pcmk__itoa(pcmk__client_pid(c));
client            149 daemons/execd/pacemaker-execd.c             client->name = strdup(value);
client            158 daemons/execd/pacemaker-execd.c     crm_xml_add(request, F_LRMD_CLIENTID, client->id);
client            159 daemons/execd/pacemaker-execd.c     crm_xml_add(request, F_LRMD_CLIENTNAME, client->name);
client            162 daemons/execd/pacemaker-execd.c     process_lrmd_message(client, id, request);
client            175 daemons/execd/pacemaker-execd.c lrmd_client_destroy(pcmk__client_t *client)
client            177 daemons/execd/pacemaker-execd.c     pcmk__free_client(client);
client            192 daemons/execd/pacemaker-execd.c     pcmk__client_t *client = pcmk__find_client(c);
client            194 daemons/execd/pacemaker-execd.c     if (client == NULL) {
client            199 daemons/execd/pacemaker-execd.c     client_disconnect_cleanup(client->id);
client            201 daemons/execd/pacemaker-execd.c     ipc_proxy_remove_provider(client);
client            203 daemons/execd/pacemaker-execd.c     lrmd_client_destroy(client);
client            224 daemons/execd/pacemaker-execd.c lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply)
client            226 daemons/execd/pacemaker-execd.c     crm_trace("Sending reply (%d) to client (%s)", id, client->id);
client            227 daemons/execd/pacemaker-execd.c     switch (PCMK__CLIENT_TYPE(client)) {
client            229 daemons/execd/pacemaker-execd.c             return pcmk__ipc_send_xml(client, id, reply, FALSE);
client            232 daemons/execd/pacemaker-execd.c             return lrmd__remote_send_xml(client->remote, reply, id, "reply");
client            237 daemons/execd/pacemaker-execd.c                     pcmk__client_name(client), client->flags);
client            244 daemons/execd/pacemaker-execd.c lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg)
client            246 daemons/execd/pacemaker-execd.c     crm_trace("Sending notification to client (%s)", client->id);
client            247 daemons/execd/pacemaker-execd.c     switch (PCMK__CLIENT_TYPE(client)) {
client            249 daemons/execd/pacemaker-execd.c             if (client->ipcs == NULL) {
client            253 daemons/execd/pacemaker-execd.c             return pcmk__ipc_send_xml(client, 0, msg, crm_ipc_server_event);
client            256 daemons/execd/pacemaker-execd.c             if (client->remote == NULL) {
client            260 daemons/execd/pacemaker-execd.c                 return lrmd__remote_send_xml(client->remote, msg, 0, "notify");
client            266 daemons/execd/pacemaker-execd.c                     pcmk__client_name(client), client->flags);
client             63 daemons/execd/pacemaker-execd.h int lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply);
client             65 daemons/execd/pacemaker-execd.h int lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg);
client             69 daemons/execd/pacemaker-execd.h void process_lrmd_message(pcmk__client_t *client, uint32_t id,
client             78 daemons/execd/pacemaker-execd.h void lrmd_client_destroy(pcmk__client_t *client);
client             98 daemons/execd/pacemaker-execd.h void ipc_proxy_add_provider(pcmk__client_t *client);
client             99 daemons/execd/pacemaker-execd.h void ipc_proxy_remove_provider(pcmk__client_t *client);
client            100 daemons/execd/pacemaker-execd.h void ipc_proxy_forward_client(pcmk__client_t *client, xmlNode *xml);
client            106 daemons/execd/pacemaker-execd.h int process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id,
client             69 daemons/execd/remoted_proxy.c     pcmk__client_t *client;
client             82 daemons/execd/remoted_proxy.c     client = pcmk__new_client(c, uid, gid);
client             83 daemons/execd/remoted_proxy.c     if (client == NULL) {
client             89 daemons/execd/remoted_proxy.c     client->userdata = strdup(ipc_proxy->id);
client             90 daemons/execd/remoted_proxy.c     client->name = crm_strdup_printf("proxy-%s-%d-%.8s", ipc_channel, client->pid, client->id);
client             95 daemons/execd/remoted_proxy.c     pcmk__set_client_flags(client, pcmk__client_to_proxy);
client             97 daemons/execd/remoted_proxy.c     g_hash_table_insert(ipc_clients, client->id, client);
client            102 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
client            107 daemons/execd/remoted_proxy.c               client->id, uid, gid, ipc_channel);
client            226 daemons/execd/remoted_proxy.c     pcmk__client_t *client = pcmk__find_client(c);
client            227 daemons/execd/remoted_proxy.c     pcmk__client_t *ipc_proxy = pcmk__find_client_by_id(client->userdata);
client            232 daemons/execd/remoted_proxy.c         qb_ipcs_disconnect(client->ipcs);
client            249 daemons/execd/remoted_proxy.c     request = pcmk__client_data2xml(client, data, &id, &flags);
client            255 daemons/execd/remoted_proxy.c     CRM_CHECK(client != NULL, crm_err("Invalid client");
client            257 daemons/execd/remoted_proxy.c     CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p", client);
client            263 daemons/execd/remoted_proxy.c     pcmk__set_ipc_flags(flags, pcmk__client_name(client), crm_ipc_proxied);
client            264 daemons/execd/remoted_proxy.c     client->request_id = id;
client            268 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
client            269 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_CLIENT, pcmk__client_name(client));
client            270 daemons/execd/remoted_proxy.c     crm_xml_add(msg, F_LRMD_IPC_USER, client->user);
client            310 daemons/execd/remoted_proxy.c     pcmk__client_t *client = pcmk__find_client(c);
client            313 daemons/execd/remoted_proxy.c     if (client == NULL) {
client            317 daemons/execd/remoted_proxy.c     ipc_proxy = pcmk__find_client_by_id(client->userdata);
client            324 daemons/execd/remoted_proxy.c         crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
client            329 daemons/execd/remoted_proxy.c     g_hash_table_remove(ipc_clients, client->id);
client            331 daemons/execd/remoted_proxy.c     free(client->userdata);
client            332 daemons/execd/remoted_proxy.c     client->userdata = NULL;
client            333 daemons/execd/remoted_proxy.c     pcmk__free_client(client);
client             56 daemons/execd/remoted_tls.c remoted__read_handshake_data(pcmk__client_t *client)
client             58 daemons/execd/remoted_tls.c     int rc = pcmk__read_handshake_data(client);
client             69 daemons/execd/remoted_tls.c     if (client->remote->auth_timeout) {
client             70 daemons/execd/remoted_tls.c         g_source_remove(client->remote->auth_timeout);
client             72 daemons/execd/remoted_tls.c     client->remote->auth_timeout = 0;
client             74 daemons/execd/remoted_tls.c     pcmk__set_client_flags(client, pcmk__client_tls_handshake_complete);
client             80 daemons/execd/remoted_tls.c     pcmk__set_client_flags(client, pcmk__client_privileged);
client             83 daemons/execd/remoted_tls.c     notify_of_new_client(client);
client             93 daemons/execd/remoted_tls.c     pcmk__client_t *client = data;
client             95 daemons/execd/remoted_tls.c     if (!pcmk_is_set(client->flags,
client             97 daemons/execd/remoted_tls.c         return remoted__read_handshake_data(client);
client            100 daemons/execd/remoted_tls.c     switch (pcmk__remote_ready(client->remote, 0)) {
client            110 daemons/execd/remoted_tls.c     rc = pcmk__read_remote_message(client->remote, -1);
client            112 daemons/execd/remoted_tls.c     request = pcmk__remote_message_xml(client->remote);
client            116 daemons/execd/remoted_tls.c         if (!client->name) {
client            120 daemons/execd/remoted_tls.c                 client->name = strdup(value);
client            129 daemons/execd/remoted_tls.c         crm_xml_add(request, F_LRMD_CLIENTID, client->id);
client            130 daemons/execd/remoted_tls.c         crm_xml_add(request, F_LRMD_CLIENTNAME, client->name);
client            133 daemons/execd/remoted_tls.c         process_lrmd_message(client, id, request);
client            137 daemons/execd/remoted_tls.c         request = pcmk__remote_message_xml(client->remote);
client            151 daemons/execd/remoted_tls.c     pcmk__client_t *client = user_data;
client            153 daemons/execd/remoted_tls.c     if (client == NULL) {
client            158 daemons/execd/remoted_tls.c                pcmk__client_name(client));
client            160 daemons/execd/remoted_tls.c     ipc_proxy_remove_provider(client);
client            168 daemons/execd/remoted_tls.c     if (client->remote->tls_session) {
client            172 daemons/execd/remoted_tls.c         sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session);
client            175 daemons/execd/remoted_tls.c         gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_RDWR);
client            176 daemons/execd/remoted_tls.c         gnutls_deinit(*client->remote->tls_session);
client            177 daemons/execd/remoted_tls.c         gnutls_free(client->remote->tls_session);
client            181 daemons/execd/remoted_tls.c     lrmd_client_destroy(client);
client            188 daemons/execd/remoted_tls.c     pcmk__client_t *client = data;
client            190 daemons/execd/remoted_tls.c     client->remote->auth_timeout = 0;
client            192 daemons/execd/remoted_tls.c     if (pcmk_is_set(client->flags,
client            197 daemons/execd/remoted_tls.c     mainloop_del_fd(client->remote->source);
client            198 daemons/execd/remoted_tls.c     client->remote->source = NULL;
client             72 daemons/fenced/fenced_commands.c                                pcmk__client_t *client);
client             95 daemons/fenced/fenced_commands.c     char *client;
client            322 daemons/fenced/fenced_commands.c     free(cmd->client);
client            361 daemons/fenced/fenced_commands.c     cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID);
client            362 daemons/fenced/fenced_commands.c     if ((cmd->action == NULL) || (cmd->op == NULL) || (cmd->client == NULL)) {
client            670 daemons/fenced/fenced_commands.c                   device->id, cmd->client, cmd->timeout);
client           1173 daemons/fenced/fenced_commands.c     cmd->client = strdup(crm_system_name);
client           2395 daemons/fenced/fenced_commands.c     pcmk__client_t *client = NULL;
client           2398 daemons/fenced/fenced_commands.c         client = pcmk__find_client_by_id(query->client_id);
client           2399 daemons/fenced/fenced_commands.c         if ((client == NULL) && (query->remote_peer == NULL)) {
client           2483 daemons/fenced/fenced_commands.c                        client);
client           2596 daemons/fenced/fenced_commands.c     pcmk__client_t *client = NULL;
client           2602 daemons/fenced/fenced_commands.c     if (cmd->client != NULL) {
client           2603 daemons/fenced/fenced_commands.c         client = pcmk__find_client_by_id(cmd->client);
client           2604 daemons/fenced/fenced_commands.c         if ((client == NULL) && (cmd->origin == NULL)) {
client           2605 daemons/fenced/fenced_commands.c             crm_trace("Skipping reply to %s: no longer a client", cmd->client);
client           2627 daemons/fenced/fenced_commands.c         stonith_send_reply(reply, cmd->options, cmd->origin, client);
client           2643 daemons/fenced/fenced_commands.c         crm_xml_add(notify_data, F_STONITH_ORIGIN, cmd->client);
client           2702 daemons/fenced/fenced_commands.c         if (pcmk__str_eq(cmd->client, cmd_other->client, pcmk__str_casei) ||
client           2991 daemons/fenced/fenced_commands.c     crm_xml_add(reply, F_STONITH_CLIENTID, cmd->client);
client           3066 daemons/fenced/fenced_commands.c                    pcmk__client_t *client)
client           3068 daemons/fenced/fenced_commands.c     CRM_CHECK((reply != NULL) && ((remote_peer != NULL) || (client != NULL)),
client           3072 daemons/fenced/fenced_commands.c         do_local_reply(reply, client, call_options);
client           3594 daemons/fenced/fenced_commands.c handle_reply(pcmk__client_t *client, xmlNode *request, const char *remote_peer)
client           3605 daemons/fenced/fenced_commands.c                 pcmk__s(op, "untyped"), ((client == NULL)? "peer" : "client"),
client           3606 daemons/fenced/fenced_commands.c                 ((client == NULL)? remote_peer : pcmk__client_name(client)));
client           3612 daemons/fenced/fenced_commands.c               op, ((client == NULL)? "peer" : "client"),
client           3613 daemons/fenced/fenced_commands.c               ((client == NULL)? remote_peer : pcmk__client_name(client)));
client           3628 daemons/fenced/fenced_commands.c stonith_command(pcmk__client_t *client, uint32_t id, uint32_t flags,
client           3644 daemons/fenced/fenced_commands.c               ((client == NULL)? "peer" : "client"),
client           3645 daemons/fenced/fenced_commands.c               ((client == NULL)? remote_peer : pcmk__client_name(client)));
client           3648 daemons/fenced/fenced_commands.c         CRM_ASSERT(client == NULL || client->request_id == id);
client           3652 daemons/fenced/fenced_commands.c         handle_reply(client, message, remote_peer);
client           3655 daemons/fenced/fenced_commands.c             .ipc_client     = client,
client            442 daemons/fenced/fenced_remote.c     pcmk__client_t *client = NULL;
client            458 daemons/fenced/fenced_remote.c     client = pcmk__find_client_by_id(op->client_id);
client            459 daemons/fenced/fenced_remote.c     if (client == NULL) {
client            462 daemons/fenced/fenced_remote.c         do_local_reply(reply, client, op->call_options);
client           1097 daemons/fenced/fenced_remote.c fenced_handle_manual_confirmation(const pcmk__client_t *client, xmlNode *msg)
client           1107 daemons/fenced/fenced_remote.c     op = initiate_remote_stonith_op(client, msg, TRUE);
client           1137 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode *request, gboolean peer)
client           1156 daemons/fenced/fenced_remote.c                       op_id, ((client == NULL)? "unknown client" : client));
client           1188 daemons/fenced/fenced_remote.c     CRM_LOG_ASSERT(client != NULL);
client           1189 daemons/fenced/fenced_remote.c     if (client) {
client           1190 daemons/fenced/fenced_remote.c         op->client_id = strdup(client);
client           1262 daemons/fenced/fenced_remote.c initiate_remote_stonith_op(const pcmk__client_t *client, xmlNode *request,
client           1272 daemons/fenced/fenced_remote.c     if (client) {
client           1273 daemons/fenced/fenced_remote.c         client_id = client->id;
client            170 daemons/fenced/pacemaker-fenced.c     pcmk__client_t *client = pcmk__find_client(c);
client            172 daemons/fenced/pacemaker-fenced.c     if (client == NULL) {
client            177 daemons/fenced/pacemaker-fenced.c     pcmk__free_client(client);
client            244 daemons/fenced/pacemaker-fenced.c do_local_reply(xmlNode *notify_src, pcmk__client_t *client, int call_options)
client            252 daemons/fenced/pacemaker-fenced.c         CRM_LOG_ASSERT(client->request_id);
client            253 daemons/fenced/pacemaker-fenced.c         rid = client->request_id;
client            254 daemons/fenced/pacemaker-fenced.c         client->request_id = 0;
client            258 daemons/fenced/pacemaker-fenced.c     local_rc = pcmk__ipc_send_xml(client, rid, notify_src, ipc_flags);
client            261 daemons/fenced/pacemaker-fenced.c                   rid, pcmk__client_name(client));
client            265 daemons/fenced/pacemaker-fenced.c                  pcmk__client_name(client), pcmk_rc_str(local_rc));
client            296 daemons/fenced/pacemaker-fenced.c     pcmk__client_t *client = value;
client            299 daemons/fenced/pacemaker-fenced.c     CRM_CHECK(client != NULL, return);
client            305 daemons/fenced/pacemaker-fenced.c     if (client->ipcs == NULL) {
client            310 daemons/fenced/pacemaker-fenced.c     if (pcmk_is_set(client->flags, get_stonith_flag(type))) {
client            311 daemons/fenced/pacemaker-fenced.c         int rc = pcmk__ipc_send_xml(client, 0, update_msg,
client            316 daemons/fenced/pacemaker-fenced.c                      CRM_XS " id=%.8s rc=%d", type, pcmk__client_name(client),
client            317 daemons/fenced/pacemaker-fenced.c                      pcmk_rc_str(rc), client->id, rc);
client            320 daemons/fenced/pacemaker-fenced.c                       type, pcmk__client_name(client));
client            328 daemons/fenced/pacemaker-fenced.c     pcmk__client_t *client = NULL;
client            335 daemons/fenced/pacemaker-fenced.c     client = pcmk__find_client_by_id(client_id);
client            336 daemons/fenced/pacemaker-fenced.c     if (!client) {
client            347 daemons/fenced/pacemaker-fenced.c     if (client) {
client            348 daemons/fenced/pacemaker-fenced.c         pcmk__ipc_send_xml(client, 0, notify_data, crm_ipc_server_event);
client            219 daemons/fenced/pacemaker-fenced.h void stonith_command(pcmk__client_t *client, uint32_t id, uint32_t flags,
client            234 daemons/fenced/pacemaker-fenced.h void do_local_reply(xmlNode *notify_src, pcmk__client_t *client,
client            241 daemons/fenced/pacemaker-fenced.h  do_stonith_async_timeout_update(const char *client, const char *call_id, int timeout);
client            253 daemons/fenced/pacemaker-fenced.h remote_fencing_op_t *initiate_remote_stonith_op(const pcmk__client_t *client,
client            261 daemons/fenced/pacemaker-fenced.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer);
client            272 daemons/fenced/pacemaker-fenced.h int fenced_handle_manual_confirmation(const pcmk__client_t *client,
client            180 daemons/pacemakerd/pcmkd_messages.c     pcmk__client_t *client = pcmk__find_client(c);
client            182 daemons/pacemakerd/pcmkd_messages.c     if (client == NULL) {
client            186 daemons/pacemakerd/pcmkd_messages.c     if (shutdown_complete_state_reported_to == client->pid) {
client            192 daemons/pacemakerd/pcmkd_messages.c     pcmk__free_client(client);
client            312 daemons/schedulerd/schedulerd_messages.c     pcmk__client_t *client = pcmk__find_client(c);
client            314 daemons/schedulerd/schedulerd_messages.c     if (client == NULL) {
client            318 daemons/schedulerd/schedulerd_messages.c     pcmk__free_client(client);
client            168 include/crm/common/ipc.h bool crm_ipc_connect(crm_ipc_t * client);
client            169 include/crm/common/ipc.h void crm_ipc_close(crm_ipc_t * client);
client            170 include/crm/common/ipc.h void crm_ipc_destroy(crm_ipc_t * client);
client            173 include/crm/common/ipc.h int crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags,
client            176 include/crm/common/ipc.h int crm_ipc_get_fd(crm_ipc_t * client);
client            177 include/crm/common/ipc.h bool crm_ipc_connected(crm_ipc_t * client);
client            178 include/crm/common/ipc.h int crm_ipc_ready(crm_ipc_t * client);
client            179 include/crm/common/ipc.h long crm_ipc_read(crm_ipc_t * client);
client            180 include/crm/common/ipc.h const char *crm_ipc_buffer(crm_ipc_t * client);
client            181 include/crm/common/ipc.h uint32_t crm_ipc_buffer_flags(crm_ipc_t * client);
client            182 include/crm/common/ipc.h const char *crm_ipc_name(crm_ipc_t * client);
client            165 include/crm/common/ipc_internal.h #define PCMK__CLIENT_TYPE(client) ((client)->flags & UINT64_C(0xff00000000))
client            193 include/crm/common/ipc_internal.h #define pcmk__set_client_flags(client, flags_to_set) do {               \
client            194 include/crm/common/ipc_internal.h         (client)->flags = pcmk__set_flags_as(__func__, __LINE__,        \
client            196 include/crm/common/ipc_internal.h             "Client", pcmk__client_name(client),                        \
client            197 include/crm/common/ipc_internal.h             (client)->flags, (flags_to_set), #flags_to_set);            \
client            200 include/crm/common/ipc_internal.h #define pcmk__clear_client_flags(client, flags_to_clear) do {           \
client            201 include/crm/common/ipc_internal.h         (client)->flags = pcmk__clear_flags_as(__func__, __LINE__,      \
client            203 include/crm/common/ipc_internal.h             "Client", pcmk__client_name(client),                        \
client            204 include/crm/common/ipc_internal.h             (client)->flags, (flags_to_clear), #flags_to_clear);        \
client            235 include/crm/common/ipc_internal.h bool pcmk__set_client_queue_max(pcmk__client_t *client, const char *qmax);
client            126 include/crm/common/mainloop.h void mainloop_del_ipc_client(mainloop_io_t * client);
client            128 include/crm/common/mainloop.h crm_ipc_t *mainloop_get_ipc_client(mainloop_io_t * client);
client            151 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(const pcmk__client_t *client);
client            109 include/crm/stonith-ng.h     char *client;
client            121 lib/cib/cib_client.c         cib_notify_client_t *client = (cib_notify_client_t *) iter->data;
client            123 lib/cib/cib_client.c         if (strcmp(client->event, event) == 0) {
client            672 lib/cib/cib_client.c             cib_notify_client_t *client = g_list_nth_data(list, 0);
client            674 lib/cib/cib_client.c             list = g_list_remove(list, client);
client            675 lib/cib/cib_client.c             free(client);
client            725 lib/common/ipc_client.c     const char *client = crm_system_name? crm_system_name : "client";
client            740 lib/common/ipc_client.c                                      pcmk_ipc_name(api, false), client, NULL);
client            822 lib/common/ipc_client.c     crm_ipc_t *client = NULL;
client            824 lib/common/ipc_client.c     client = calloc(1, sizeof(crm_ipc_t));
client            825 lib/common/ipc_client.c     if (client == NULL) {
client            830 lib/common/ipc_client.c     client->server_name = strdup(name);
client            831 lib/common/ipc_client.c     if (client->server_name == NULL) {
client            834 lib/common/ipc_client.c         free(client);
client            837 lib/common/ipc_client.c     client->buf_size = pcmk__ipc_buffer_size(max_size);
client            838 lib/common/ipc_client.c     client->buffer = malloc(client->buf_size);
client            839 lib/common/ipc_client.c     if (client->buffer == NULL) {
client            842 lib/common/ipc_client.c         free(client->server_name);
client            843 lib/common/ipc_client.c         free(client);
client            848 lib/common/ipc_client.c     client->max_buf_size = client->buf_size;
client            850 lib/common/ipc_client.c     client->pfd.fd = -1;
client            851 lib/common/ipc_client.c     client->pfd.events = POLLIN;
client            852 lib/common/ipc_client.c     client->pfd.revents = 0;
client            854 lib/common/ipc_client.c     return client;
client            867 lib/common/ipc_client.c crm_ipc_connect(crm_ipc_t *client)
client            874 lib/common/ipc_client.c     if (client == NULL) {
client            879 lib/common/ipc_client.c     client->need_reply = FALSE;
client            880 lib/common/ipc_client.c     client->ipc = qb_ipcc_connect(client->server_name, client->buf_size);
client            882 lib/common/ipc_client.c     if (client->ipc == NULL) {
client            884 lib/common/ipc_client.c                   client->server_name, pcmk_rc_str(errno), errno);
client            888 lib/common/ipc_client.c     client->pfd.fd = crm_ipc_get_fd(client);
client            889 lib/common/ipc_client.c     if (client->pfd.fd < 0) {
client            892 lib/common/ipc_client.c         crm_ipc_close(client);
client            900 lib/common/ipc_client.c         crm_ipc_close(client);
client            905 lib/common/ipc_client.c     if ((rv = pcmk__crm_ipc_is_authentic_process(client->ipc, client->pfd.fd, cl_uid, cl_gid,
client            910 lib/common/ipc_client.c                 client->server_name,
client            914 lib/common/ipc_client.c         crm_ipc_close(client);
client            920 lib/common/ipc_client.c                    client->server_name);
client            921 lib/common/ipc_client.c         crm_ipc_close(client);
client            930 lib/common/ipc_client.c     qb_ipcc_context_set(client->ipc, client);
client            932 lib/common/ipc_client.c     client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc);
client            933 lib/common/ipc_client.c     if (client->max_buf_size > client->buf_size) {
client            934 lib/common/ipc_client.c         free(client->buffer);
client            935 lib/common/ipc_client.c         client->buffer = calloc(1, client->max_buf_size);
client            936 lib/common/ipc_client.c         client->buf_size = client->max_buf_size;
client            942 lib/common/ipc_client.c crm_ipc_close(crm_ipc_t * client)
client            944 lib/common/ipc_client.c     if (client) {
client            945 lib/common/ipc_client.c         if (client->ipc) {
client            946 lib/common/ipc_client.c             qb_ipcc_connection_t *ipc = client->ipc;
client            948 lib/common/ipc_client.c             client->ipc = NULL;
client            955 lib/common/ipc_client.c crm_ipc_destroy(crm_ipc_t * client)
client            957 lib/common/ipc_client.c     if (client) {
client            958 lib/common/ipc_client.c         if (client->ipc && qb_ipcc_is_connected(client->ipc)) {
client            960 lib/common/ipc_client.c                        client->server_name);
client            972 lib/common/ipc_client.c                       client->server_name);
client            974 lib/common/ipc_client.c         free(client->buffer);
client            975 lib/common/ipc_client.c         free(client->server_name);
client            976 lib/common/ipc_client.c         free(client);
client            981 lib/common/ipc_client.c crm_ipc_get_fd(crm_ipc_t * client)
client            985 lib/common/ipc_client.c     if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) {
client            990 lib/common/ipc_client.c                (client? client->server_name : "unspecified"));
client            995 lib/common/ipc_client.c crm_ipc_connected(crm_ipc_t * client)
client            999 lib/common/ipc_client.c     if (client == NULL) {
client           1003 lib/common/ipc_client.c     } else if (client->ipc == NULL) {
client           1007 lib/common/ipc_client.c     } else if (client->pfd.fd < 0) {
client           1012 lib/common/ipc_client.c     rc = qb_ipcc_is_connected(client->ipc);
client           1014 lib/common/ipc_client.c         client->pfd.fd = -EINVAL;
client           1027 lib/common/ipc_client.c crm_ipc_ready(crm_ipc_t *client)
client           1031 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1033 lib/common/ipc_client.c     if (!crm_ipc_connected(client)) {
client           1037 lib/common/ipc_client.c     client->pfd.revents = 0;
client           1038 lib/common/ipc_client.c     rc = poll(&(client->pfd), 1, 0);
client           1044 lib/common/ipc_client.c crm_ipc_decompress(crm_ipc_t * client)
client           1046 lib/common/ipc_client.c     pcmk__ipc_header_t *header = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1052 lib/common/ipc_client.c         unsigned int new_buf_size = QB_MAX((sizeof(pcmk__ipc_header_t) + size_u), client->max_buf_size);
client           1059 lib/common/ipc_client.c                                         client->buffer + sizeof(pcmk__ipc_header_t), header->size_compressed, 1, 0);
client           1078 lib/common/ipc_client.c         memcpy(uncompressed, client->buffer, sizeof(pcmk__ipc_header_t));       /* Preserve the header */
client           1081 lib/common/ipc_client.c         free(client->buffer);
client           1082 lib/common/ipc_client.c         client->buf_size = new_buf_size;
client           1083 lib/common/ipc_client.c         client->buffer = uncompressed;
client           1086 lib/common/ipc_client.c     CRM_ASSERT(client->buffer[sizeof(pcmk__ipc_header_t) + header->size_uncompressed - 1] == 0);
client           1091 lib/common/ipc_client.c crm_ipc_read(crm_ipc_t * client)
client           1095 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1096 lib/common/ipc_client.c     CRM_ASSERT(client->ipc != NULL);
client           1097 lib/common/ipc_client.c     CRM_ASSERT(client->buffer != NULL);
client           1099 lib/common/ipc_client.c     client->buffer[0] = 0;
client           1100 lib/common/ipc_client.c     client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer,
client           1101 lib/common/ipc_client.c                                           client->buf_size, 0);
client           1102 lib/common/ipc_client.c     if (client->msg_size >= 0) {
client           1103 lib/common/ipc_client.c         int rc = crm_ipc_decompress(client);
client           1109 lib/common/ipc_client.c         header = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1115 lib/common/ipc_client.c                   client->server_name, header->qb.id, header->qb.size,
client           1116 lib/common/ipc_client.c                   client->msg_size,
client           1117 lib/common/ipc_client.c                   client->buffer + sizeof(pcmk__ipc_header_t));
client           1121 lib/common/ipc_client.c                   client->server_name, pcmk_strerror(client->msg_size));
client           1123 lib/common/ipc_client.c         if (client->msg_size == -EAGAIN) {
client           1128 lib/common/ipc_client.c     if (!crm_ipc_connected(client) || client->msg_size == -ENOTCONN) {
client           1129 lib/common/ipc_client.c         crm_err("Connection to %s IPC failed", client->server_name);
client           1140 lib/common/ipc_client.c crm_ipc_buffer(crm_ipc_t * client)
client           1142 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1143 lib/common/ipc_client.c     return client->buffer + sizeof(pcmk__ipc_header_t);
client           1147 lib/common/ipc_client.c crm_ipc_buffer_flags(crm_ipc_t * client)
client           1151 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1152 lib/common/ipc_client.c     if (client->buffer == NULL) {
client           1156 lib/common/ipc_client.c     header = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1161 lib/common/ipc_client.c crm_ipc_name(crm_ipc_t * client)
client           1163 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1164 lib/common/ipc_client.c     return client->server_name;
client           1169 lib/common/ipc_client.c internal_ipc_get_reply(crm_ipc_t *client, int request_id, int ms_timeout,
client           1177 lib/common/ipc_client.c               client->server_name, request_id);
client           1180 lib/common/ipc_client.c         *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000);
client           1184 lib/common/ipc_client.c             rc = crm_ipc_decompress(client);
client           1189 lib/common/ipc_client.c             hdr = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1194 lib/common/ipc_client.c                 xmlNode *bad = string2xml(crm_ipc_buffer(client));
client           1200 lib/common/ipc_client.c                 xmlNode *bad = string2xml(crm_ipc_buffer(client));
client           1206 lib/common/ipc_client.c         } else if (!crm_ipc_connected(client)) {
client           1208 lib/common/ipc_client.c                     client->server_name, request_id);
client           1234 lib/common/ipc_client.c crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags, int32_t ms_timeout,
client           1245 lib/common/ipc_client.c     if (client == NULL) {
client           1250 lib/common/ipc_client.c     } else if (!crm_ipc_connected(client)) {
client           1253 lib/common/ipc_client.c                    client->server_name);
client           1261 lib/common/ipc_client.c     if (client->need_reply) {
client           1262 lib/common/ipc_client.c         qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout);
client           1265 lib/common/ipc_client.c                      client->server_name);
client           1270 lib/common/ipc_client.c                        client->server_name);
client           1271 lib/common/ipc_client.c             client->need_reply = FALSE;
client           1277 lib/common/ipc_client.c     rc = pcmk__ipc_prepare_iov(id, message, client->max_buf_size, &iov, &bytes);
client           1280 lib/common/ipc_client.c                  client->server_name, pcmk_rc_str(rc), rc);
client           1285 lib/common/ipc_client.c     pcmk__set_ipc_flags(header->flags, client->server_name, flags);
client           1293 lib/common/ipc_client.c         if(factor < 10 && (client->max_buf_size / 10) < (bytes / factor)) {
client           1297 lib/common/ipc_client.c                        factor, client->max_buf_size, 2 * client->max_buf_size);
client           1303 lib/common/ipc_client.c               client->server_name, header->qb.id, header->qb.size, ms_timeout);
client           1313 lib/common/ipc_client.c             if (!crm_ipc_connected(client)) {
client           1317 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv(client->ipc, iov, 2);
client           1326 lib/common/ipc_client.c                       client->server_name, header->qb.id);
client           1330 lib/common/ipc_client.c         rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes);
client           1338 lib/common/ipc_client.c             client->need_reply = TRUE;
client           1345 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer,
client           1346 lib/common/ipc_client.c                                        client->buf_size, -1);
client           1347 lib/common/ipc_client.c         } while ((qb_rc == -EAGAIN) && crm_ipc_connected(client));
client           1352 lib/common/ipc_client.c         pcmk__ipc_header_t *hdr = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1355 lib/common/ipc_client.c                   rc, hdr->qb.id, client->server_name, header->qb.id,
client           1356 lib/common/ipc_client.c                   crm_ipc_buffer(client));
client           1359 lib/common/ipc_client.c             *reply = string2xml(crm_ipc_buffer(client));
client           1364 lib/common/ipc_client.c                   client->server_name, header->qb.id, rc);
client           1368 lib/common/ipc_client.c     if (!crm_ipc_connected(client)) {
client           1370 lib/common/ipc_client.c                    CRM_XS " rc=%d", client->server_name, header->qb.id, rc);
client           1374 lib/common/ipc_client.c                  client->server_name, header->qb.id, pcmk_strerror(rc),
client           1380 lib/common/ipc_client.c                  client->server_name, header->qb.id,
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 = calloc(1, sizeof(pcmk__client_t));
client            168 lib/common/ipc_server.c     if (client == NULL) {
client            174 lib/common/ipc_server.c         client->user = pcmk__uid2username(uid_client);
client            175 lib/common/ipc_server.c         if (client->user == NULL) {
client            176 lib/common/ipc_server.c             client->user = strdup("#unprivileged");
client            177 lib/common/ipc_server.c             CRM_CHECK(client->user != NULL, free(client); return NULL);
client            181 lib/common/ipc_server.c         client->ipcs = c;
client            182 lib/common/ipc_server.c         pcmk__set_client_flags(client, pcmk__client_ipc);
client            183 lib/common/ipc_server.c         client->pid = pcmk__client_pid(c);
client            189 lib/common/ipc_server.c     client->id = crm_generate_uuid();
client            191 lib/common/ipc_server.c         key = client->id;
client            197 lib/common/ipc_server.c     g_hash_table_insert(client_connections, key, client);
client            198 lib/common/ipc_server.c     return client;
client            211 lib/common/ipc_server.c     pcmk__client_t *client = client_from_connection(NULL, key, 0);
client            213 lib/common/ipc_server.c     CRM_ASSERT(client != NULL);
client            214 lib/common/ipc_server.c     return client;
client            223 lib/common/ipc_server.c     pcmk__client_t *client = NULL;
client            244 lib/common/ipc_server.c     client = client_from_connection(c, NULL, uid_client);
client            245 lib/common/ipc_server.c     if (client == NULL) {
client            251 lib/common/ipc_server.c         pcmk__set_client_flags(client, pcmk__client_privileged);
client            255 lib/common/ipc_server.c               client->id, client->pid, uid_client, gid_client);
client            256 lib/common/ipc_server.c     return client;
client            350 lib/common/ipc_server.c pcmk__set_client_queue_max(pcmk__client_t *client, const char *qmax)
client            352 lib/common/ipc_server.c     if (pcmk_is_set(client->flags, pcmk__client_privileged)) {
client            357 lib/common/ipc_server.c             client->queue_max = (unsigned int) qmax_ll;
client            729 lib/common/mainloop.c     mainloop_io_t *client = data;
client            731 lib/common/mainloop.c     CRM_ASSERT(client->fd == g_io_channel_unix_get_fd(gio));
client            734 lib/common/mainloop.c         if (client->ipc) {
client            739 lib/common/mainloop.c                 read_rc = crm_ipc_read(client->ipc);
client            742 lib/common/mainloop.c                               client->name, pcmk_strerror(read_rc), read_rc);
client            744 lib/common/mainloop.c                 } else if (client->dispatch_fn_ipc) {
client            745 lib/common/mainloop.c                     const char *buffer = crm_ipc_buffer(client->ipc);
client            749 lib/common/mainloop.c                               read_rc, client->name, (int) condition);
client            750 lib/common/mainloop.c                     if (client->dispatch_fn_ipc(buffer, read_rc, client->userdata) < 0) {
client            751 lib/common/mainloop.c                         crm_trace("Connection to %s no longer required", client->name);
client            760 lib/common/mainloop.c                       client->name, (int) condition);
client            761 lib/common/mainloop.c             if (client->dispatch_fn_io) {
client            762 lib/common/mainloop.c                 if (client->dispatch_fn_io(client->userdata) < 0) {
client            763 lib/common/mainloop.c                     crm_trace("Connection to %s no longer required", client->name);
client            770 lib/common/mainloop.c     if (client->ipc && !crm_ipc_connected(client->ipc)) {
client            772 lib/common/mainloop.c                 client->name, client, condition);
client            777 lib/common/mainloop.c                   client->name, client, condition);
client            820 lib/common/mainloop.c     mainloop_io_t *client = c;
client            821 lib/common/mainloop.c     char *c_name = strdup(client->name);
client            828 lib/common/mainloop.c     if (client->ipc) {
client            829 lib/common/mainloop.c         crm_ipc_close(client->ipc);
client            832 lib/common/mainloop.c     if (client->destroy_fn) {
client            833 lib/common/mainloop.c         void (*destroy_fn) (gpointer userdata) = client->destroy_fn;
client            835 lib/common/mainloop.c         client->destroy_fn = NULL;
client            836 lib/common/mainloop.c         destroy_fn(client->userdata);
client            839 lib/common/mainloop.c     if (client->ipc) {
client            840 lib/common/mainloop.c         crm_ipc_t *ipc = client->ipc;
client            842 lib/common/mainloop.c         client->ipc = NULL;
client            848 lib/common/mainloop.c     free(client->name); client->name = NULL;
client            849 lib/common/mainloop.c     free(client);
client            940 lib/common/mainloop.c mainloop_del_ipc_client(mainloop_io_t * client)
client            942 lib/common/mainloop.c     mainloop_del_fd(client);
client            946 lib/common/mainloop.c mainloop_get_ipc_client(mainloop_io_t * client)
client            948 lib/common/mainloop.c     if (client) {
client            949 lib/common/mainloop.c         return client->ipc;
client            958 lib/common/mainloop.c     mainloop_io_t *client = NULL;
client            961 lib/common/mainloop.c         client = calloc(1, sizeof(mainloop_io_t));
client            962 lib/common/mainloop.c         if (client == NULL) {
client            965 lib/common/mainloop.c         client->name = strdup(name);
client            966 lib/common/mainloop.c         client->userdata = userdata;
client            969 lib/common/mainloop.c             client->destroy_fn = callbacks->destroy;
client            970 lib/common/mainloop.c             client->dispatch_fn_io = callbacks->dispatch;
client            973 lib/common/mainloop.c         client->fd = fd;
client            974 lib/common/mainloop.c         client->channel = g_io_channel_unix_new(fd);
client            975 lib/common/mainloop.c         client->source =
client            976 lib/common/mainloop.c             g_io_add_watch_full(client->channel, priority,
client            978 lib/common/mainloop.c                                 client, mainloop_gio_destroy);
client            989 lib/common/mainloop.c         g_io_channel_unref(client->channel);
client            990 lib/common/mainloop.c         crm_trace("Added connection %d for %s[%p].%d", client->source, client->name, client, fd);
client            995 lib/common/mainloop.c     return client;
client            999 lib/common/mainloop.c mainloop_del_fd(mainloop_io_t * client)
client           1001 lib/common/mainloop.c     if (client != NULL) {
client           1002 lib/common/mainloop.c         crm_trace("Removing client %s[%p]", client->name, client);
client           1003 lib/common/mainloop.c         if (client->source) {
client           1007 lib/common/mainloop.c             g_source_remove(client->source);
client            345 lib/common/remote.c pcmk__read_handshake_data(const pcmk__client_t *client)
client            349 lib/common/remote.c     CRM_ASSERT(client && client->remote && client->remote->tls_session);
client            352 lib/common/remote.c         rc = gnutls_handshake(*client->remote->tls_session);
client            732 lib/fencing/st_client.c             kvp->client = crm_element_value_copy(op, F_STONITH_CLIENTNAME);
client            764 lib/fencing/st_client.c         free(hp->client);
client            113 lib/fencing/st_output.c         pcmk__g_strcat(str, " for ", history->client, "@", history->origin,
client            140 lib/fencing/st_output.c                        "client=", history->client, ", origin=", history->origin,
client            462 lib/fencing/st_output.c                                                    "client", event->client,
client            200 lib/pengine/pe_output.c                     const char *client, const char *origin) {
client            201 lib/pengine/pe_output.c     if (last_written != NULL || user != NULL || client != NULL || origin != NULL) {
client            206 lib/pengine/pe_output.c                                  client ? " via " : "",
client            207 lib/pengine/pe_output.c                                  client ? client : "",
client            408 lib/pengine/pe_output.c         const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT);
client            413 lib/pengine/pe_output.c                      data_set->localhost, last_written, user, client, origin);
client            477 lib/pengine/pe_output.c         const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT);
client            482 lib/pengine/pe_output.c                      data_set->localhost, last_written, user, client, origin);
client           1171 lib/pengine/pe_output.c     const char *client = va_arg(args, const char *);
client           1188 lib/pengine/pe_output.c     time_s = last_changed_string(last_written, user, client, origin);
client           1204 lib/pengine/pe_output.c     const char *client = va_arg(args, const char *);
client           1217 lib/pengine/pe_output.c                                  "client", client ? client : "",
client           1232 lib/pengine/pe_output.c     const char *client = va_arg(args, const char *);
client           1242 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);