c 104 daemons/attrd/attrd_utils.c attrd_ipc_accept(qb_ipcs_connection_t *c, uid_t uid, gid_t gid) c 106 daemons/attrd/attrd_utils.c crm_trace("New client connection %p", c); c 109 daemons/attrd/attrd_utils.c pcmk__client_pid(c)); c 113 daemons/attrd/attrd_utils.c if (pcmk__new_client(c, uid, gid) == NULL) { c 128 daemons/attrd/attrd_utils.c attrd_ipc_closed(qb_ipcs_connection_t *c) c 130 daemons/attrd/attrd_utils.c pcmk__client_t *client = pcmk__find_client(c); c 133 daemons/attrd/attrd_utils.c crm_trace("Ignoring request to clean up unknown connection %p", c); c 135 daemons/attrd/attrd_utils.c crm_trace("Cleaning up closed client connection %p", c); c 151 daemons/attrd/attrd_utils.c attrd_ipc_destroy(qb_ipcs_connection_t *c) c 153 daemons/attrd/attrd_utils.c crm_trace("Destroying client connection %p", c); c 154 daemons/attrd/attrd_utils.c attrd_ipc_closed(c); c 223 daemons/attrd/pacemaker-attrd.c attrd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) c 227 daemons/attrd/pacemaker-attrd.c pcmk__client_t *client = pcmk__find_client(c); c 232 daemons/attrd/pacemaker-attrd.c CRM_CHECK((c != NULL) && (client != NULL), return 0); c 234 daemons/attrd/pacemaker-attrd.c crm_debug("No IPC data from PID %d", pcmk__client_pid(c)); c 239 daemons/attrd/pacemaker-attrd.c crm_debug("Unrecognizable IPC data from PID %d", pcmk__client_pid(c)); c 60 daemons/based/based_callbacks.c gboolean cib_common_callback(qb_ipcs_connection_t * c, void *data, size_t size, c 70 daemons/based/based_callbacks.c cib_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 74 daemons/based/based_callbacks.c pcmk__client_pid(c)); c 78 daemons/based/based_callbacks.c if (pcmk__new_client(c, uid, gid) == NULL) { c 85 daemons/based/based_callbacks.c cib_ipc_dispatch_rw(qb_ipcs_connection_t * c, void *data, size_t size) c 87 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); c 89 daemons/based/based_callbacks.c crm_trace("%p message from %s", c, client->id); c 90 daemons/based/based_callbacks.c return cib_common_callback(c, data, size, TRUE); c 94 daemons/based/based_callbacks.c cib_ipc_dispatch_ro(qb_ipcs_connection_t * c, void *data, size_t size) c 96 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); c 98 daemons/based/based_callbacks.c crm_trace("%p message from %s", c, client->id); c 99 daemons/based/based_callbacks.c return cib_common_callback(c, data, size, FALSE); c 104 daemons/based/based_callbacks.c cib_ipc_closed(qb_ipcs_connection_t * c) c 106 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); c 111 daemons/based/based_callbacks.c crm_trace("Connection %p", c); c 117 daemons/based/based_callbacks.c cib_ipc_destroy(qb_ipcs_connection_t * c) c 119 daemons/based/based_callbacks.c crm_trace("Connection %p", c); c 120 daemons/based/based_callbacks.c cib_ipc_closed(c); c 207 daemons/based/based_callbacks.c cib_common_callback(qb_ipcs_connection_t * c, void *data, size_t size, gboolean privileged) c 212 daemons/based/based_callbacks.c pcmk__client_t *cib_client = pcmk__find_client(c); c 220 daemons/based/based_callbacks.c crm_trace("Invalid message from %p", c); c 225 daemons/based/based_callbacks.c crm_trace("Invalid client %p", c); c 1436 daemons/based/based_callbacks.c qb_ipcs_connection_t *c = NULL; c 1440 daemons/based/based_callbacks.c c = qb_ipcs_connection_first_get(ipcs_rw); c 1441 daemons/based/based_callbacks.c while (c != NULL) { c 1442 daemons/based/based_callbacks.c qb_ipcs_connection_t *last = c; c 1444 daemons/based/based_callbacks.c c = qb_ipcs_connection_next_get(ipcs_rw, last); c 1452 daemons/based/based_callbacks.c c = qb_ipcs_connection_first_get(ipcs_ro); c 1453 daemons/based/based_callbacks.c while (c != NULL) { c 1454 daemons/based/based_callbacks.c qb_ipcs_connection_t *last = c; c 1456 daemons/based/based_callbacks.c c = qb_ipcs_connection_next_get(ipcs_ro, last); c 1464 daemons/based/based_callbacks.c c = qb_ipcs_connection_first_get(ipcs_shm); c 1465 daemons/based/based_callbacks.c while (c != NULL) { c 1466 daemons/based/based_callbacks.c qb_ipcs_connection_t *last = c; c 1468 daemons/based/based_callbacks.c c = qb_ipcs_connection_next_get(ipcs_shm, last); c 362 daemons/controld/controld_control.c accept_controller_client(qb_ipcs_connection_t *c, uid_t uid, gid_t gid) c 365 daemons/controld/controld_control.c if (pcmk__new_client(c, uid, gid) == NULL) { c 373 daemons/controld/controld_control.c dispatch_controller_ipc(qb_ipcs_connection_t * c, void *data, size_t size) c 377 daemons/controld/controld_control.c pcmk__client_t *client = pcmk__find_client(c); c 404 daemons/controld/controld_control.c crmd_ipc_closed(qb_ipcs_connection_t * c) c 406 daemons/controld/controld_control.c pcmk__client_t *client = pcmk__find_client(c); c 411 daemons/controld/controld_control.c c, client); c 420 daemons/controld/controld_control.c crmd_ipc_destroy(qb_ipcs_connection_t * c) c 422 daemons/controld/controld_control.c crm_trace("Connection %p", c); c 423 daemons/controld/controld_control.c crmd_ipc_closed(c); c 86 daemons/execd/pacemaker-execd.c lrmd_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 88 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 89 daemons/execd/pacemaker-execd.c if (pcmk__new_client(c, uid, gid) == NULL) { c 96 daemons/execd/pacemaker-execd.c lrmd_ipc_created(qb_ipcs_connection_t * c) c 98 daemons/execd/pacemaker-execd.c pcmk__client_t *new_client = pcmk__find_client(c); c 100 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 109 daemons/execd/pacemaker-execd.c lrmd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) c 113 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); c 132 daemons/execd/pacemaker-execd.c client->name = crm_itoa(pcmk__client_pid(c)); c 175 daemons/execd/pacemaker-execd.c lrmd_ipc_closed(qb_ipcs_connection_t * c) c 177 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); c 183 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 193 daemons/execd/pacemaker-execd.c lrmd_ipc_destroy(qb_ipcs_connection_t * c) c 195 daemons/execd/pacemaker-execd.c lrmd_ipc_closed(c); c 196 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 66 daemons/execd/remoted_proxy.c ipc_proxy_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid, const char *ipc_channel) c 81 daemons/execd/remoted_proxy.c client = pcmk__new_client(c, uid, gid); c 111 daemons/execd/remoted_proxy.c crmd_proxy_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 113 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, CRM_SYSTEM_CRMD); c 117 daemons/execd/remoted_proxy.c attrd_proxy_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 119 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, T_ATTRD); c 123 daemons/execd/remoted_proxy.c stonith_proxy_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 125 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, "stonith-ng"); c 129 daemons/execd/remoted_proxy.c cib_proxy_accept_rw(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 131 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, PCMK__SERVER_BASED_RW); c 135 daemons/execd/remoted_proxy.c cib_proxy_accept_ro(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 137 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, PCMK__SERVER_BASED_RO); c 215 daemons/execd/remoted_proxy.c ipc_proxy_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) c 219 daemons/execd/remoted_proxy.c pcmk__client_t *client = pcmk__find_client(c); c 299 daemons/execd/remoted_proxy.c ipc_proxy_closed(qb_ipcs_connection_t * c) c 301 daemons/execd/remoted_proxy.c pcmk__client_t *client = pcmk__find_client(c); c 310 daemons/execd/remoted_proxy.c crm_trace("Connection %p", c); c 329 daemons/execd/remoted_proxy.c ipc_proxy_destroy(qb_ipcs_connection_t * c) c 331 daemons/execd/remoted_proxy.c crm_trace("Connection %p", c); c 332 daemons/execd/remoted_proxy.c ipc_proxy_closed(c); c 63 daemons/fenced/pacemaker-fenced.c st_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 67 daemons/fenced/pacemaker-fenced.c pcmk__client_pid(c)); c 71 daemons/fenced/pacemaker-fenced.c if (pcmk__new_client(c, uid, gid) == NULL) { c 85 daemons/fenced/pacemaker-fenced.c pcmk__client_t *c = pcmk__find_client(qbc); c 88 daemons/fenced/pacemaker-fenced.c if (c == NULL) { c 93 daemons/fenced/pacemaker-fenced.c request = pcmk__client_data2xml(c, data, &id, &flags); c 95 daemons/fenced/pacemaker-fenced.c pcmk__ipc_send_ack(c, id, flags, "nack", CRM_EX_PROTOCOL); c 104 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTID, c->id); c 105 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTNAME, pcmk__client_name(c)); c 113 daemons/fenced/pacemaker-fenced.c if (c->name == NULL) { c 119 daemons/fenced/pacemaker-fenced.c c->name = crm_strdup_printf("%s.%u", value, c->pid); c 124 daemons/fenced/pacemaker-fenced.c flags, call_options, id, pcmk__client_name(c)); c 128 daemons/fenced/pacemaker-fenced.c CRM_LOG_ASSERT(c->request_id == 0); /* This means the client has two synchronous events in-flight */ c 129 daemons/fenced/pacemaker-fenced.c c->request_id = id; /* Reply only to the last one */ c 132 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTID, c->id); c 133 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTNAME, pcmk__client_name(c)); c 136 daemons/fenced/pacemaker-fenced.c stonith_command(c, id, flags, request, NULL); c 144 daemons/fenced/pacemaker-fenced.c st_ipc_closed(qb_ipcs_connection_t * c) c 146 daemons/fenced/pacemaker-fenced.c pcmk__client_t *client = pcmk__find_client(c); c 152 daemons/fenced/pacemaker-fenced.c crm_trace("Connection %p closed", c); c 160 daemons/fenced/pacemaker-fenced.c st_ipc_destroy(qb_ipcs_connection_t * c) c 162 daemons/fenced/pacemaker-fenced.c crm_trace("Connection %p destroyed", c); c 163 daemons/fenced/pacemaker-fenced.c st_ipc_closed(c); c 506 daemons/pacemakerd/pacemakerd.c pcmk_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 508 daemons/pacemakerd/pacemakerd.c crm_trace("Connection %p", c); c 509 daemons/pacemakerd/pacemakerd.c if (pcmk__new_client(c, uid, gid) == NULL) { c 516 daemons/pacemakerd/pacemakerd.c pcmk_handle_ping_request(pcmk__client_t *c, xmlNode *msg, uint32_t id) c 537 daemons/pacemakerd/pacemakerd.c if (pcmk__ipc_send_xml(c, id, reply, crm_ipc_server_event) != c 551 daemons/pacemakerd/pacemakerd.c shutdown_complete_state_reported_to = c->pid; c 568 daemons/pacemakerd/pacemakerd.c pcmk__client_t *c = pcmk__find_client(qbc); c 570 daemons/pacemakerd/pacemakerd.c CRM_CHECK(c != NULL, return 0); c 572 daemons/pacemakerd/pacemakerd.c msg = pcmk__client_data2xml(c, data, &id, &flags); c 574 daemons/pacemakerd/pacemakerd.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_PROTOCOL); c 587 daemons/pacemakerd/pacemakerd.c bool allowed = pcmk_is_set(c->flags, pcmk__client_privileged); c 595 daemons/pacemakerd/pacemakerd.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_OK); c 599 daemons/pacemakerd/pacemakerd.c pcmk__client_name(c)); c 600 daemons/pacemakerd/pacemakerd.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_INSUFFICIENT_PRIV); c 606 daemons/pacemakerd/pacemakerd.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_OK); c 609 daemons/pacemakerd/pacemakerd.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_INDETERMINATE); c 610 daemons/pacemakerd/pacemakerd.c pcmk_handle_ping_request(c, msg, id); c 615 daemons/pacemakerd/pacemakerd.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_INVALID_PARAM); c 624 daemons/pacemakerd/pacemakerd.c pcmk_ipc_closed(qb_ipcs_connection_t * c) c 626 daemons/pacemakerd/pacemakerd.c pcmk__client_t *client = pcmk__find_client(c); c 631 daemons/pacemakerd/pacemakerd.c crm_trace("Connection %p", c); c 643 daemons/pacemakerd/pacemakerd.c pcmk_ipc_destroy(qb_ipcs_connection_t * c) c 645 daemons/pacemakerd/pacemakerd.c crm_trace("Connection %p", c); c 646 daemons/pacemakerd/pacemakerd.c pcmk_ipc_closed(c); c 209 daemons/schedulerd/pacemaker-schedulerd.c pe_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 211 daemons/schedulerd/pacemaker-schedulerd.c crm_trace("Connection %p", c); c 212 daemons/schedulerd/pacemaker-schedulerd.c if (pcmk__new_client(c, uid, gid) == NULL) { c 226 daemons/schedulerd/pacemaker-schedulerd.c pcmk__client_t *c = pcmk__find_client(qbc); c 227 daemons/schedulerd/pacemaker-schedulerd.c xmlNode *msg = pcmk__client_data2xml(c, data, &id, &flags); c 229 daemons/schedulerd/pacemaker-schedulerd.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_INDETERMINATE); c 233 daemons/schedulerd/pacemaker-schedulerd.c process_pe_message(msg, data_xml, c); c 241 daemons/schedulerd/pacemaker-schedulerd.c pe_ipc_closed(qb_ipcs_connection_t * c) c 243 daemons/schedulerd/pacemaker-schedulerd.c pcmk__client_t *client = pcmk__find_client(c); c 248 daemons/schedulerd/pacemaker-schedulerd.c crm_trace("Connection %p", c); c 254 daemons/schedulerd/pacemaker-schedulerd.c pe_ipc_destroy(qb_ipcs_connection_t * c) c 256 daemons/schedulerd/pacemaker-schedulerd.c crm_trace("Connection %p", c); c 257 daemons/schedulerd/pacemaker-schedulerd.c pe_ipc_closed(c); c 27 devel/coccinelle/test/ref-passed-variables-inited.input.c int a = 1, b, c = 3; c 32 devel/coccinelle/test/ref-passed-variables-inited.input.c foo(&c); c 33 devel/coccinelle/test/ref-passed-variables-inited.input.c baz(c); c 195 include/crm/common/ipc_internal.h pcmk__client_t *pcmk__find_client(qb_ipcs_connection_t *c); c 197 include/crm/common/ipc_internal.h const char *pcmk__client_name(pcmk__client_t *c); c 201 include/crm/common/ipc_internal.h pcmk__client_t *pcmk__new_client(qb_ipcs_connection_t *c, uid_t uid, gid_t gid); c 202 include/crm/common/ipc_internal.h void pcmk__free_client(pcmk__client_t *c); c 206 include/crm/common/ipc_internal.h int pcmk__ipc_send_ack_as(const char *function, int line, pcmk__client_t *c, c 209 include/crm/common/ipc_internal.h #define pcmk__ipc_send_ack(c, req, flags, tag, st) \ c 210 include/crm/common/ipc_internal.h pcmk__ipc_send_ack_as(__func__, __LINE__, (c), (req), (flags), (tag), (st)) c 215 include/crm/common/ipc_internal.h int pcmk__ipc_send_xml(pcmk__client_t *c, uint32_t request, xmlNode *message, c 217 include/crm/common/ipc_internal.h int pcmk__ipc_send_iov(pcmk__client_t *c, struct iovec *iov, uint32_t flags); c 218 include/crm/common/ipc_internal.h xmlNode *pcmk__client_data2xml(pcmk__client_t *c, void *data, c 221 include/crm/common/ipc_internal.h int pcmk__client_pid(qb_ipcs_connection_t *c); c 405 lib/cib/cib_utils.c xmlNode * c = copy_xml(current_cib); c 408 lib/cib/cib_utils.c test_rc = xml_apply_patchset(c, local_diff, manage_counters); c 411 lib/cib/cib_utils.c save_xml_to_file(c, "PatchApply:calculated", NULL); c 417 lib/cib/cib_utils.c free_xml(c); c 746 lib/cluster/membership.c for (const char *c = uname; *c; ++c) { c 747 lib/cluster/membership.c if ((*c >= 'A') && (*c <= 'Z')) { c 86 lib/common/crmcommon_private.h void pcmk__buffer_add_char(char **buffer, int *offset, int *max, char c); c 1365 lib/common/ipc_client.c qb_ipcc_connection_t *c; c 1367 lib/common/ipc_client.c c = qb_ipcc_connect(name, 0); c 1368 lib/common/ipc_client.c if (c == NULL) { c 1374 lib/common/ipc_client.c qb_rc = qb_ipcc_fd_get(c, &fd); c 1423 lib/common/ipc_client.c if (c != NULL) { c 1424 lib/common/ipc_client.c qb_ipcc_disconnect(c); c 59 lib/common/ipc_server.c pcmk__find_client(qb_ipcs_connection_t *c) c 62 lib/common/ipc_server.c return g_hash_table_lookup(client_connections, c); c 65 lib/common/ipc_server.c crm_trace("No client found for %p", c); c 90 lib/common/ipc_server.c pcmk__client_name(pcmk__client_t *c) c 92 lib/common/ipc_server.c if (c == NULL) { c 94 lib/common/ipc_server.c } else if (c->name == NULL && c->id == NULL) { c 96 lib/common/ipc_server.c } else if (c->name == NULL) { c 97 lib/common/ipc_server.c return c->id; c 99 lib/common/ipc_server.c return c->name; c 120 lib/common/ipc_server.c qb_ipcs_connection_t *c = NULL; c 126 lib/common/ipc_server.c c = qb_ipcs_connection_first_get(service); c 128 lib/common/ipc_server.c while (c != NULL) { c 129 lib/common/ipc_server.c qb_ipcs_connection_t *last = c; c 131 lib/common/ipc_server.c c = qb_ipcs_connection_next_get(service, last); c 152 lib/common/ipc_server.c client_from_connection(qb_ipcs_connection_t *c, void *key, uid_t uid_client) c 161 lib/common/ipc_server.c if (c) { c 171 lib/common/ipc_server.c client->ipcs = c; c 173 lib/common/ipc_server.c client->pid = pcmk__client_pid(c); c 175 lib/common/ipc_server.c key = c; c 214 lib/common/ipc_server.c pcmk__new_client(qb_ipcs_connection_t *c, uid_t uid_client, gid_t gid_client) c 221 lib/common/ipc_server.c CRM_CHECK(c != NULL, return NULL); c 236 lib/common/ipc_server.c qb_ipcs_connection_auth_set(c, -1, gid_cluster, S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP); c 240 lib/common/ipc_server.c client = client_from_connection(c, NULL, uid_client); c 286 lib/common/ipc_server.c add_event(pcmk__client_t *c, struct iovec *iov) c 288 lib/common/ipc_server.c if (c->event_queue == NULL) { c 289 lib/common/ipc_server.c c->event_queue = g_queue_new(); c 291 lib/common/ipc_server.c g_queue_push_tail(c->event_queue, iov); c 295 lib/common/ipc_server.c pcmk__free_client(pcmk__client_t *c) c 297 lib/common/ipc_server.c if (c == NULL) { c 302 lib/common/ipc_server.c if (c->ipcs) { c 304 lib/common/ipc_server.c c, c->ipcs, g_hash_table_size(client_connections) - 1); c 305 lib/common/ipc_server.c g_hash_table_remove(client_connections, c->ipcs); c 309 lib/common/ipc_server.c c, g_hash_table_size(client_connections) - 1); c 310 lib/common/ipc_server.c g_hash_table_remove(client_connections, c->id); c 314 lib/common/ipc_server.c if (c->event_timer) { c 315 lib/common/ipc_server.c g_source_remove(c->event_timer); c 318 lib/common/ipc_server.c if (c->event_queue) { c 319 lib/common/ipc_server.c crm_debug("Destroying %d events", g_queue_get_length(c->event_queue)); c 320 lib/common/ipc_server.c g_queue_free_full(c->event_queue, free_event); c 323 lib/common/ipc_server.c free(c->id); c 324 lib/common/ipc_server.c free(c->name); c 325 lib/common/ipc_server.c free(c->user); c 326 lib/common/ipc_server.c if (c->remote) { c 327 lib/common/ipc_server.c if (c->remote->auth_timeout) { c 328 lib/common/ipc_server.c g_source_remove(c->remote->auth_timeout); c 330 lib/common/ipc_server.c free(c->remote->buffer); c 331 lib/common/ipc_server.c free(c->remote); c 333 lib/common/ipc_server.c free(c); c 362 lib/common/ipc_server.c pcmk__client_pid(qb_ipcs_connection_t *c) c 367 lib/common/ipc_server.c qb_ipcs_connection_stats_get(c, &stats, 0); c 383 lib/common/ipc_server.c pcmk__client_data2xml(pcmk__client_t *c, void *data, uint32_t *id, c 407 lib/common/ipc_server.c pcmk__set_client_flags(c, pcmk__client_proxied); c 438 lib/common/ipc_server.c static int crm_ipcs_flush_events(pcmk__client_t *c); c 443 lib/common/ipc_server.c pcmk__client_t *c = data; c 445 lib/common/ipc_server.c c->event_timer = 0; c 446 lib/common/ipc_server.c crm_ipcs_flush_events(c); c 458 lib/common/ipc_server.c delay_next_flush(pcmk__client_t *c, unsigned int queue_len) c 463 lib/common/ipc_server.c c->event_timer = g_timeout_add(delay, crm_ipcs_flush_events_cb, c); c 475 lib/common/ipc_server.c crm_ipcs_flush_events(pcmk__client_t *c) c 482 lib/common/ipc_server.c if (c == NULL) { c 485 lib/common/ipc_server.c } else if (c->event_timer) { c 487 lib/common/ipc_server.c crm_trace("Timer active for %p - %d", c->ipcs, c->event_timer); c 491 lib/common/ipc_server.c if (c->event_queue) { c 492 lib/common/ipc_server.c queue_len = g_queue_get_length(c->event_queue); c 498 lib/common/ipc_server.c if (c->event_queue) { c 500 lib/common/ipc_server.c event = g_queue_peek_head(c->event_queue); c 506 lib/common/ipc_server.c qb_rc = qb_ipcs_event_sendv(c->ipcs, event, 2); c 511 lib/common/ipc_server.c event = g_queue_pop_head(c->event_queue); c 517 lib/common/ipc_server.c header->qb.id, c->ipcs, c->pid, (long long) qb_rc); c 520 lib/common/ipc_server.c header->qb.id, c->ipcs, c->pid, (long long) qb_rc, c 529 lib/common/ipc_server.c sent, queue_len, c->ipcs, c->pid, c 539 lib/common/ipc_server.c if (queue_len > QB_MAX(c->queue_max, PCMK_IPC_DEFAULT_QUEUE_MAX)) { c 540 lib/common/ipc_server.c if ((c->queue_backlog <= 1) || (queue_len < c->queue_backlog)) { c 543 lib/common/ipc_server.c CRM_XS " %p", c->pid, queue_len, c->ipcs); c 546 lib/common/ipc_server.c CRM_XS " %p", c->pid, queue_len, c->ipcs); c 547 lib/common/ipc_server.c c->queue_backlog = 0; c 548 lib/common/ipc_server.c qb_ipcs_disconnect(c->ipcs); c 553 lib/common/ipc_server.c c->queue_backlog = queue_len; c 554 lib/common/ipc_server.c delay_next_flush(c, queue_len); c 558 lib/common/ipc_server.c c->queue_backlog = 0; c 662 lib/common/ipc_server.c pcmk__ipc_send_iov(pcmk__client_t *c, struct iovec *iov, uint32_t flags) c 668 lib/common/ipc_server.c if (c->flags & pcmk__client_proxied) { c 685 lib/common/ipc_server.c crm_trace("Sending the original to %p[%d]", c->ipcs, c->pid); c 686 lib/common/ipc_server.c add_event(c, iov); c 691 lib/common/ipc_server.c crm_trace("Sending a copy to %p[%d]", c->ipcs, c->pid); c 700 lib/common/ipc_server.c add_event(c, iov_copy); c 708 lib/common/ipc_server.c qb_rc = qb_ipcs_response_sendv(c->ipcs, iov, 2); c 715 lib/common/ipc_server.c header->qb.id, c->pid, pcmk_rc_str(rc), c 716 lib/common/ipc_server.c header->qb.size, (long long) qb_rc, c->ipcs); c 720 lib/common/ipc_server.c header->qb.id, (long long) qb_rc, c->ipcs, c->pid); c 729 lib/common/ipc_server.c rc = crm_ipcs_flush_events(c); c 731 lib/common/ipc_server.c crm_ipcs_flush_events(c); c 735 lib/common/ipc_server.c crm_trace("Client %p disconnected", c->ipcs); c 741 lib/common/ipc_server.c pcmk__ipc_send_xml(pcmk__client_t *c, uint32_t request, xmlNode *message, c 747 lib/common/ipc_server.c if (c == NULL) { c 754 lib/common/ipc_server.c rc = pcmk__ipc_send_iov(c, iov, flags); c 758 lib/common/ipc_server.c c->pid, pcmk_rc_str(rc), rc); c 779 lib/common/ipc_server.c pcmk__ipc_send_ack_as(const char *function, int line, pcmk__client_t *c, c 789 lib/common/ipc_server.c pcmk__client_name(c), tag, status); c 790 lib/common/ipc_server.c c->request_id = 0; c 794 lib/common/ipc_server.c rc = pcmk__ipc_send_xml(c, request, ack, flags); c 801 lib/common/mainloop.c mainloop_gio_destroy(gpointer c) c 803 lib/common/mainloop.c mainloop_io_t *client = c; c 809 lib/common/mainloop.c crm_trace("Destroying client %s[%p]", c_name, c); c 829 lib/common/mainloop.c crm_trace("Destroyed client %s[%p]", c_name, c); c 319 lib/common/md5.c #define FF(b, c, d) (d ^ (b & (c ^ d))) c 320 lib/common/md5.c #define FG(b, c, d) FF (d, b, c) c 321 lib/common/md5.c #define FH(b, c, d) (b ^ c ^ d) c 322 lib/common/md5.c #define FI(b, c, d) (c ^ (b | ~d)) c 363 lib/common/md5.c #define OP(a, b, c, d, s, T) \ c 366 lib/common/md5.c a += FF (b, c, d) + (*cwp++ = SWAP (*words)) + T; \ c 409 lib/common/md5.c #define OP(f, a, b, c, d, k, s, T) \ c 412 lib/common/md5.c a += f (b, c, d) + correct_words[k] + T; \ c 480 lib/common/xml.c #define attr_matches(c, n, v) pcmk__str_eq(crm_element_value((c), (n)), \ c 1104 lib/common/xml.c char *c; c 1106 lib/common/xml.c for (c = id; *c; ++c) { c 1108 lib/common/xml.c switch (*c) { c 1111 lib/common/xml.c *c = '.'; c 1971 lib/common/xml.c pcmk__buffer_add_char(char **buffer, int *offset, int *max, char c) c 1973 lib/common/xml.c buffer_print(*buffer, *max, *offset, "%c", c); c 319 lib/gnu/md5.c #define FF(b, c, d) (d ^ (b & (c ^ d))) c 320 lib/gnu/md5.c #define FG(b, c, d) FF (d, b, c) c 321 lib/gnu/md5.c #define FH(b, c, d) (b ^ c ^ d) c 322 lib/gnu/md5.c #define FI(b, c, d) (c ^ (b | ~d)) c 363 lib/gnu/md5.c #define OP(a, b, c, d, s, T) \ c 366 lib/gnu/md5.c a += FF (b, c, d) + (*cwp++ = SWAP (*words)) + T; \ c 409 lib/gnu/md5.c #define OP(f, a, b, c, d, k, s, T) \ c 412 lib/gnu/md5.c a += f (b, c, d) + correct_words[k] + T; \ c 162 libltdl/libltdl/lt_system.h # define LT__CONC3(a, b, c) a##b##c c 163 libltdl/libltdl/lt_system.h # define LT_CONC3(a, b, c) LT__CONC3(a, b, c) c 44 maint/mocked/based.c mock_based_ipc_accept(qb_ipcs_connection_t *c, uid_t uid, gid_t gid) c 49 maint/mocked/based.c crm_trace("Connection %p", c); c 50 maint/mocked/based.c cib_client = pcmk__new_client(c, uid, gid); c 62 maint/mocked/based.c mock_based_ipc_closed(qb_ipcs_connection_t *c) c 64 maint/mocked/based.c pcmk__client_t *client = pcmk__find_client(c); c 67 maint/mocked/based.c crm_trace("Connection %p", c); c 76 maint/mocked/based.c mock_based_ipc_destroy(qb_ipcs_connection_t *c) c 78 maint/mocked/based.c crm_trace("Connection %p", c); c 79 maint/mocked/based.c mock_based_ipc_closed(c); c 160 maint/mocked/based.c for (size_t c = ctxt->modules_cnt; c > 0; c--) { c 161 maint/mocked/based.c if (ctxt->modules[c - 1]->hooks.cib_notify != NULL) { c 162 maint/mocked/based.c ctxt->modules[c - 1]->hooks.cib_notify(cib_client); c 180 maint/mocked/based.c mock_based_dispatch_command(qb_ipcs_connection_t *c, void *data, size_t size) c 184 maint/mocked/based.c pcmk__client_t *cib_client = pcmk__find_client(c); c 187 maint/mocked/based.c crm_notice("Got connection %p", c); c 192 maint/mocked/based.c crm_trace("Invalid message from %p", c); c 268 maint/mocked/based.c for (size_t c = ctxt->modules_cnt; c > 0; c--) { c 269 maint/mocked/based.c args2argv[c] = (char[]){'-', ctxt->modules[c - 1]->shortopt, '\0'}; c 271 maint/mocked/based.c s[(ctxt->modules_cnt - i) + 2] = ctxt->modules[c - 1]->shortopt; c 281 maint/mocked/based.c for (size_t c = ctxt->modules_cnt; c > 0; c--) { c 282 maint/mocked/based.c if (ctxt->modules[c - 1]->shortopt == argv[i][1]) { c 283 maint/mocked/based.c ret = ctxt->modules[c - 1]->hooks.argparse(ctxt, usage, argc - i, &argv[i]); c 322 maint/mocked/based.c for (size_t c = ctxt->modules_cnt; c > 0; c--) { c 323 maint/mocked/based.c if (ctxt->modules[c - 1]->hooks.destroy != NULL) { c 324 maint/mocked/based.c ctxt->modules[c - 1]->hooks.destroy(ctxt->modules[c - 1]); c 326 maint/mocked/based.c free(mock_based_context.modules[c - 1]); c 9 replace/strchrnul.c char c = c_in; c 11 replace/strchrnul.c while (*s && (*s != c)) c 863 tools/crm_mon.c get_option_desc(char c) c 868 tools/crm_mon.c if (entry->short_name == c) { c 882 tools/crm_mon.c int c; c 888 tools/crm_mon.c c = getchar(); c 890 tools/crm_mon.c switch (c) {