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            227 daemons/attrd/pacemaker-attrd.c     pcmk__client_t *client = pcmk__find_client(c);
client            232 daemons/attrd/pacemaker-attrd.c     CRM_CHECK((c != NULL) && (client != NULL), return 0);
client            237 daemons/attrd/pacemaker-attrd.c     xml = pcmk__client_data2xml(client, data, &id, &flags);
client            243 daemons/attrd/pacemaker-attrd.c     CRM_ASSERT(client->user != NULL);
client            244 daemons/attrd/pacemaker-attrd.c     pcmk__update_acl_user(xml, PCMK__XA_ATTR_USER, client->user);
client            248 daemons/attrd/pacemaker-attrd.c     if (client->name == NULL) {
client            250 daemons/attrd/pacemaker-attrd.c         client->name = crm_strdup_printf("%s.%d", value?value:"unknown", client->pid);
client            254 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            255 daemons/attrd/pacemaker-attrd.c         attrd_client_peer_remove(client, xml);
client            258 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            262 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            266 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            270 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            274 daemons/attrd/pacemaker-attrd.c         attrd_send_ack(client, id, flags);
client            279 daemons/attrd/pacemaker-attrd.c         attrd_client_query(client, id, flags, xml);
client            283 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           1344 daemons/based/based_callbacks.c         const char *client = crm_element_value(request, F_CIB_CLIENTNAME);
client           1348 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            264 daemons/based/based_remote.c     pcmk__client_t *client = data;
client            266 daemons/based/based_remote.c     client->remote->auth_timeout = 0;
client            268 daemons/based/based_remote.c     if (client->remote->authenticated == TRUE) {
client            272 daemons/based/based_remote.c     mainloop_del_fd(client->remote->source);
client            357 daemons/based/based_remote.c     pcmk__client_t *client = user_data;
client            360 daemons/based/based_remote.c     if (client == NULL) {
client            365 daemons/based/based_remote.c               pcmk__client_name(client));
client            370 daemons/based/based_remote.c     switch (PCMK__CLIENT_TYPE(client)) {
client            372 daemons/based/based_remote.c             csock = client->remote->tcp_socket;
client            376 daemons/based/based_remote.c             if (client->remote->tls_session) {
client            377 daemons/based/based_remote.c                 void *sock_ptr = gnutls_transport_get_ptr(*client->remote->tls_session);
client            380 daemons/based/based_remote.c                 if (client->remote->tls_handshake_complete) {
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            429 daemons/based/based_remote.c     if (client->userdata == NULL) {
client            432 daemons/based/based_remote.c             client->userdata = strdup(value);
client            433 daemons/based/based_remote.c             crm_trace("Callback channel for %s is %s", client->id, (char*)client->userdata);
client            436 daemons/based/based_remote.c             client->userdata = strdup(client->id);
client            446 daemons/based/based_remote.c     crm_xml_add(command, F_CIB_CLIENTID, client->id);
client            447 daemons/based/based_remote.c     crm_xml_add(command, F_CIB_CLIENTNAME, client->name);
client            448 daemons/based/based_remote.c     crm_xml_add(command, F_CIB_USER, client->user);
client            463 daemons/based/based_remote.c     cib_common_callback_worker(0, 0, command, client, TRUE);
client            470 daemons/based/based_remote.c     pcmk__client_t *client = data;
client            472 daemons/based/based_remote.c     int timeout = client->remote->authenticated ? -1 : 1000;
client            475 daemons/based/based_remote.c               pcmk__client_type_str(PCMK__CLIENT_TYPE(client)),
client            476 daemons/based/based_remote.c               pcmk__client_name(client));
client            479 daemons/based/based_remote.c     if ((PCMK__CLIENT_TYPE(client) == pcmk__client_tls)
client            480 daemons/based/based_remote.c         && !(client->remote->tls_handshake_complete)) {
client            482 daemons/based/based_remote.c         int rc = pcmk__read_handshake_data(client);
client            494 daemons/based/based_remote.c         client->remote->tls_handshake_complete = TRUE;
client            495 daemons/based/based_remote.c         if (client->remote->auth_timeout) {
client            496 daemons/based/based_remote.c             g_source_remove(client->remote->auth_timeout);
client            500 daemons/based/based_remote.c         client->remote->auth_timeout = g_timeout_add(REMOTE_AUTH_TIMEOUT,
client            502 daemons/based/based_remote.c                                                      client);
client            507 daemons/based/based_remote.c     rc = pcmk__read_remote_message(client->remote, timeout);
client            510 daemons/based/based_remote.c     if (client->remote->authenticated == FALSE) {
client            514 daemons/based/based_remote.c         command = pcmk__remote_message_xml(client->remote);
client            521 daemons/based/based_remote.c         client->remote->authenticated = TRUE;
client            522 daemons/based/based_remote.c         g_source_remove(client->remote->auth_timeout);
client            523 daemons/based/based_remote.c         client->remote->auth_timeout = 0;
client            524 daemons/based/based_remote.c         client->name = crm_element_value_copy(command, "name");
client            528 daemons/based/based_remote.c             client->user = strdup(user);
client            534 daemons/based/based_remote.c         crm_xml_add(reg, F_CIB_CLIENTID, client->id);
client            535 daemons/based/based_remote.c         pcmk__remote_send_xml(client->remote, reg);
client            540 daemons/based/based_remote.c     command = pcmk__remote_message_xml(client->remote);
client            543 daemons/based/based_remote.c         cib_handle_remote_msg(client, command);
client            545 daemons/based/based_remote.c         command = pcmk__remote_message_xml(client->remote);
client            147 daemons/based/pacemaker-based.h void cib_diff_notify(int options, const char *client, const char *call_id,
client            375 daemons/controld/controld_control.c     pcmk__client_t *client = pcmk__find_client(c);
client            377 daemons/controld/controld_control.c     xmlNode *msg = pcmk__client_data2xml(client, data, &id, &flags);
client            380 daemons/controld/controld_control.c         pcmk__ipc_send_ack(client, id, flags, "ack", CRM_EX_PROTOCOL);
client            383 daemons/controld/controld_control.c     pcmk__ipc_send_ack(client, id, flags, "ack", CRM_EX_INDETERMINATE);
client            385 daemons/controld/controld_control.c     CRM_ASSERT(client->user != NULL);
client            386 daemons/controld/controld_control.c     pcmk__update_acl_user(msg, F_CRM_USER, client->user);
client            388 daemons/controld/controld_control.c     crm_xml_add(msg, F_CRM_SYS_FROM, client->id);
client            389 daemons/controld/controld_control.c     if (controld_authorize_ipc_message(msg, client, NULL)) {
client            391 daemons/controld/controld_control.c                   pcmk__client_name(client));
client            403 daemons/controld/controld_control.c     pcmk__client_t *client = pcmk__find_client(c);
client            405 daemons/controld/controld_control.c     if (client) {
client            407 daemons/controld/controld_control.c                   (client->userdata? "" : "un"), pcmk__client_name(client),
client            408 daemons/controld/controld_control.c                   c, client);
client            409 daemons/controld/controld_control.c         free(client->userdata);
client            410 daemons/controld/controld_control.c         pcmk__free_client(client);
client             83 daemons/execd/execd_alerts.c process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id, xmlNode *request)
client             97 daemons/execd/execd_alerts.c         (client == NULL) || (client->id == NULL)) { /* hint static analyzer */
client            106 daemons/execd/execd_alerts.c     crm_info("Executing alert %s for %s", alert_id, client->id);
client            119 daemons/execd/execd_alerts.c     cb_data->client_id = strdup(client->id);
client            291 daemons/execd/execd_commands.c create_lrmd_cmd(xmlNode *msg, pcmk__client_t *client)
client            301 daemons/execd/execd_commands.c     cmd->client_id = strdup(client->id);
client            540 daemons/execd/execd_commands.c     pcmk__client_t *client = value;
client            545 daemons/execd/execd_commands.c     CRM_CHECK(client != NULL, return);
client            546 daemons/execd/execd_commands.c     if (client->name == NULL) {
client            550 daemons/execd/execd_commands.c     if (pcmk_is_set(client->flags, pcmk__client_to_proxy)) {
client            556 daemons/execd/execd_commands.c                   pcmk__client_name(client));
client            560 daemons/execd/execd_commands.c     rc = lrmd_server_send_notify(client, update_msg);
client            577 daemons/execd/execd_commands.c                pcmk__client_name(client), msg, rc);
client            660 daemons/execd/execd_commands.c         pcmk__client_t *client = pcmk__find_client_by_id(cmd->client_id);
client            662 daemons/execd/execd_commands.c         if (client) {
client            663 daemons/execd/execd_commands.c             send_client_notify(client->id, client, notify);
client            807 daemons/execd/execd_commands.c     pcmk__client_t *client = value;
client            810 daemons/execd/execd_commands.c     if (!pcmk__str_eq(client->id, data->new_client->id, pcmk__str_casei)) {
client            811 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->remote->tls_handshake_complete) {
client           1488 daemons/execd/execd_commands.c             ipc_proxy_add_provider(client);
client           1499 daemons/execd/execd_commands.c     crm_xml_add(*reply, F_LRMD_CLIENTID, client->id);
client           1506 daemons/execd/execd_commands.c process_lrmd_rsc_register(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1556 daemons/execd/execd_commands.c process_lrmd_rsc_unregister(pcmk__client_t *client, uint32_t id,
client           1588 daemons/execd/execd_commands.c process_lrmd_rsc_exec(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1605 daemons/execd/execd_commands.c     cmd = create_lrmd_cmd(request, client);
client           1713 daemons/execd/execd_commands.c process_lrmd_rsc_cancel(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1793 daemons/execd/execd_commands.c process_lrmd_message(pcmk__client_t *client, uint32_t id, xmlNode *request)
client           1806 daemons/execd/execd_commands.c     bool allowed = pcmk_is_set(client->flags, pcmk__client_privileged);
client           1808 daemons/execd/execd_commands.c     crm_trace("Processing %s operation from %s", op, client->id);
client           1814 daemons/execd/execd_commands.c             ipc_proxy_forward_client(client, request);
client           1823 daemons/execd/execd_commands.c         rc = process_lrmd_signon(client, request, call_id, &reply);
client           1827 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_register(client, id, request);
client           1842 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_unregister(client, id, request);
client           1853 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_exec(client, id, request);
client           1860 daemons/execd/execd_commands.c             rc = process_lrmd_rsc_cancel(client, id, request);
client           1879 daemons/execd/execd_commands.c             rc = process_lrmd_alert_exec(client, id, request);
client           1895 daemons/execd/execd_commands.c                 op, pcmk__client_name(client));
client           1900 daemons/execd/execd_commands.c                  op, pcmk__client_name(client));
client           1904 daemons/execd/execd_commands.c               op, client->id, rc, do_reply, do_notify);
client           1912 daemons/execd/execd_commands.c         send_rc = lrmd_server_send_reply(client, id, reply);
client           1916 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             56 daemons/execd/pacemaker-execd.h int lrmd_server_send_reply(pcmk__client_t *client, uint32_t id, xmlNode *reply);
client             58 daemons/execd/pacemaker-execd.h int lrmd_server_send_notify(pcmk__client_t *client, xmlNode *msg);
client             62 daemons/execd/pacemaker-execd.h void process_lrmd_message(pcmk__client_t *client, uint32_t id,
client             71 daemons/execd/pacemaker-execd.h void lrmd_client_destroy(pcmk__client_t *client);
client             91 daemons/execd/pacemaker-execd.h void ipc_proxy_add_provider(pcmk__client_t *client);
client             92 daemons/execd/pacemaker-execd.h void ipc_proxy_remove_provider(pcmk__client_t *client);
client             93 daemons/execd/pacemaker-execd.h void ipc_proxy_forward_client(pcmk__client_t *client, xmlNode *xml);
client             99 daemons/execd/pacemaker-execd.h int process_lrmd_alert_exec(pcmk__client_t *client, uint32_t id,
client             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             89 daemons/fenced/fenced_commands.c     char *client;
client            251 daemons/fenced/fenced_commands.c     free(cmd->client);
client            278 daemons/fenced/fenced_commands.c     cmd->client = crm_element_value_copy(msg, F_STONITH_CLIENTID);
client            286 daemons/fenced/fenced_commands.c     CRM_CHECK(cmd->client != NULL, crm_log_xml_warn(msg, "NoClient"));
client            573 daemons/fenced/fenced_commands.c                   device->id, cmd->client, cmd->timeout);
client           1096 daemons/fenced/fenced_commands.c     cmd->client = strdup(crm_system_name);
client           2367 daemons/fenced/fenced_commands.c         do_local_reply(reply, cmd->client, cmd->options & st_opt_sync_call, FALSE);
client           2380 daemons/fenced/fenced_commands.c         crm_xml_add(notify_data, F_STONITH_ORIGIN, cmd->client);
client           2489 daemons/fenced/fenced_commands.c         if (pcmk__str_eq(cmd->client, cmd_other->client, pcmk__str_casei) ||
client           2679 daemons/fenced/fenced_commands.c     crm_xml_add(reply, F_STONITH_CLIENTID, cmd->client);
client           2831 daemons/fenced/fenced_commands.c handle_request(pcmk__client_t *client, uint32_t id, uint32_t flags,
client           2850 daemons/fenced/fenced_commands.c     bool allowed = (client == NULL)
client           2851 daemons/fenced/fenced_commands.c                    || pcmk_is_set(client->flags, pcmk__client_privileged);
client           2856 daemons/fenced/fenced_commands.c         CRM_ASSERT(client == NULL || client->request_id == id);
client           2862 daemons/fenced/fenced_commands.c         CRM_ASSERT(client);
client           2864 daemons/fenced/fenced_commands.c         crm_xml_add(reply, F_STONITH_CLIENTID, client->id);
client           2865 daemons/fenced/fenced_commands.c         pcmk__ipc_send_xml(client, id, reply, flags);
client           2866 daemons/fenced/fenced_commands.c         client->request_id = 0;
client           2896 daemons/fenced/fenced_commands.c         CRM_ASSERT(client);
client           2900 daemons/fenced/fenced_commands.c                       flag_name, pcmk__client_name(client));
client           2901 daemons/fenced/fenced_commands.c             pcmk__set_client_flags(client, get_stonith_flag(flag_name));
client           2907 daemons/fenced/fenced_commands.c                       flag_name, pcmk__client_name(client));
client           2908 daemons/fenced/fenced_commands.c             pcmk__clear_client_flags(client, get_stonith_flag(flag_name));
client           2911 daemons/fenced/fenced_commands.c         pcmk__ipc_send_ack(client, id, flags, "ack", CRM_EX_OK);
client           2919 daemons/fenced/fenced_commands.c                    ((client == NULL)? "peer" : "client"),
client           2920 daemons/fenced/fenced_commands.c                    ((client == NULL)? remote_peer : pcmk__client_name(client)),
client           2939 daemons/fenced/fenced_commands.c             rop = initiate_remote_stonith_op(client, request, TRUE);
client           2949 daemons/fenced/fenced_commands.c             if (client) {
client           2953 daemons/fenced/fenced_commands.c                            pcmk__client_name(client), action,
client           2970 daemons/fenced/fenced_commands.c             if (alternate_host && client) {
client           2977 daemons/fenced/fenced_commands.c                 if (client->id) {
client           2978 daemons/fenced/fenced_commands.c                     client_id = client->id;
client           2988 daemons/fenced/fenced_commands.c                 crm_xml_add(request, F_STONITH_CLIENTID, client->id);
client           2994 daemons/fenced/fenced_commands.c             } else if (initiate_remote_stonith_op(client, request, FALSE) != NULL) {
client           3063 daemons/fenced/fenced_commands.c                 ((client == NULL)? "peer" : "client"),
client           3064 daemons/fenced/fenced_commands.c                 ((client == NULL)? remote_peer : pcmk__client_name(client)));
client           3071 daemons/fenced/fenced_commands.c                  crm_str(op), pcmk__client_name(client));
client           3078 daemons/fenced/fenced_commands.c         crm_trace("Reply handling: %p %u %u %d %d %s", client, client?client->request_id:0,
client           3083 daemons/fenced/fenced_commands.c             CRM_ASSERT(client == NULL || client->request_id == id);
client           3097 daemons/fenced/fenced_commands.c handle_reply(pcmk__client_t *client, xmlNode *request, const char *remote_peer)
client           3110 daemons/fenced/fenced_commands.c                 ((client == NULL)? "peer" : "client"),
client           3111 daemons/fenced/fenced_commands.c                 ((client == NULL)? remote_peer : pcmk__client_name(client)));
client           3117 daemons/fenced/fenced_commands.c stonith_command(pcmk__client_t *client, uint32_t id, uint32_t flags,
client           3142 daemons/fenced/fenced_commands.c               ((client == NULL)? "peer" : "client"),
client           3143 daemons/fenced/fenced_commands.c               ((client == NULL)? remote_peer : pcmk__client_name(client)),
client           3147 daemons/fenced/fenced_commands.c         CRM_ASSERT(client == NULL || client->request_id == id);
client           3151 daemons/fenced/fenced_commands.c         handle_reply(client, request, remote_peer);
client           3153 daemons/fenced/fenced_commands.c         rc = handle_request(client, id, flags, request, remote_peer);
client           3158 daemons/fenced/fenced_commands.c               ((client == NULL)? "peer" : "client"),
client           3159 daemons/fenced/fenced_commands.c               ((client == NULL)? remote_peer : pcmk__client_name(client)),
client           1016 daemons/fenced/fenced_remote.c create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer)
client           1035 daemons/fenced/fenced_remote.c                       op_id, ((client == NULL)? "unknown client" : client));
client           1067 daemons/fenced/fenced_remote.c     CRM_LOG_ASSERT(client != NULL);
client           1068 daemons/fenced/fenced_remote.c     if (client) {
client           1069 daemons/fenced/fenced_remote.c         op->client_id = strdup(client);
client           1131 daemons/fenced/fenced_remote.c initiate_remote_stonith_op(pcmk__client_t *client, xmlNode *request,
client           1141 daemons/fenced/fenced_remote.c     if (client) {
client           1142 daemons/fenced/fenced_remote.c         client_id = client->id;
client            155 daemons/fenced/pacemaker-fenced.c     pcmk__client_t *client = pcmk__find_client(c);
client            157 daemons/fenced/pacemaker-fenced.c     if (client == NULL) {
client            162 daemons/fenced/pacemaker-fenced.c     pcmk__free_client(client);
client            301 daemons/fenced/pacemaker-fenced.c     pcmk__client_t *client = value;
client            304 daemons/fenced/pacemaker-fenced.c     CRM_CHECK(client != NULL, return);
client            310 daemons/fenced/pacemaker-fenced.c     if (client->ipcs == NULL) {
client            315 daemons/fenced/pacemaker-fenced.c     if (pcmk_is_set(client->flags, get_stonith_flag(type))) {
client            316 daemons/fenced/pacemaker-fenced.c         int rc = pcmk__ipc_send_xml(client, 0, update_msg,
client            321 daemons/fenced/pacemaker-fenced.c                      CRM_XS " id=%.8s rc=%d", type, pcmk__client_name(client),
client            322 daemons/fenced/pacemaker-fenced.c                      pcmk_rc_str(rc), client->id, rc);
client            325 daemons/fenced/pacemaker-fenced.c                       type, pcmk__client_name(client));
client            333 daemons/fenced/pacemaker-fenced.c     pcmk__client_t *client = NULL;
client            340 daemons/fenced/pacemaker-fenced.c     client = pcmk__find_client_by_id(client_id);
client            341 daemons/fenced/pacemaker-fenced.c     if (!client) {
client            352 daemons/fenced/pacemaker-fenced.c     if (client) {
client            353 daemons/fenced/pacemaker-fenced.c         pcmk__ipc_send_xml(client, 0, notify_data, crm_ipc_server_event);
client            212 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  do_stonith_async_timeout_update(const char *client, const char *call_id, int timeout);
client            240 daemons/fenced/pacemaker-fenced.h remote_fencing_op_t *initiate_remote_stonith_op(pcmk__client_t *client,
client            248 daemons/fenced/pacemaker-fenced.h void *create_remote_stonith_op(const char *client, xmlNode * request, gboolean peer);
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            273 daemons/schedulerd/pacemaker-schedulerd.c     pcmk__client_t *client = pcmk__find_client(c);
client            275 daemons/schedulerd/pacemaker-schedulerd.c     if (client == NULL) {
client            279 daemons/schedulerd/pacemaker-schedulerd.c     pcmk__free_client(client);
client            165 include/crm/common/ipc.h bool crm_ipc_connect(crm_ipc_t * client);
client            166 include/crm/common/ipc.h void crm_ipc_close(crm_ipc_t * client);
client            167 include/crm/common/ipc.h void crm_ipc_destroy(crm_ipc_t * client);
client            170 include/crm/common/ipc.h int crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags,
client            173 include/crm/common/ipc.h int crm_ipc_get_fd(crm_ipc_t * client);
client            174 include/crm/common/ipc.h bool crm_ipc_connected(crm_ipc_t * client);
client            175 include/crm/common/ipc.h int crm_ipc_ready(crm_ipc_t * client);
client            176 include/crm/common/ipc.h long crm_ipc_read(crm_ipc_t * client);
client            177 include/crm/common/ipc.h const char *crm_ipc_buffer(crm_ipc_t * client);
client            178 include/crm/common/ipc.h uint32_t crm_ipc_buffer_flags(crm_ipc_t * client);
client            179 include/crm/common/ipc.h const char *crm_ipc_name(crm_ipc_t * client);
client            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            125 include/crm/common/mainloop.h void mainloop_del_ipc_client(mainloop_io_t * client);
client            127 include/crm/common/mainloop.h crm_ipc_t *mainloop_get_ipc_client(mainloop_io_t * client);
client            150 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            647 lib/common/ipc_client.c     const char *client = crm_system_name? crm_system_name : "client";
client            665 lib/common/ipc_client.c                                      pcmk_ipc_name(api, false), client, NULL);
client            747 lib/common/ipc_client.c     crm_ipc_t *client = NULL;
client            749 lib/common/ipc_client.c     client = calloc(1, sizeof(crm_ipc_t));
client            750 lib/common/ipc_client.c     if (client == NULL) {
client            755 lib/common/ipc_client.c     client->server_name = strdup(name);
client            756 lib/common/ipc_client.c     if (client->server_name == NULL) {
client            759 lib/common/ipc_client.c         free(client);
client            762 lib/common/ipc_client.c     client->buf_size = pcmk__ipc_buffer_size(max_size);
client            763 lib/common/ipc_client.c     client->buffer = malloc(client->buf_size);
client            764 lib/common/ipc_client.c     if (client->buffer == NULL) {
client            767 lib/common/ipc_client.c         free(client->server_name);
client            768 lib/common/ipc_client.c         free(client);
client            773 lib/common/ipc_client.c     client->max_buf_size = client->buf_size;
client            775 lib/common/ipc_client.c     client->pfd.fd = -1;
client            776 lib/common/ipc_client.c     client->pfd.events = POLLIN;
client            777 lib/common/ipc_client.c     client->pfd.revents = 0;
client            779 lib/common/ipc_client.c     return client;
client            792 lib/common/ipc_client.c crm_ipc_connect(crm_ipc_t * client)
client            799 lib/common/ipc_client.c     client->need_reply = FALSE;
client            800 lib/common/ipc_client.c     client->ipc = qb_ipcc_connect(client->server_name, client->buf_size);
client            802 lib/common/ipc_client.c     if (client->ipc == NULL) {
client            804 lib/common/ipc_client.c                   client->server_name, pcmk_strerror(errno), errno);
client            808 lib/common/ipc_client.c     client->pfd.fd = crm_ipc_get_fd(client);
client            809 lib/common/ipc_client.c     if (client->pfd.fd < 0) {
client            812 lib/common/ipc_client.c         crm_ipc_close(client);
client            820 lib/common/ipc_client.c         crm_ipc_close(client);
client            825 lib/common/ipc_client.c     if ((rv = pcmk__crm_ipc_is_authentic_process(client->ipc, client->pfd.fd, cl_uid, cl_gid,
client            830 lib/common/ipc_client.c                 client->server_name,
client            834 lib/common/ipc_client.c         crm_ipc_close(client);
client            840 lib/common/ipc_client.c                    client->server_name);
client            841 lib/common/ipc_client.c         crm_ipc_close(client);
client            850 lib/common/ipc_client.c     qb_ipcc_context_set(client->ipc, client);
client            852 lib/common/ipc_client.c     client->max_buf_size = qb_ipcc_get_buffer_size(client->ipc);
client            853 lib/common/ipc_client.c     if (client->max_buf_size > client->buf_size) {
client            854 lib/common/ipc_client.c         free(client->buffer);
client            855 lib/common/ipc_client.c         client->buffer = calloc(1, client->max_buf_size);
client            856 lib/common/ipc_client.c         client->buf_size = client->max_buf_size;
client            862 lib/common/ipc_client.c crm_ipc_close(crm_ipc_t * client)
client            864 lib/common/ipc_client.c     if (client) {
client            865 lib/common/ipc_client.c         if (client->ipc) {
client            866 lib/common/ipc_client.c             qb_ipcc_connection_t *ipc = client->ipc;
client            868 lib/common/ipc_client.c             client->ipc = NULL;
client            875 lib/common/ipc_client.c crm_ipc_destroy(crm_ipc_t * client)
client            877 lib/common/ipc_client.c     if (client) {
client            878 lib/common/ipc_client.c         if (client->ipc && qb_ipcc_is_connected(client->ipc)) {
client            880 lib/common/ipc_client.c                        client->server_name);
client            892 lib/common/ipc_client.c                       client->server_name);
client            894 lib/common/ipc_client.c         free(client->buffer);
client            895 lib/common/ipc_client.c         free(client->server_name);
client            896 lib/common/ipc_client.c         free(client);
client            901 lib/common/ipc_client.c crm_ipc_get_fd(crm_ipc_t * client)
client            905 lib/common/ipc_client.c     if (client && client->ipc && (qb_ipcc_fd_get(client->ipc, &fd) == 0)) {
client            910 lib/common/ipc_client.c                (client? client->server_name : "unspecified"));
client            915 lib/common/ipc_client.c crm_ipc_connected(crm_ipc_t * client)
client            919 lib/common/ipc_client.c     if (client == NULL) {
client            923 lib/common/ipc_client.c     } else if (client->ipc == NULL) {
client            927 lib/common/ipc_client.c     } else if (client->pfd.fd < 0) {
client            932 lib/common/ipc_client.c     rc = qb_ipcc_is_connected(client->ipc);
client            934 lib/common/ipc_client.c         client->pfd.fd = -EINVAL;
client            947 lib/common/ipc_client.c crm_ipc_ready(crm_ipc_t *client)
client            951 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client            953 lib/common/ipc_client.c     if (crm_ipc_connected(client) == FALSE) {
client            957 lib/common/ipc_client.c     client->pfd.revents = 0;
client            958 lib/common/ipc_client.c     rc = poll(&(client->pfd), 1, 0);
client            964 lib/common/ipc_client.c crm_ipc_decompress(crm_ipc_t * client)
client            966 lib/common/ipc_client.c     pcmk__ipc_header_t *header = (pcmk__ipc_header_t *)(void*)client->buffer;
client            972 lib/common/ipc_client.c         unsigned int new_buf_size = QB_MAX((sizeof(pcmk__ipc_header_t) + size_u), client->max_buf_size);
client            979 lib/common/ipc_client.c                                         client->buffer + sizeof(pcmk__ipc_header_t), header->size_compressed, 1, 0);
client            998 lib/common/ipc_client.c         memcpy(uncompressed, client->buffer, sizeof(pcmk__ipc_header_t));       /* Preserve the header */
client           1001 lib/common/ipc_client.c         free(client->buffer);
client           1002 lib/common/ipc_client.c         client->buf_size = new_buf_size;
client           1003 lib/common/ipc_client.c         client->buffer = uncompressed;
client           1006 lib/common/ipc_client.c     CRM_ASSERT(client->buffer[sizeof(pcmk__ipc_header_t) + header->size_uncompressed - 1] == 0);
client           1011 lib/common/ipc_client.c crm_ipc_read(crm_ipc_t * client)
client           1015 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1016 lib/common/ipc_client.c     CRM_ASSERT(client->ipc != NULL);
client           1017 lib/common/ipc_client.c     CRM_ASSERT(client->buffer != NULL);
client           1019 lib/common/ipc_client.c     client->buffer[0] = 0;
client           1020 lib/common/ipc_client.c     client->msg_size = qb_ipcc_event_recv(client->ipc, client->buffer,
client           1021 lib/common/ipc_client.c                                           client->buf_size, 0);
client           1022 lib/common/ipc_client.c     if (client->msg_size >= 0) {
client           1023 lib/common/ipc_client.c         int rc = crm_ipc_decompress(client);
client           1029 lib/common/ipc_client.c         header = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1035 lib/common/ipc_client.c                   client->server_name, header->qb.id, header->qb.size,
client           1036 lib/common/ipc_client.c                   client->msg_size,
client           1037 lib/common/ipc_client.c                   client->buffer + sizeof(pcmk__ipc_header_t));
client           1041 lib/common/ipc_client.c                   client->server_name, pcmk_strerror(client->msg_size));
client           1044 lib/common/ipc_client.c     if (crm_ipc_connected(client) == FALSE || client->msg_size == -ENOTCONN) {
client           1045 lib/common/ipc_client.c         crm_err("Connection to %s IPC failed", client->server_name);
client           1056 lib/common/ipc_client.c crm_ipc_buffer(crm_ipc_t * client)
client           1058 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1059 lib/common/ipc_client.c     return client->buffer + sizeof(pcmk__ipc_header_t);
client           1063 lib/common/ipc_client.c crm_ipc_buffer_flags(crm_ipc_t * client)
client           1067 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1068 lib/common/ipc_client.c     if (client->buffer == NULL) {
client           1072 lib/common/ipc_client.c     header = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1077 lib/common/ipc_client.c crm_ipc_name(crm_ipc_t * client)
client           1079 lib/common/ipc_client.c     CRM_ASSERT(client != NULL);
client           1080 lib/common/ipc_client.c     return client->server_name;
client           1085 lib/common/ipc_client.c internal_ipc_get_reply(crm_ipc_t *client, int request_id, int ms_timeout,
client           1093 lib/common/ipc_client.c               client->server_name, request_id);
client           1096 lib/common/ipc_client.c         *bytes = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, 1000);
client           1100 lib/common/ipc_client.c             rc = crm_ipc_decompress(client);
client           1105 lib/common/ipc_client.c             hdr = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1110 lib/common/ipc_client.c                 xmlNode *bad = string2xml(crm_ipc_buffer(client));
client           1116 lib/common/ipc_client.c                 xmlNode *bad = string2xml(crm_ipc_buffer(client));
client           1122 lib/common/ipc_client.c         } else if (crm_ipc_connected(client) == FALSE) {
client           1124 lib/common/ipc_client.c                     client->server_name, request_id);
client           1150 lib/common/ipc_client.c crm_ipc_send(crm_ipc_t * client, xmlNode * message, enum crm_ipc_flags flags, int32_t ms_timeout,
client           1161 lib/common/ipc_client.c     if (client == NULL) {
client           1166 lib/common/ipc_client.c     } else if (crm_ipc_connected(client) == FALSE) {
client           1169 lib/common/ipc_client.c                    client->server_name);
client           1177 lib/common/ipc_client.c     if (client->need_reply) {
client           1178 lib/common/ipc_client.c         qb_rc = qb_ipcc_recv(client->ipc, client->buffer, client->buf_size, ms_timeout);
client           1181 lib/common/ipc_client.c                      client->server_name);
client           1186 lib/common/ipc_client.c                        client->server_name);
client           1187 lib/common/ipc_client.c             client->need_reply = FALSE;
client           1193 lib/common/ipc_client.c     rc = pcmk__ipc_prepare_iov(id, message, client->max_buf_size, &iov, &bytes);
client           1196 lib/common/ipc_client.c                  client->server_name, pcmk_rc_str(rc), rc);
client           1201 lib/common/ipc_client.c     pcmk__set_ipc_flags(header->flags, client->server_name, flags);
client           1209 lib/common/ipc_client.c         if(factor < 10 && (client->max_buf_size / 10) < (bytes / factor)) {
client           1213 lib/common/ipc_client.c                        factor, client->max_buf_size, 2 * client->max_buf_size);
client           1219 lib/common/ipc_client.c               client->server_name, header->qb.id, header->qb.size, ms_timeout);
client           1229 lib/common/ipc_client.c             if (!crm_ipc_connected(client)) {
client           1233 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv(client->ipc, iov, 2);
client           1242 lib/common/ipc_client.c                       client->server_name, header->qb.id);
client           1246 lib/common/ipc_client.c         rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes);
client           1254 lib/common/ipc_client.c             client->need_reply = TRUE;
client           1261 lib/common/ipc_client.c             qb_rc = qb_ipcc_sendv_recv(client->ipc, iov, 2, client->buffer,
client           1262 lib/common/ipc_client.c                                        client->buf_size, -1);
client           1263 lib/common/ipc_client.c         } while ((qb_rc == -EAGAIN) && crm_ipc_connected(client));
client           1268 lib/common/ipc_client.c         pcmk__ipc_header_t *hdr = (pcmk__ipc_header_t *)(void*)client->buffer;
client           1271 lib/common/ipc_client.c                   rc, hdr->qb.id, client->server_name, header->qb.id,
client           1272 lib/common/ipc_client.c                   crm_ipc_buffer(client));
client           1275 lib/common/ipc_client.c             *reply = string2xml(crm_ipc_buffer(client));
client           1280 lib/common/ipc_client.c                   client->server_name, header->qb.id, rc);
client           1284 lib/common/ipc_client.c     if (crm_ipc_connected(client) == FALSE) {
client           1286 lib/common/ipc_client.c                    CRM_XS " rc=%d", client->server_name, header->qb.id, rc);
client           1290 lib/common/ipc_client.c                  client->server_name, header->qb.id, pcmk_strerror(rc),
client           1296 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            749 lib/common/mainloop.c     mainloop_io_t *client = data;
client            751 lib/common/mainloop.c     CRM_ASSERT(client->fd == g_io_channel_unix_get_fd(gio));
client            754 lib/common/mainloop.c         if (client->ipc) {
client            759 lib/common/mainloop.c                 read_rc = crm_ipc_read(client->ipc);
client            762 lib/common/mainloop.c                               client->name, pcmk_strerror(read_rc), read_rc);
client            764 lib/common/mainloop.c                 } else if (client->dispatch_fn_ipc) {
client            765 lib/common/mainloop.c                     const char *buffer = crm_ipc_buffer(client->ipc);
client            769 lib/common/mainloop.c                               read_rc, client->name, (int) condition);
client            770 lib/common/mainloop.c                     if (client->dispatch_fn_ipc(buffer, read_rc, client->userdata) < 0) {
client            771 lib/common/mainloop.c                         crm_trace("Connection to %s no longer required", client->name);
client            780 lib/common/mainloop.c                       client->name, (int) condition);
client            781 lib/common/mainloop.c             if (client->dispatch_fn_io) {
client            782 lib/common/mainloop.c                 if (client->dispatch_fn_io(client->userdata) < 0) {
client            783 lib/common/mainloop.c                     crm_trace("Connection to %s no longer required", client->name);
client            790 lib/common/mainloop.c     if (client->ipc && crm_ipc_connected(client->ipc) == FALSE) {
client            792 lib/common/mainloop.c                 client->name, client, condition);
client            797 lib/common/mainloop.c                   client->name, client, condition);
client            840 lib/common/mainloop.c     mainloop_io_t *client = c;
client            841 lib/common/mainloop.c     char *c_name = strdup(client->name);
client            848 lib/common/mainloop.c     if (client->ipc) {
client            849 lib/common/mainloop.c         crm_ipc_close(client->ipc);
client            852 lib/common/mainloop.c     if (client->destroy_fn) {
client            853 lib/common/mainloop.c         void (*destroy_fn) (gpointer userdata) = client->destroy_fn;
client            855 lib/common/mainloop.c         client->destroy_fn = NULL;
client            856 lib/common/mainloop.c         destroy_fn(client->userdata);
client            859 lib/common/mainloop.c     if (client->ipc) {
client            860 lib/common/mainloop.c         crm_ipc_t *ipc = client->ipc;
client            862 lib/common/mainloop.c         client->ipc = NULL;
client            868 lib/common/mainloop.c     free(client->name); client->name = NULL;
client            869 lib/common/mainloop.c     free(client);
client            960 lib/common/mainloop.c mainloop_del_ipc_client(mainloop_io_t * client)
client            962 lib/common/mainloop.c     mainloop_del_fd(client);
client            966 lib/common/mainloop.c mainloop_get_ipc_client(mainloop_io_t * client)
client            968 lib/common/mainloop.c     if (client) {
client            969 lib/common/mainloop.c         return client->ipc;
client            978 lib/common/mainloop.c     mainloop_io_t *client = NULL;
client            981 lib/common/mainloop.c         client = calloc(1, sizeof(mainloop_io_t));
client            982 lib/common/mainloop.c         if (client == NULL) {
client            985 lib/common/mainloop.c         client->name = strdup(name);
client            986 lib/common/mainloop.c         client->userdata = userdata;
client            989 lib/common/mainloop.c             client->destroy_fn = callbacks->destroy;
client            990 lib/common/mainloop.c             client->dispatch_fn_io = callbacks->dispatch;
client            993 lib/common/mainloop.c         client->fd = fd;
client            994 lib/common/mainloop.c         client->channel = g_io_channel_unix_new(fd);
client            995 lib/common/mainloop.c         client->source =
client            996 lib/common/mainloop.c             g_io_add_watch_full(client->channel, priority,
client            998 lib/common/mainloop.c                                 client, mainloop_gio_destroy);
client           1009 lib/common/mainloop.c         g_io_channel_unref(client->channel);
client           1010 lib/common/mainloop.c         crm_trace("Added connection %d for %s[%p].%d", client->source, client->name, client, fd);
client           1015 lib/common/mainloop.c     return client;
client           1019 lib/common/mainloop.c mainloop_del_fd(mainloop_io_t * client)
client           1021 lib/common/mainloop.c     if (client != NULL) {
client           1022 lib/common/mainloop.c         crm_trace("Removing client %s[%p]", client->name, client);
client           1023 lib/common/mainloop.c         if (client->source) {
client           1027 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           1202 lib/fencing/st_client.c             kvp->client = crm_element_value_copy(op, F_STONITH_CLIENTNAME);
client           1232 lib/fencing/st_client.c         free(hp->client);
client            255 lib/fencing/st_output.c                            event->client, event->origin,
client            269 lib/fencing/st_output.c                            event->client, event->origin,
client            281 lib/fencing/st_output.c                            event->client, event->origin);
client            302 lib/fencing/st_output.c                                   event->client, event->origin,
client            311 lib/fencing/st_output.c                                   event->client, event->origin,
client            318 lib/fencing/st_output.c                                   event->client, event->origin);
client            338 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            469 tools/crm_mon_curses.c                                    event->client, event->origin,
client            478 tools/crm_mon_curses.c                                    event->client, event->origin,
client            485 tools/crm_mon_curses.c                                    event->client, event->origin);