client            228 daemons/attrd/attrd_commands.c attrd_client_peer_remove(pcmk__client_t *client, xmlNode *xml)
client            256 daemons/attrd/attrd_commands.c                  pcmk__client_name(client), host);
client            261 daemons/attrd/attrd_commands.c                  pcmk__client_name(client));
client            502 daemons/attrd/attrd_commands.c attrd_client_query(pcmk__client_t *client, uint32_t id, uint32_t flags,
client            533 daemons/attrd/attrd_commands.c     client->request_id = 0;
client            535 daemons/attrd/attrd_commands.c         int rc = pcmk__ipc_send_xml(client, id, reply, flags);
client            163 daemons/attrd/attrd_utils.c     pcmk__client_t *client = pcmk__find_client(c);
client            165 daemons/attrd/attrd_utils.c     if (client == NULL) {
client            169 daemons/attrd/attrd_utils.c         pcmk__free_client(client);
client            225 daemons/attrd/pacemaker-attrd.c     pcmk__client_t *client = pcmk__find_client(c);
client            230 daemons/attrd/pacemaker-attrd.c     CRM_CHECK((c != NULL) && (client != NULL), return 0);
client            235 daemons/attrd/pacemaker-attrd.c     xml = pcmk__client_data2xml(client, data, &id, &flags);
client            241 daemons/attrd/pacemaker-attrd.c     CRM_ASSERT(client->user != NULL);
client            242 daemons/attrd/pacemaker-attrd.c     pcmk__update_acl_user(xml, PCMK__XA_ATTR_USER, client->user);
client            246 daemons/attrd/pacemaker-attrd.c     if (client->name == NULL) {
client            248 daemons/attrd/pacemaker-attrd.c         client->name = crm_strdup_printf("%s.%d", value?value:"unknown", client->pid);
client            252 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            253 daemons/attrd/pacemaker-attrd.c         attrd_client_peer_remove(client, xml);
client            256 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            260 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            264 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            268 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            272 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            277 daemons/attrd/pacemaker-attrd.c         attrd_client_query(client, id, flags, xml);
client            281 daemons/attrd/pacemaker-attrd.c                  pcmk__client_name(client), op);
client            118 daemons/attrd/pacemaker-attrd.h #define attrd_send_ack(client, id, flags) \
client            119 daemons/attrd/pacemaker-attrd.h     pcmk__ipc_send_ack((client), (id), (flags), "ack", CRM_EX_INDETERMINATE)
client            125 daemons/attrd/pacemaker-attrd.h void attrd_peer_message(crm_node_t *client, xmlNode *msg);
client            126 daemons/attrd/pacemaker-attrd.h void attrd_client_peer_remove(pcmk__client_t *client, xmlNode *xml);
client            130 daemons/attrd/pacemaker-attrd.h void attrd_client_query(pcmk__client_t *client, uint32_t id, uint32_t flags,
client             87 daemons/based/based_callbacks.c     pcmk__client_t *client = pcmk__find_client(c);
client             89 daemons/based/based_callbacks.c     crm_trace("%p message from %s", c, client->id);
client             96 daemons/based/based_callbacks.c     pcmk__client_t *client = pcmk__find_client(c);
client             98 daemons/based/based_callbacks.c     crm_trace("%p message from %s", c, client->id);
client            106 daemons/based/based_callbacks.c     pcmk__client_t *client = pcmk__find_client(c);
client            108 daemons/based/based_callbacks.c     if (client == NULL) {
client            112 daemons/based/based_callbacks.c     pcmk__free_client(client);
client           1382 daemons/based/based_callbacks.c         const char *client = crm_element_value(request, F_CIB_CLIENTNAME);
client           1386 daemons/based/based_callbacks.c         cib_diff_notify(call_options, client, call_id, op, input, rc, *cib_diff);
client             53 daemons/based/based_notify.c     pcmk__client_t *client = value;
client             56 daemons/based/based_notify.c     if (client->ipcs == NULL && client->remote == NULL) {
client             64 daemons/based/based_notify.c     if (pcmk_is_set(client->flags, cib_notify_diff)
client             69 daemons/based/based_notify.c     } else if (pcmk_is_set(client->flags, cib_notify_replace)
client             73 daemons/based/based_notify.c     } else if (pcmk_is_set(client->flags, cib_notify_confirm)
client             77 daemons/based/based_notify.c     } else if (pcmk_is_set(client->flags, cib_notify_pre)
client             81 daemons/based/based_notify.c     } else if (pcmk_is_set(client->flags, cib_notify_post)
client             88 daemons/based/based_notify.c         switch (PCMK__CLIENT_TYPE(client)) {
client             90 daemons/based/based_notify.c                 rc = pcmk__ipc_send_iov(client, update->iov,
client             94 daemons/based/based_notify.c                              pcmk__client_name(client), pcmk_rc_str(rc),
client             95 daemons/based/based_notify.c                              client->id);
client            103 daemons/based/based_notify.c                           type, pcmk__client_name(client), client->id);
client            104 daemons/based/based_notify.c                 pcmk__remote_send_xml(client->remote, update->msg);
client            109 daemons/based/based_notify.c                         pcmk__client_name(client), client->flags);
client            137 daemons/based/based_notify.c cib_diff_notify(int options, const char *client, const char *call_id, const char *op,
client            164 daemons/based/based_notify.c                    client, call_id ? ", call:" : "", call_id ? call_id : "",
client            171 daemons/based/based_notify.c                    client, call_id ? ", call: " : "", call_id ? call_id : "",
client            263 daemons/based/based_remote.c     pcmk__client_t *client = data;
client            265 daemons/based/based_remote.c     client->remote->auth_timeout = 0;
client            267 daemons/based/based_remote.c     if (client->remote->authenticated == TRUE) {
client            271 daemons/based/based_remote.c     mainloop_del_fd(client->remote->source);
client            356 daemons/based/based_remote.c     pcmk__client_t *client = user_data;
client            359 daemons/based/based_remote.c     if (client == NULL) {
client            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 (client->remote->tls_handshake_complete) {
client            380 daemons/based/based_remote.c                     gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_WR);
client            382 daemons/based/based_remote.c                 gnutls_deinit(*client->remote->tls_session);
client            383 daemons/based/based_remote.c                 gnutls_free(client->remote->tls_session);
client            384 daemons/based/based_remote.c                 client->remote->tls_session = NULL;
client            391 daemons/based/based_remote.c                      pcmk__client_name(client), client->flags);
client            398 daemons/based/based_remote.c     pcmk__free_client(client);
client            409 daemons/based/based_remote.c cib_handle_remote_msg(pcmk__client_t *client, xmlNode *command)
client            419 daemons/based/based_remote.c     if (client->name == NULL) {
client            422 daemons/based/based_remote.c             client->name = strdup(client->id);
client            424 daemons/based/based_remote.c             client->name = strdup(value);
client            428 daemons/based/based_remote.c     if (client->userdata == NULL) {
client            431 daemons/based/based_remote.c             client->userdata = strdup(value);
client            432 daemons/based/based_remote.c             crm_trace("Callback channel for %s is %s", client->id, (char*)client->userdata);
client            435 daemons/based/based_remote.c             client->userdata = strdup(client->id);
client            445 daemons/based/based_remote.c     crm_xml_add(command, F_CIB_CLIENTID, client->id);
client            446 daemons/based/based_remote.c     crm_xml_add(command, F_CIB_CLIENTNAME, client->name);
client            447 daemons/based/based_remote.c     crm_xml_add(command, F_CIB_USER, client->user);
client            462 daemons/based/based_remote.c     cib_common_callback_worker(0, 0, command, client, TRUE);
client            469 daemons/based/based_remote.c     pcmk__client_t *client = data;
client            471 daemons/based/based_remote.c     int timeout = client->remote->authenticated ? -1 : 1000;
client            474 daemons/based/based_remote.c               pcmk__client_type_str(PCMK__CLIENT_TYPE(client)),
client            475 daemons/based/based_remote.c               pcmk__client_name(client));
client            478 daemons/based/based_remote.c     if ((PCMK__CLIENT_TYPE(client) == pcmk__client_tls)
client            479 daemons/based/based_remote.c         && !(client->remote->tls_handshake_complete)) {
client            481 daemons/based/based_remote.c         int rc = pcmk__read_handshake_data(client);
client            493 daemons/based/based_remote.c         client->remote->tls_handshake_complete = TRUE;
client            494 daemons/based/based_remote.c         if (client->remote->auth_timeout) {
client            495 daemons/based/based_remote.c             g_source_remove(client->remote->auth_timeout);
client            499 daemons/based/based_remote.c         client->remote->auth_timeout = g_timeout_add(REMOTE_AUTH_TIMEOUT,
client            501 daemons/based/based_remote.c                                                      client);
client            506 daemons/based/based_remote.c     rc = pcmk__read_remote_message(client->remote, timeout);
client            509 daemons/based/based_remote.c     if (client->remote->authenticated == FALSE) {
client            513 daemons/based/based_remote.c         command = pcmk__remote_message_xml(client->remote);
client            520 daemons/based/based_remote.c         client->remote->authenticated = TRUE;
client            521 daemons/based/based_remote.c         g_source_remove(client->remote->auth_timeout);
client            522 daemons/based/based_remote.c         client->remote->auth_timeout = 0;
client            523 daemons/based/based_remote.c         client->name = crm_element_value_copy(command, "name");
client            527 daemons/based/based_remote.c             client->user = strdup(user);
client            533 daemons/based/based_remote.c         crm_xml_add(reg, F_CIB_CLIENTID, client->id);
client            534 daemons/based/based_remote.c         pcmk__remote_send_xml(client->remote, reg);
client            539 daemons/based/based_remote.c     command = pcmk__remote_message_xml(client->remote);
client            542 daemons/based/based_remote.c         cib_handle_remote_msg(client, command);
client            544 daemons/based/based_remote.c         command = pcmk__remote_message_xml(client->remote);
client            146 daemons/based/pacemaker-based.h void cib_diff_notify(int options, const char *client, const char *call_id,
client            383 daemons/controld/controld_control.c     pcmk__client_t *client = pcmk__find_client(c);
client            385 daemons/controld/controld_control.c     xmlNode *msg = pcmk__client_data2xml(client, data, &id, &flags);
client            388 daemons/controld/controld_control.c         pcmk__ipc_send_ack(client, id, flags, "ack", CRM_EX_PROTOCOL);
client            391 daemons/controld/controld_control.c     pcmk__ipc_send_ack(client, id, flags, "ack", CRM_EX_INDETERMINATE);
client            393 daemons/controld/controld_control.c     CRM_ASSERT(client->user != NULL);
client            394 daemons/controld/controld_control.c     pcmk__update_acl_user(msg, F_CRM_USER, client->user);
client            396 daemons/controld/controld_control.c     crm_xml_add(msg, F_CRM_SYS_FROM, client->id);
client            397 daemons/controld/controld_control.c     if (controld_authorize_ipc_message(msg, client, NULL)) {
client            399 daemons/controld/controld_control.c                   pcmk__client_name(client));
client            411 daemons/controld/controld_control.c     pcmk__client_t *client = pcmk__find_client(c);
client            413 daemons/controld/controld_control.c     if (client) {
client            415 daemons/controld/controld_control.c                   (client->userdata? "" : "un"), pcmk__client_name(client),
client            416 daemons/controld/controld_control.c                   c, client);
client            417 daemons/controld/controld_control.c         free(client->userdata);
client            418 daemons/controld/controld_control.c         pcmk__free_client(client);
client            448 daemons/controld/controld_fencing.c     const char *client = "a client";
client            466 daemons/controld/controld_fencing.c         client = event->client_origin;
client            485 daemons/controld/controld_fencing.c                        event->target, executioner, client, event->origin);
client            537 daemons/controld/controld_fencing.c                event->action, executioner, client, event->origin,
client            567 daemons/controld/controld_fencing.c             if (!pcmk__str_eq(client, te_client_id, pcmk__str_casei)) {
client            572 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            296 daemons/execd/execd_commands.c create_lrmd_cmd(xmlNode *msg, pcmk__client_t *client)
client            306 daemons/execd/execd_commands.c     cmd->client_id = strdup(client->id);
client            545 daemons/execd/execd_commands.c     pcmk__client_t *client = value;
client            550 daemons/execd/execd_commands.c     CRM_CHECK(client != NULL, return);
client            551 daemons/execd/execd_commands.c     if (client->name == NULL) {
client            555 daemons/execd/execd_commands.c     if (pcmk_is_set(client->flags, pcmk__client_to_proxy)) {
client            561 daemons/execd/execd_commands.c                   pcmk__client_name(client));
client            565 daemons/execd/execd_commands.c     rc = lrmd_server_send_notify(client, update_msg);
client            582 daemons/execd/execd_commands.c                pcmk__client_name(client), msg, rc);
client            665 daemons/execd/execd_commands.c         pcmk__client_t *client = pcmk__find_client_by_id(cmd->client_id);
client            667 daemons/execd/execd_commands.c         if (client) {
client            668 daemons/execd/execd_commands.c             send_client_notify(client->id, client, notify);
client            763 daemons/execd/execd_commands.c     pcmk__client_t *client = value;
client            766 daemons/execd/execd_commands.c     if (!pcmk__str_eq(client->id, data->new_client->id, pcmk__str_casei)) {
client            767 daemons/execd/execd_commands.c         send_client_notify(key, (gpointer) client, (gpointer) data->notify);
client           1459 daemons/execd/execd_commands.c process_lrmd_signon(pcmk__client_t *client, xmlNode *request, int call_id,
client           1473 daemons/execd/execd_commands.c         if ((client->remote != NULL) && client->remote->tls_handshake_complete) {
client           1475 daemons/execd/execd_commands.c             ipc_proxy_add_provider(client);
client           1486 daemons/execd/execd_commands.c     crm_xml_add(*reply, F_LRMD_CLIENTID, client->id);
client           1493 daemons/execd/execd_commands.c process_lrmd_rsc_register(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1543 daemons/execd/execd_commands.c process_lrmd_rsc_unregister(pcmk__client_t *client, uint32_t id,
client           1575 daemons/execd/execd_commands.c process_lrmd_rsc_exec(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1592 daemons/execd/execd_commands.c     cmd = create_lrmd_cmd(request, client);
client           1700 daemons/execd/execd_commands.c process_lrmd_rsc_cancel(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1780 daemons/execd/execd_commands.c process_lrmd_message(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1793 daemons/execd/execd_commands.c     bool allowed = pcmk_is_set(client->flags, pcmk__client_privileged);
client           1795 daemons/execd/execd_commands.c     crm_trace("Processing %s operation from %s", op, client->id);
client           1801 daemons/execd/execd_commands.c             ipc_proxy_forward_client(client, request);
client           1810 daemons/execd/execd_commands.c         rc = process_lrmd_signon(client, request, call_id, &reply);
client           1814 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_register(client, id, request);
client           1829 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_unregister(client, id, request);
client           1840 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_exec(client, id, request);
client           1847 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_cancel(client, id, request);
client           1866 daemons/execd/execd_commands.c             rc = process_lrmd_alert_exec(client, id, request);
client           1882 daemons/execd/execd_commands.c                 op, pcmk__client_name(client));
client           1887 daemons/execd/execd_commands.c                  op, pcmk__client_name(client));
client           1891 daemons/execd/execd_commands.c               op, client->id, rc, do_reply, do_notify);
client           1899 daemons/execd/execd_commands.c         send_rc = lrmd_server_send_reply(client, id, reply);
client           1903 daemons/execd/execd_commands.c                      pcmk__client_name(client), pcmk_rc_str(send_rc), send_rc);
client            109 daemons/execd/pacemaker-execd.c     pcmk__client_t *client = pcmk__find_client(c);
client            110 daemons/execd/pacemaker-execd.c     xmlNode *request = pcmk__client_data2xml(client, data, &id, &flags);
client            112 daemons/execd/pacemaker-execd.c     CRM_CHECK(client != NULL, crm_err("Invalid client");
client            114 daemons/execd/pacemaker-execd.c     CRM_CHECK(client->id != NULL, crm_err("Invalid client: %p", client);
client            117 daemons/execd/pacemaker-execd.c     CRM_CHECK(flags & crm_ipc_client_response, crm_err("Invalid client request: %p", client);
client            124 daemons/execd/pacemaker-execd.c     if (!client->name) {
client            128 daemons/execd/pacemaker-execd.c             client->name = pcmk__itoa(pcmk__client_pid(c));
client            130 daemons/execd/pacemaker-execd.c             client->name = strdup(value);
client            139 daemons/execd/pacemaker-execd.c     crm_xml_add(request, F_LRMD_CLIENTID, client->id);
client            140 daemons/execd/pacemaker-execd.c     crm_xml_add(request, F_LRMD_CLIENTNAME, client->name);
client            143 daemons/execd/pacemaker-execd.c     process_lrmd_message(client, id, request);
client            156 daemons/execd/pacemaker-execd.c lrmd_client_destroy(pcmk__client_t *client)
client            158 daemons/execd/pacemaker-execd.c     pcmk__free_client(client);
client            173 daemons/execd/pacemaker-execd.c     pcmk__client_t *client = pcmk__find_client(c);
client            175 daemons/execd/pacemaker-execd.c     if (client == NULL) {
client            180 daemons/execd/pacemaker-execd.c     client_disconnect_cleanup(client->id);
client            182 daemons/execd/pacemaker-execd.c     ipc_proxy_remove_provider(client);
client            184 daemons/execd/pacemaker-execd.c     lrmd_client_destroy(client);
client            205 daemons/execd/pacemaker-execd.c lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply)
client            207 daemons/execd/pacemaker-execd.c     crm_trace("Sending reply (%d) to client (%s)", id, client->id);
client            208 daemons/execd/pacemaker-execd.c     switch (PCMK__CLIENT_TYPE(client)) {
client            210 daemons/execd/pacemaker-execd.c             return pcmk__ipc_send_xml(client, id, reply, FALSE);
client            213 daemons/execd/pacemaker-execd.c             return lrmd__remote_send_xml(client->remote, reply, id, "reply");
client            218 daemons/execd/pacemaker-execd.c                     pcmk__client_name(client), client->flags);
client            225 daemons/execd/pacemaker-execd.c lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg)
client            227 daemons/execd/pacemaker-execd.c     crm_trace("Sending notification to client (%s)", client->id);
client            228 daemons/execd/pacemaker-execd.c     switch (PCMK__CLIENT_TYPE(client)) {
client            230 daemons/execd/pacemaker-execd.c             if (client->ipcs == NULL) {
client            234 daemons/execd/pacemaker-execd.c             return pcmk__ipc_send_xml(client, 0, msg, crm_ipc_server_event);
client            237 daemons/execd/pacemaker-execd.c             if (client->remote == NULL) {
client            241 daemons/execd/pacemaker-execd.c                 return lrmd__remote_send_xml(client->remote, msg, 0, "notify");
client            247 daemons/execd/pacemaker-execd.c                     pcmk__client_name(client), client->flags);
client             62 daemons/execd/pacemaker-execd.h int lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply);
client             64 daemons/execd/pacemaker-execd.h int lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg);
client             68 daemons/execd/pacemaker-execd.h void process_lrmd_message(pcmk__client_t *client, uint32_t id,
client             77 daemons/execd/pacemaker-execd.h void lrmd_client_destroy(pcmk__client_t *client);
client             97 daemons/execd/pacemaker-execd.h void ipc_proxy_add_provider(pcmk__client_t *client);
client             98 daemons/execd/pacemaker-execd.h void ipc_proxy_remove_provider(pcmk__client_t *client);
client             99 daemons/execd/pacemaker-execd.h void ipc_proxy_forward_client(pcmk__client_t *client, xmlNode *xml);
client            105 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            308 daemons/execd/remoted_proxy.c     pcmk__client_t *client = pcmk__find_client(c);
client            311 daemons/execd/remoted_proxy.c     if (client == NULL) {
client            315 daemons/execd/remoted_proxy.c     ipc_proxy = pcmk__find_client_by_id(client->userdata);
client            322 daemons/execd/remoted_proxy.c         crm_xml_add(msg, F_LRMD_IPC_SESSION, client->id);
client            327 daemons/execd/remoted_proxy.c     g_hash_table_remove(ipc_clients, client->id);
client            329 daemons/execd/remoted_proxy.c     free(client->userdata);
client            330 daemons/execd/remoted_proxy.c     client->userdata = NULL;
client            331 daemons/execd/remoted_proxy.c     pcmk__free_client(client);
client             52 daemons/execd/remoted_tls.c remoted__read_handshake_data(pcmk__client_t *client)
client             54 daemons/execd/remoted_tls.c     int rc = pcmk__read_handshake_data(client);
client             65 daemons/execd/remoted_tls.c     if (client->remote->auth_timeout) {
client             66 daemons/execd/remoted_tls.c         g_source_remove(client->remote->auth_timeout);
client             68 daemons/execd/remoted_tls.c     client->remote->auth_timeout = 0;
client             70 daemons/execd/remoted_tls.c     client->remote->tls_handshake_complete = TRUE;
client             76 daemons/execd/remoted_tls.c     pcmk__set_client_flags(client, pcmk__client_privileged);
client             79 daemons/execd/remoted_tls.c     notify_of_new_client(client);
client             89 daemons/execd/remoted_tls.c     pcmk__client_t *client = data;
client             91 daemons/execd/remoted_tls.c     if (client->remote->tls_handshake_complete == FALSE) {
client             92 daemons/execd/remoted_tls.c         return remoted__read_handshake_data(client);
client             95 daemons/execd/remoted_tls.c     switch (pcmk__remote_ready(client->remote, 0)) {
client            105 daemons/execd/remoted_tls.c     rc = pcmk__read_remote_message(client->remote, -1);
client            107 daemons/execd/remoted_tls.c     request = pcmk__remote_message_xml(client->remote);
client            111 daemons/execd/remoted_tls.c         if (!client->name) {
client            115 daemons/execd/remoted_tls.c                 client->name = strdup(value);
client            124 daemons/execd/remoted_tls.c         crm_xml_add(request, F_LRMD_CLIENTID, client->id);
client            125 daemons/execd/remoted_tls.c         crm_xml_add(request, F_LRMD_CLIENTNAME, client->name);
client            128 daemons/execd/remoted_tls.c         process_lrmd_message(client, id, request);
client            132 daemons/execd/remoted_tls.c         request = pcmk__remote_message_xml(client->remote);
client            146 daemons/execd/remoted_tls.c     pcmk__client_t *client = user_data;
client            148 daemons/execd/remoted_tls.c     if (client == NULL) {
client            153 daemons/execd/remoted_tls.c                pcmk__client_name(client));
client            155 daemons/execd/remoted_tls.c     ipc_proxy_remove_provider(client);
client            163 daemons/execd/remoted_tls.c     if (client->remote->tls_session) {
client            167 daemons/execd/remoted_tls.c         sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session);
client            170 daemons/execd/remoted_tls.c         gnutls_bye(*client->remote->tls_session, GNUTLS_SHUT_RDWR);
client            171 daemons/execd/remoted_tls.c         gnutls_deinit(*client->remote->tls_session);
client            172 daemons/execd/remoted_tls.c         gnutls_free(client->remote->tls_session);
client            176 daemons/execd/remoted_tls.c     lrmd_client_destroy(client);
client            183 daemons/execd/remoted_tls.c     pcmk__client_t *client = data;
client            185 daemons/execd/remoted_tls.c     client->remote->auth_timeout = 0;
client            187 daemons/execd/remoted_tls.c     if (client->remote->tls_handshake_complete == TRUE) {
client            191 daemons/execd/remoted_tls.c     mainloop_del_fd(client->remote->source);
client            192 daemons/execd/remoted_tls.c     client->remote->source = NULL;
client             70 daemons/fenced/fenced_commands.c                                pcmk__client_t *client);
client             93 daemons/fenced/fenced_commands.c     char *client;
client            256 daemons/fenced/fenced_commands.c     free(cmd->client);
client            283 daemons/fenced/fenced_commands.c     cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID);
client            291 daemons/fenced/fenced_commands.c     CRM_CHECK(cmd->client != NULL, crm_log_xml_warn(msg, "NoClient"));
client            586 daemons/fenced/fenced_commands.c                   device->id, cmd->client, cmd->timeout);
client           1105 daemons/fenced/fenced_commands.c     cmd->client = strdup(crm_system_name);
client           2249 daemons/fenced/fenced_commands.c     pcmk__client_t *client = NULL;
client           2252 daemons/fenced/fenced_commands.c         client = pcmk__find_client_by_id(query->client_id);
client           2253 daemons/fenced/fenced_commands.c         if ((client == NULL) && (query->remote_peer == NULL)) {
client           2336 daemons/fenced/fenced_commands.c                        client);
client           2446 daemons/fenced/fenced_commands.c     pcmk__client_t *client = NULL;
client           2452 daemons/fenced/fenced_commands.c     if (cmd->client != NULL) {
client           2453 daemons/fenced/fenced_commands.c         client = pcmk__find_client_by_id(cmd->client);
client           2454 daemons/fenced/fenced_commands.c         if ((client == NULL) && (cmd->origin == NULL)) {
client           2455 daemons/fenced/fenced_commands.c             crm_trace("Skipping reply to %s: no longer a client", cmd->client);
client           2477 daemons/fenced/fenced_commands.c         stonith_send_reply(reply, cmd->options, cmd->origin, client);
client           2493 daemons/fenced/fenced_commands.c         crm_xml_add(notify_data, F_STONITH_ORIGIN, cmd->client);
client           2601 daemons/fenced/fenced_commands.c         if (pcmk__str_eq(cmd->client, cmd_other->client, pcmk__str_casei) ||
client           2818 daemons/fenced/fenced_commands.c     crm_xml_add(reply, F_STONITH_CLIENTID, cmd->client);
client           2904 daemons/fenced/fenced_commands.c                    pcmk__client_t *client)
client           2906 daemons/fenced/fenced_commands.c     CRM_CHECK((reply != NULL) && ((remote_peer != NULL) || (client != NULL)),
client           2910 daemons/fenced/fenced_commands.c         do_local_reply(reply, client, call_options);
client           3431 daemons/fenced/fenced_commands.c handle_reply(pcmk__client_t *client, xmlNode *request, const char *remote_peer)
client           3442 daemons/fenced/fenced_commands.c                 crm_str(op), ((client == NULL)? "peer" : "client"),
client           3443 daemons/fenced/fenced_commands.c                 ((client == NULL)? remote_peer : pcmk__client_name(client)));
client           3449 daemons/fenced/fenced_commands.c               op, ((client == NULL)? "peer" : "client"),
client           3450 daemons/fenced/fenced_commands.c               ((client == NULL)? remote_peer : pcmk__client_name(client)));
client           3465 daemons/fenced/fenced_commands.c stonith_command(pcmk__client_t *client, uint32_t id, uint32_t flags,
client           3481 daemons/fenced/fenced_commands.c               ((client == NULL)? "peer" : "client"),
client           3482 daemons/fenced/fenced_commands.c               ((client == NULL)? remote_peer : pcmk__client_name(client)));
client           3485 daemons/fenced/fenced_commands.c         CRM_ASSERT(client == NULL || client->request_id == id);
client           3489 daemons/fenced/fenced_commands.c         handle_reply(client, message, remote_peer);
client           3492 daemons/fenced/fenced_commands.c             .ipc_client     = client,
client            431 daemons/fenced/fenced_remote.c     pcmk__client_t *client = NULL;
client            447 daemons/fenced/fenced_remote.c     client = pcmk__find_client_by_id(op->client_id);
client            448 daemons/fenced/fenced_remote.c     if (client == NULL) {
client            451 daemons/fenced/fenced_remote.c         do_local_reply(reply, client, op->call_options);
client           1074 daemons/fenced/fenced_remote.c fenced_handle_manual_confirmation(pcmk__client_t *client, xmlNode *msg)
client           1083 daemons/fenced/fenced_remote.c     op = initiate_remote_stonith_op(client, msg, TRUE);
client           1113 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer)
client           1132 daemons/fenced/fenced_remote.c                       op_id, ((client == NULL)? "unknown client" : client));
client           1164 daemons/fenced/fenced_remote.c     CRM_LOG_ASSERT(client != NULL);
client           1165 daemons/fenced/fenced_remote.c     if (client) {
client           1166 daemons/fenced/fenced_remote.c         op->client_id = strdup(client);
client           1238 daemons/fenced/fenced_remote.c initiate_remote_stonith_op(pcmk__client_t *client, xmlNode *request,
client           1248 daemons/fenced/fenced_remote.c     if (client) {
client           1249 daemons/fenced/fenced_remote.c         client_id = client->id;
client            158 daemons/fenced/pacemaker-fenced.c     pcmk__client_t *client = pcmk__find_client(c);
client            160 daemons/fenced/pacemaker-fenced.c     if (client == NULL) {
client            165 daemons/fenced/pacemaker-fenced.c     pcmk__free_client(client);
client            232 daemons/fenced/pacemaker-fenced.c do_local_reply(xmlNode *notify_src, pcmk__client_t *client, int call_options)
client            240 daemons/fenced/pacemaker-fenced.c         CRM_LOG_ASSERT(client->request_id);
client            241 daemons/fenced/pacemaker-fenced.c         rid = client->request_id;
client            242 daemons/fenced/pacemaker-fenced.c         client->request_id = 0;
client            246 daemons/fenced/pacemaker-fenced.c     local_rc = pcmk__ipc_send_xml(client, rid, notify_src, ipc_flags);
client            249 daemons/fenced/pacemaker-fenced.c                   rid, pcmk__client_name(client));
client            253 daemons/fenced/pacemaker-fenced.c                  pcmk__client_name(client), pcmk_rc_str(local_rc));
client            284 daemons/fenced/pacemaker-fenced.c     pcmk__client_t *client = value;
client            287 daemons/fenced/pacemaker-fenced.c     CRM_CHECK(client != NULL, return);
client            293 daemons/fenced/pacemaker-fenced.c     if (client->ipcs == NULL) {
client            298 daemons/fenced/pacemaker-fenced.c     if (pcmk_is_set(client->flags, get_stonith_flag(type))) {
client            299 daemons/fenced/pacemaker-fenced.c         int rc = pcmk__ipc_send_xml(client, 0, update_msg,
client            304 daemons/fenced/pacemaker-fenced.c                      CRM_XS " id=%.8s rc=%d", type, pcmk__client_name(client),
client            305 daemons/fenced/pacemaker-fenced.c                      pcmk_rc_str(rc), client->id, rc);
client            308 daemons/fenced/pacemaker-fenced.c                       type, pcmk__client_name(client));
client            316 daemons/fenced/pacemaker-fenced.c     pcmk__client_t *client = NULL;
client            323 daemons/fenced/pacemaker-fenced.c     client = pcmk__find_client_by_id(client_id);
client            324 daemons/fenced/pacemaker-fenced.c     if (!client) {
client            335 daemons/fenced/pacemaker-fenced.c     if (client) {
client            336 daemons/fenced/pacemaker-fenced.c         pcmk__ipc_send_xml(client, 0, notify_data, crm_ipc_server_event);
client            217 daemons/fenced/pacemaker-fenced.h void stonith_command(pcmk__client_t *client, uint32_t id, uint32_t flags,
client            232 daemons/fenced/pacemaker-fenced.h void do_local_reply(xmlNode *notify_src, pcmk__client_t *client,
client            239 daemons/fenced/pacemaker-fenced.h  do_stonith_async_timeout_update(const char *client, const char *call_id, int timeout);
client            251 daemons/fenced/pacemaker-fenced.h remote_fencing_op_t *initiate_remote_stonith_op(pcmk__client_t *client,
client            259 daemons/fenced/pacemaker-fenced.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer);
client            270 daemons/fenced/pacemaker-fenced.h int fenced_handle_manual_confirmation(pcmk__client_t *client, xmlNode *msg);
client            126 daemons/pacemakerd/pcmkd_messages.c     pcmk__client_t *client = pcmk__find_client(c);
client            128 daemons/pacemakerd/pcmkd_messages.c     if (client == NULL) {
client            132 daemons/pacemakerd/pcmkd_messages.c     if (shutdown_complete_state_reported_to == client->pid) {
client            138 daemons/pacemakerd/pcmkd_messages.c     pcmk__free_client(client);
client            240 daemons/schedulerd/schedulerd_messages.c     pcmk__client_t *client = pcmk__find_client(c);
client            242 daemons/schedulerd/schedulerd_messages.c     if (client == NULL) {
client            246 daemons/schedulerd/schedulerd_messages.c     pcmk__free_client(client);
client            166 include/crm/common/ipc.h bool crm_ipc_connect(crm_ipc_t * client);
client            167 include/crm/common/ipc.h void crm_ipc_close(crm_ipc_t * client);
client            168 include/crm/common/ipc.h void crm_ipc_destroy(crm_ipc_t * client);
client            171 include/crm/common/ipc.h int crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags,
client            174 include/crm/common/ipc.h int crm_ipc_get_fd(crm_ipc_t * client);
client            175 include/crm/common/ipc.h bool crm_ipc_connected(crm_ipc_t * client);
client            176 include/crm/common/ipc.h int crm_ipc_ready(crm_ipc_t * client);
client            177 include/crm/common/ipc.h long crm_ipc_read(crm_ipc_t * client);
client            178 include/crm/common/ipc.h const char *crm_ipc_buffer(crm_ipc_t * client);
client            179 include/crm/common/ipc.h uint32_t crm_ipc_buffer_flags(crm_ipc_t * client);
client            180 include/crm/common/ipc.h const char *crm_ipc_name(crm_ipc_t * client);
client            134 include/crm/common/ipc_internal.h #define PCMK__CLIENT_TYPE(client) ((client)->flags & UINT64_C(0xff00000000))
client            162 include/crm/common/ipc_internal.h #define pcmk__set_client_flags(client, flags_to_set) do {               \
client            163 include/crm/common/ipc_internal.h         (client)->flags = pcmk__set_flags_as(__func__, __LINE__,        \
client            165 include/crm/common/ipc_internal.h             "Client", pcmk__client_name(client),                        \
client            166 include/crm/common/ipc_internal.h             (client)->flags, (flags_to_set), #flags_to_set);            \
client            169 include/crm/common/ipc_internal.h #define pcmk__clear_client_flags(client, flags_to_clear) do {           \
client            170 include/crm/common/ipc_internal.h         (client)->flags = pcmk__clear_flags_as(__func__, __LINE__,      \
client            172 include/crm/common/ipc_internal.h             "Client", pcmk__client_name(client),                        \
client            173 include/crm/common/ipc_internal.h             (client)->flags, (flags_to_clear), #flags_to_clear);        \
client            204 include/crm/common/ipc_internal.h bool pcmk__set_client_queue_max(pcmk__client_t *client, const char *qmax);
client            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(pcmk__client_t *client);
client            109 include/crm/stonith-ng.h     char *client;
client            424 lib/cib/cib_client.c             cib_notify_client_t *client = g_list_nth_data(list, 0);
client            426 lib/cib/cib_client.c             list = g_list_remove(list, client);
client            427 lib/cib/cib_client.c             free(client);
client            514 lib/cib/cib_client.c         cib_notify_client_t *client = (cib_notify_client_t *)l->data;
client            516 lib/cib/cib_client.c         if (strcmp(client->event, event) == 0) {
client            702 lib/common/ipc_client.c     const char *client = crm_system_name? crm_system_name : "client";
client            720 lib/common/ipc_client.c                                      pcmk_ipc_name(api, false), client, NULL);
client            802 lib/common/ipc_client.c     crm_ipc_t *client = NULL;
client            804 lib/common/ipc_client.c     client = calloc(1, sizeof(crm_ipc_t));
client            805 lib/common/ipc_client.c     if (client == NULL) {
client            810 lib/common/ipc_client.c     client->server_name = strdup(name);
client            811 lib/common/ipc_client.c     if (client->server_name == NULL) {
client            814 lib/common/ipc_client.c         free(client);
client            817 lib/common/ipc_client.c     client->buf_size = pcmk__ipc_buffer_size(max_size);
client            818 lib/common/ipc_client.c     client->buffer = malloc(client->buf_size);
client            819 lib/common/ipc_client.c     if (client->buffer == NULL) {
client            822 lib/common/ipc_client.c         free(client->server_name);
client            823 lib/common/ipc_client.c         free(client);
client            828 lib/common/ipc_client.c     client->max_buf_size = client->buf_size;
client            830 lib/common/ipc_client.c     client->pfd.fd = -1;
client            831 lib/common/ipc_client.c     client->pfd.events = POLLIN;
client            832 lib/common/ipc_client.c     client->pfd.revents = 0;
client            834 lib/common/ipc_client.c     return client;
client            847 lib/common/ipc_client.c crm_ipc_connect(crm_ipc_t * client)
client            854 lib/common/ipc_client.c     client->need_reply = FALSE;
client            855 lib/common/ipc_client.c     client->ipc = qb_ipcc_connect(client->server_name, client->buf_size);
client            857 lib/common/ipc_client.c     if (client->ipc == NULL) {
client            859 lib/common/ipc_client.c                   client->server_name, pcmk_rc_str(errno), errno);
client            863 lib/common/ipc_client.c     client->pfd.fd = crm_ipc_get_fd(client);
client            864 lib/common/ipc_client.c     if (client->pfd.fd < 0) {
client            867 lib/common/ipc_client.c         crm_ipc_close(client);
client            875 lib/common/ipc_client.c         crm_ipc_close(client);
client            880 lib/common/ipc_client.c     if ((rv = pcmk__crm_ipc_is_authentic_process(client->ipc, client->pfd.fd, cl_uid, cl_gid,
client            885 lib/common/ipc_client.c                 client->server_name,
client            889 lib/common/ipc_client.c         crm_ipc_close(client);
client            895 lib/common/ipc_client.c                    client->server_name);
client            896 lib/common/ipc_client.c         crm_ipc_close(client);
client            905 lib/common/ipc_client.c     qb_ipcc_context_set(client->ipc, client);
client            907 lib/common/ipc_client.c     client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc);
client            908 lib/common/ipc_client.c     if (client->max_buf_size > client->buf_size) {
client            909 lib/common/ipc_client.c         free(client->buffer);
client            910 lib/common/ipc_client.c         client->buffer = calloc(1, client->max_buf_size);
client            911 lib/common/ipc_client.c         client->buf_size = client->max_buf_size;
client            917 lib/common/ipc_client.c crm_ipc_close(crm_ipc_t * client)
client            919 lib/common/ipc_client.c     if (client) {
client            920 lib/common/ipc_client.c         if (client->ipc) {
client            921 lib/common/ipc_client.c             qb_ipcc_connection_t *ipc = client->ipc;
client            923 lib/common/ipc_client.c             client->ipc = NULL;
client            930 lib/common/ipc_client.c crm_ipc_destroy(crm_ipc_t * client)
client            932 lib/common/ipc_client.c     if (client) {
client            933 lib/common/ipc_client.c         if (client->ipc && qb_ipcc_is_connected(client->ipc)) {
client            935 lib/common/ipc_client.c                        client->server_name);
client            947 lib/common/ipc_client.c                       client->server_name);
client            949 lib/common/ipc_client.c         free(client->buffer);
client            950 lib/common/ipc_client.c         free(client->server_name);
client            951 lib/common/ipc_client.c         free(client);
client            956 lib/common/ipc_client.c crm_ipc_get_fd(crm_ipc_t * client)
client            960 lib/common/ipc_client.c     if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) {
client            965 lib/common/ipc_client.c                (client? client->server_name : "unspecified"));
client            970 lib/common/ipc_client.c crm_ipc_connected(crm_ipc_t * client)
client            974 lib/common/ipc_client.c     if (client == NULL) {
client            978 lib/common/ipc_client.c     } else if (client->ipc == NULL) {
client            982 lib/common/ipc_client.c     } else if (client->pfd.fd < 0) {
client            987 lib/common/ipc_client.c     rc = qb_ipcc_is_connected(client->ipc);
client            989 lib/common/ipc_client.c         client->pfd.fd = -EINVAL;
client           1002 lib/common/ipc_client.c crm_ipc_ready(crm_ipc_t *client)
client           1006 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1008 lib/common/ipc_client.c     if (crm_ipc_connected(client) == FALSE) {
client           1012 lib/common/ipc_client.c     client->pfd.revents = 0;
client           1013 lib/common/ipc_client.c     rc = poll(&(client->pfd), 1, 0);
client           1019 lib/common/ipc_client.c crm_ipc_decompress(crm_ipc_t * client)
client           1021 lib/common/ipc_client.c     pcmk__ipc_header_t *header = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1027 lib/common/ipc_client.c         unsigned int new_buf_size = QB_MAX((sizeof(pcmk__ipc_header_t) + size_u), client->max_buf_size);
client           1034 lib/common/ipc_client.c                                         client->buffer + sizeof(pcmk__ipc_header_t), header->size_compressed, 1, 0);
client           1053 lib/common/ipc_client.c         memcpy(uncompressed, client->buffer, sizeof(pcmk__ipc_header_t));       /* Preserve the header */
client           1056 lib/common/ipc_client.c         free(client->buffer);
client           1057 lib/common/ipc_client.c         client->buf_size = new_buf_size;
client           1058 lib/common/ipc_client.c         client->buffer = uncompressed;
client           1061 lib/common/ipc_client.c     CRM_ASSERT(client->buffer[sizeof(pcmk__ipc_header_t) + header->size_uncompressed - 1] == 0);
client           1066 lib/common/ipc_client.c crm_ipc_read(crm_ipc_t * client)
client           1070 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1071 lib/common/ipc_client.c     CRM_ASSERT(client->ipc != NULL);
client           1072 lib/common/ipc_client.c     CRM_ASSERT(client->buffer != NULL);
client           1074 lib/common/ipc_client.c     client->buffer[0] = 0;
client           1075 lib/common/ipc_client.c     client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer,
client           1076 lib/common/ipc_client.c                                           client->buf_size, 0);
client           1077 lib/common/ipc_client.c     if (client->msg_size >= 0) {
client           1078 lib/common/ipc_client.c         int rc = crm_ipc_decompress(client);
client           1084 lib/common/ipc_client.c         header = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1090 lib/common/ipc_client.c                   client->server_name, header->qb.id, header->qb.size,
client           1091 lib/common/ipc_client.c                   client->msg_size,
client           1092 lib/common/ipc_client.c                   client->buffer + sizeof(pcmk__ipc_header_t));
client           1096 lib/common/ipc_client.c                   client->server_name, pcmk_strerror(client->msg_size));
client           1098 lib/common/ipc_client.c         if (client->msg_size == -EAGAIN) {
client           1103 lib/common/ipc_client.c     if (crm_ipc_connected(client) == FALSE || client->msg_size == -ENOTCONN) {
client           1104 lib/common/ipc_client.c         crm_err("Connection to %s IPC failed", client->server_name);
client           1115 lib/common/ipc_client.c crm_ipc_buffer(crm_ipc_t * client)
client           1117 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1118 lib/common/ipc_client.c     return client->buffer + sizeof(pcmk__ipc_header_t);
client           1122 lib/common/ipc_client.c crm_ipc_buffer_flags(crm_ipc_t * client)
client           1126 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1127 lib/common/ipc_client.c     if (client->buffer == NULL) {
client           1131 lib/common/ipc_client.c     header = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1136 lib/common/ipc_client.c crm_ipc_name(crm_ipc_t * client)
client           1138 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1139 lib/common/ipc_client.c     return client->server_name;
client           1144 lib/common/ipc_client.c internal_ipc_get_reply(crm_ipc_t *client, int request_id, int ms_timeout,
client           1152 lib/common/ipc_client.c               client->server_name, request_id);
client           1155 lib/common/ipc_client.c         *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000);
client           1159 lib/common/ipc_client.c             rc = crm_ipc_decompress(client);
client           1164 lib/common/ipc_client.c             hdr = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1169 lib/common/ipc_client.c                 xmlNode *bad = string2xml(crm_ipc_buffer(client));
client           1175 lib/common/ipc_client.c                 xmlNode *bad = string2xml(crm_ipc_buffer(client));
client           1181 lib/common/ipc_client.c         } else if (crm_ipc_connected(client) == FALSE) {
client           1183 lib/common/ipc_client.c                     client->server_name, request_id);
client           1209 lib/common/ipc_client.c crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags, int32_t ms_timeout,
client           1220 lib/common/ipc_client.c     if (client == NULL) {
client           1225 lib/common/ipc_client.c     } else if (crm_ipc_connected(client) == FALSE) {
client           1228 lib/common/ipc_client.c                    client->server_name);
client           1236 lib/common/ipc_client.c     if (client->need_reply) {
client           1237 lib/common/ipc_client.c         qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout);
client           1240 lib/common/ipc_client.c                      client->server_name);
client           1245 lib/common/ipc_client.c                        client->server_name);
client           1246 lib/common/ipc_client.c             client->need_reply = FALSE;
client           1252 lib/common/ipc_client.c     rc = pcmk__ipc_prepare_iov(id, message, client->max_buf_size, &iov, &bytes);
client           1255 lib/common/ipc_client.c                  client->server_name, pcmk_rc_str(rc), rc);
client           1260 lib/common/ipc_client.c     pcmk__set_ipc_flags(header->flags, client->server_name, flags);
client           1268 lib/common/ipc_client.c         if(factor < 10 && (client->max_buf_size / 10) < (bytes / factor)) {
client           1272 lib/common/ipc_client.c                        factor, client->max_buf_size, 2 * client->max_buf_size);
client           1278 lib/common/ipc_client.c               client->server_name, header->qb.id, header->qb.size, ms_timeout);
client           1288 lib/common/ipc_client.c             if (!crm_ipc_connected(client)) {
client           1292 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv(client->ipc, iov, 2);
client           1301 lib/common/ipc_client.c                       client->server_name, header->qb.id);
client           1305 lib/common/ipc_client.c         rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes);
client           1313 lib/common/ipc_client.c             client->need_reply = TRUE;
client           1320 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer,
client           1321 lib/common/ipc_client.c                                        client->buf_size, -1);
client           1322 lib/common/ipc_client.c         } while ((qb_rc == -EAGAIN) && crm_ipc_connected(client));
client           1327 lib/common/ipc_client.c         pcmk__ipc_header_t *hdr = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1330 lib/common/ipc_client.c                   rc, hdr->qb.id, client->server_name, header->qb.id,
client           1331 lib/common/ipc_client.c                   crm_ipc_buffer(client));
client           1334 lib/common/ipc_client.c             *reply = string2xml(crm_ipc_buffer(client));
client           1339 lib/common/ipc_client.c                   client->server_name, header->qb.id, rc);
client           1343 lib/common/ipc_client.c     if (crm_ipc_connected(client) == FALSE) {
client           1345 lib/common/ipc_client.c                    CRM_XS " rc=%d", client->server_name, header->qb.id, rc);
client           1349 lib/common/ipc_client.c                  client->server_name, header->qb.id, pcmk_strerror(rc),
client           1355 lib/common/ipc_client.c                  client->server_name, header->qb.id,
client             73 lib/common/ipc_server.c     pcmk__client_t *client;
client             78 lib/common/ipc_server.c         while (g_hash_table_iter_next(&iter, &key, (gpointer *) & client)) {
client             79 lib/common/ipc_server.c             if (strcmp(client->id, id) == 0) {
client             80 lib/common/ipc_server.c                 return client;
client            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            190 lib/common/ipc_server.c     if (client->id == NULL) {
client            192 lib/common/ipc_server.c         free(client->user);
client            193 lib/common/ipc_server.c         free(client);
client            197 lib/common/ipc_server.c         key = client->id;
client            203 lib/common/ipc_server.c     g_hash_table_insert(client_connections, key, client);
client            204 lib/common/ipc_server.c     return client;
client            217 lib/common/ipc_server.c     pcmk__client_t *client = client_from_connection(NULL, key, 0);
client            219 lib/common/ipc_server.c     CRM_ASSERT(client != NULL);
client            220 lib/common/ipc_server.c     return client;
client            229 lib/common/ipc_server.c     pcmk__client_t *client = NULL;
client            250 lib/common/ipc_server.c     client = client_from_connection(c, NULL, uid_client);
client            251 lib/common/ipc_server.c     if (client == NULL) {
client            257 lib/common/ipc_server.c         pcmk__set_client_flags(client, pcmk__client_privileged);
client            261 lib/common/ipc_server.c               client->id, client->pid, uid_client, gid_client);
client            262 lib/common/ipc_server.c     return client;
client            356 lib/common/ipc_server.c pcmk__set_client_queue_max(pcmk__client_t *client, const char *qmax)
client            358 lib/common/ipc_server.c     if (pcmk_is_set(client->flags, pcmk__client_privileged)) {
client            363 lib/common/ipc_server.c             client->queue_max = (unsigned int) qmax_ll;
client            750 lib/common/mainloop.c     mainloop_io_t *client = data;
client            752 lib/common/mainloop.c     CRM_ASSERT(client->fd == g_io_channel_unix_get_fd(gio));
client            755 lib/common/mainloop.c         if (client->ipc) {
client            760 lib/common/mainloop.c                 read_rc = crm_ipc_read(client->ipc);
client            763 lib/common/mainloop.c                               client->name, pcmk_strerror(read_rc), read_rc);
client            765 lib/common/mainloop.c                 } else if (client->dispatch_fn_ipc) {
client            766 lib/common/mainloop.c                     const char *buffer = crm_ipc_buffer(client->ipc);
client            770 lib/common/mainloop.c                               read_rc, client->name, (int) condition);
client            771 lib/common/mainloop.c                     if (client->dispatch_fn_ipc(buffer, read_rc, client->userdata) < 0) {
client            772 lib/common/mainloop.c                         crm_trace("Connection to %s no longer required", client->name);
client            781 lib/common/mainloop.c                       client->name, (int) condition);
client            782 lib/common/mainloop.c             if (client->dispatch_fn_io) {
client            783 lib/common/mainloop.c                 if (client->dispatch_fn_io(client->userdata) < 0) {
client            784 lib/common/mainloop.c                     crm_trace("Connection to %s no longer required", client->name);
client            791 lib/common/mainloop.c     if (client->ipc && crm_ipc_connected(client->ipc) == FALSE) {
client            793 lib/common/mainloop.c                 client->name, client, condition);
client            798 lib/common/mainloop.c                   client->name, client, condition);
client            841 lib/common/mainloop.c     mainloop_io_t *client = c;
client            842 lib/common/mainloop.c     char *c_name = strdup(client->name);
client            849 lib/common/mainloop.c     if (client->ipc) {
client            850 lib/common/mainloop.c         crm_ipc_close(client->ipc);
client            853 lib/common/mainloop.c     if (client->destroy_fn) {
client            854 lib/common/mainloop.c         void (*destroy_fn) (gpointer userdata) = client->destroy_fn;
client            856 lib/common/mainloop.c         client->destroy_fn = NULL;
client            857 lib/common/mainloop.c         destroy_fn(client->userdata);
client            860 lib/common/mainloop.c     if (client->ipc) {
client            861 lib/common/mainloop.c         crm_ipc_t *ipc = client->ipc;
client            863 lib/common/mainloop.c         client->ipc = NULL;
client            869 lib/common/mainloop.c     free(client->name); client->name = NULL;
client            870 lib/common/mainloop.c     free(client);
client            961 lib/common/mainloop.c mainloop_del_ipc_client(mainloop_io_t * client)
client            963 lib/common/mainloop.c     mainloop_del_fd(client);
client            967 lib/common/mainloop.c mainloop_get_ipc_client(mainloop_io_t * client)
client            969 lib/common/mainloop.c     if (client) {
client            970 lib/common/mainloop.c         return client->ipc;
client            979 lib/common/mainloop.c     mainloop_io_t *client = NULL;
client            982 lib/common/mainloop.c         client = calloc(1, sizeof(mainloop_io_t));
client            983 lib/common/mainloop.c         if (client == NULL) {
client            986 lib/common/mainloop.c         client->name = strdup(name);
client            987 lib/common/mainloop.c         client->userdata = userdata;
client            990 lib/common/mainloop.c             client->destroy_fn = callbacks->destroy;
client            991 lib/common/mainloop.c             client->dispatch_fn_io = callbacks->dispatch;
client            994 lib/common/mainloop.c         client->fd = fd;
client            995 lib/common/mainloop.c         client->channel = g_io_channel_unix_new(fd);
client            996 lib/common/mainloop.c         client->source =
client            997 lib/common/mainloop.c             g_io_add_watch_full(client->channel, priority,
client            999 lib/common/mainloop.c                                 client, mainloop_gio_destroy);
client           1010 lib/common/mainloop.c         g_io_channel_unref(client->channel);
client           1011 lib/common/mainloop.c         crm_trace("Added connection %d for %s[%p].%d", client->source, client->name, client, fd);
client           1016 lib/common/mainloop.c     return client;
client           1020 lib/common/mainloop.c mainloop_del_fd(mainloop_io_t * client)
client           1022 lib/common/mainloop.c     if (client != NULL) {
client           1023 lib/common/mainloop.c         crm_trace("Removing client %s[%p]", client->name, client);
client           1024 lib/common/mainloop.c         if (client->source) {
client           1028 lib/common/mainloop.c             g_source_remove(client->source);
client            345 lib/common/remote.c pcmk__read_handshake_data(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            714 lib/fencing/st_client.c             kvp->client = crm_element_value_copy(op, F_STONITH_CLIENTNAME);
client            746 lib/fencing/st_client.c         free(hp->client);
client            257 lib/fencing/st_output.c                            event->client, event->origin,
client            275 lib/fencing/st_output.c                            event->client, event->origin,
client            287 lib/fencing/st_output.c                            event->client, event->origin);
client            313 lib/fencing/st_output.c                                   event->client, event->origin,
client            322 lib/fencing/st_output.c                                   event->client, event->origin,
client            329 lib/fencing/st_output.c                                   event->client, event->origin);
client            349 lib/fencing/st_output.c                                                    "client", event->client,
client            187 lib/pengine/pe_output.c                     const char *client, const char *origin) {
client            188 lib/pengine/pe_output.c     if (last_written != NULL || user != NULL || client != NULL || origin != NULL) {
client            193 lib/pengine/pe_output.c                                  client ? " via " : "",
client            194 lib/pengine/pe_output.c                                  client ? client : "",
client            344 lib/pengine/pe_output.c         const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT);
client            348 lib/pengine/pe_output.c         out->message(out, "cluster-times", last_written, user, client, origin);
client            407 lib/pengine/pe_output.c         const char *client = crm_element_value(data_set->input, XML_ATTR_UPDATE_CLIENT);
client            411 lib/pengine/pe_output.c         out->message(out, "cluster-times", last_written, user, client, origin);
client           1058 lib/pengine/pe_output.c     const char *client = va_arg(args, const char *);
client           1064 lib/pengine/pe_output.c     char *buf = last_changed_string(last_written, user, client, origin);
client           1082 lib/pengine/pe_output.c     const char *client = va_arg(args, const char *);
client           1091 lib/pengine/pe_output.c                                  "client", client ? client : "",
client           1103 lib/pengine/pe_output.c     const char *client = va_arg(args, const char *);
client           1106 lib/pengine/pe_output.c     char *buf = 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);
client            476 tools/crm_mon_curses.c                                    event->client, event->origin,
client            485 tools/crm_mon_curses.c                                    event->client, event->origin,
client            492 tools/crm_mon_curses.c                                    event->client, event->origin);