c 137 daemons/attrd/attrd_utils.c attrd_ipc_accept(qb_ipcs_connection_t *c, uid_t uid, gid_t gid) c 139 daemons/attrd/attrd_utils.c crm_trace("New client connection %p", c); c 142 daemons/attrd/attrd_utils.c pcmk__client_pid(c)); c 146 daemons/attrd/attrd_utils.c if (pcmk__new_client(c, uid, gid) == NULL) { c 161 daemons/attrd/attrd_utils.c attrd_ipc_closed(qb_ipcs_connection_t *c) c 163 daemons/attrd/attrd_utils.c pcmk__client_t *client = pcmk__find_client(c); c 166 daemons/attrd/attrd_utils.c crm_trace("Ignoring request to clean up unknown connection %p", c); c 168 daemons/attrd/attrd_utils.c crm_trace("Cleaning up closed client connection %p", c); c 184 daemons/attrd/attrd_utils.c attrd_ipc_destroy(qb_ipcs_connection_t *c) c 186 daemons/attrd/attrd_utils.c crm_trace("Destroying client connection %p", c); c 187 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 1454 daemons/based/based_callbacks.c qb_ipcs_connection_t *c = NULL; c 1458 daemons/based/based_callbacks.c c = qb_ipcs_connection_first_get(ipcs_rw); c 1459 daemons/based/based_callbacks.c while (c != NULL) { c 1460 daemons/based/based_callbacks.c qb_ipcs_connection_t *last = c; c 1462 daemons/based/based_callbacks.c c = qb_ipcs_connection_next_get(ipcs_rw, last); c 1470 daemons/based/based_callbacks.c c = qb_ipcs_connection_first_get(ipcs_ro); c 1471 daemons/based/based_callbacks.c while (c != NULL) { c 1472 daemons/based/based_callbacks.c qb_ipcs_connection_t *last = c; c 1474 daemons/based/based_callbacks.c c = qb_ipcs_connection_next_get(ipcs_ro, last); c 1482 daemons/based/based_callbacks.c c = qb_ipcs_connection_first_get(ipcs_shm); c 1483 daemons/based/based_callbacks.c while (c != NULL) { c 1484 daemons/based/based_callbacks.c qb_ipcs_connection_t *last = c; c 1486 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 403 daemons/controld/controld_control.c crmd_ipc_closed(qb_ipcs_connection_t * c) c 405 daemons/controld/controld_control.c pcmk__client_t *client = pcmk__find_client(c); c 410 daemons/controld/controld_control.c c, client); c 419 daemons/controld/controld_control.c crmd_ipc_destroy(qb_ipcs_connection_t * c) c 421 daemons/controld/controld_control.c crm_trace("Connection %p", c); c 422 daemons/controld/controld_control.c crmd_ipc_closed(c); c 82 daemons/execd/pacemaker-execd.c lrmd_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 84 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 85 daemons/execd/pacemaker-execd.c if (pcmk__new_client(c, uid, gid) == NULL) { c 92 daemons/execd/pacemaker-execd.c lrmd_ipc_created(qb_ipcs_connection_t * c) c 94 daemons/execd/pacemaker-execd.c pcmk__client_t *new_client = pcmk__find_client(c); c 96 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 105 daemons/execd/pacemaker-execd.c lrmd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) c 109 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); c 128 daemons/execd/pacemaker-execd.c client->name = pcmk__itoa(pcmk__client_pid(c)); c 171 daemons/execd/pacemaker-execd.c lrmd_ipc_closed(qb_ipcs_connection_t * c) c 173 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); c 179 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 189 daemons/execd/pacemaker-execd.c lrmd_ipc_destroy(qb_ipcs_connection_t * c) c 191 daemons/execd/pacemaker-execd.c lrmd_ipc_closed(c); c 192 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 67 daemons/execd/remoted_proxy.c ipc_proxy_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid, const char *ipc_channel) c 82 daemons/execd/remoted_proxy.c client = pcmk__new_client(c, uid, gid); c 112 daemons/execd/remoted_proxy.c crmd_proxy_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 114 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, CRM_SYSTEM_CRMD); c 118 daemons/execd/remoted_proxy.c attrd_proxy_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 120 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, T_ATTRD); c 124 daemons/execd/remoted_proxy.c stonith_proxy_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 126 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, "stonith-ng"); c 130 daemons/execd/remoted_proxy.c pacemakerd_proxy_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 136 daemons/execd/remoted_proxy.c cib_proxy_accept_rw(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 138 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, PCMK__SERVER_BASED_RW); c 142 daemons/execd/remoted_proxy.c cib_proxy_accept_ro(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 144 daemons/execd/remoted_proxy.c return ipc_proxy_accept(c, uid, gid, PCMK__SERVER_BASED_RO); c 222 daemons/execd/remoted_proxy.c ipc_proxy_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) c 226 daemons/execd/remoted_proxy.c pcmk__client_t *client = pcmk__find_client(c); c 306 daemons/execd/remoted_proxy.c ipc_proxy_closed(qb_ipcs_connection_t * c) c 308 daemons/execd/remoted_proxy.c pcmk__client_t *client = pcmk__find_client(c); c 317 daemons/execd/remoted_proxy.c crm_trace("Connection %p", c); c 336 daemons/execd/remoted_proxy.c ipc_proxy_destroy(qb_ipcs_connection_t * c) c 338 daemons/execd/remoted_proxy.c crm_trace("Connection %p", c); c 339 daemons/execd/remoted_proxy.c ipc_proxy_closed(c); c 71 daemons/fenced/pacemaker-fenced.c st_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 75 daemons/fenced/pacemaker-fenced.c pcmk__client_pid(c)); c 79 daemons/fenced/pacemaker-fenced.c if (pcmk__new_client(c, uid, gid) == NULL) { c 93 daemons/fenced/pacemaker-fenced.c pcmk__client_t *c = pcmk__find_client(qbc); c 96 daemons/fenced/pacemaker-fenced.c if (c == NULL) { c 101 daemons/fenced/pacemaker-fenced.c request = pcmk__client_data2xml(c, data, &id, &flags); c 103 daemons/fenced/pacemaker-fenced.c pcmk__ipc_send_ack(c, id, flags, "nack", CRM_EX_PROTOCOL); c 112 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTID, c->id); c 113 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTNAME, pcmk__client_name(c)); c 121 daemons/fenced/pacemaker-fenced.c if (c->name == NULL) { c 127 daemons/fenced/pacemaker-fenced.c c->name = crm_strdup_printf("%s.%u", value, c->pid); c 132 daemons/fenced/pacemaker-fenced.c " from client %s", flags, call_options, id, pcmk__client_name(c)); c 136 daemons/fenced/pacemaker-fenced.c CRM_LOG_ASSERT(c->request_id == 0); /* This means the client has two synchronous events in-flight */ c 137 daemons/fenced/pacemaker-fenced.c c->request_id = id; /* Reply only to the last one */ c 140 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTID, c->id); c 141 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, F_STONITH_CLIENTNAME, pcmk__client_name(c)); c 144 daemons/fenced/pacemaker-fenced.c stonith_command(c, id, flags, request, NULL); c 152 daemons/fenced/pacemaker-fenced.c st_ipc_closed(qb_ipcs_connection_t * c) c 154 daemons/fenced/pacemaker-fenced.c pcmk__client_t *client = pcmk__find_client(c); c 160 daemons/fenced/pacemaker-fenced.c crm_trace("Connection %p closed", c); c 168 daemons/fenced/pacemaker-fenced.c st_ipc_destroy(qb_ipcs_connection_t * c) c 170 daemons/fenced/pacemaker-fenced.c crm_trace("Connection %p destroyed", c); c 171 daemons/fenced/pacemaker-fenced.c st_ipc_closed(c); c 46 daemons/pacemakerd/pacemakerd.h void pcmk_handle_ping_request(pcmk__client_t *c, xmlNode *msg, uint32_t id); c 47 daemons/pacemakerd/pacemakerd.h void pcmk_handle_shutdown_request(pcmk__client_t *c, xmlNode *msg, uint32_t id, uint32_t flags); c 23 daemons/pacemakerd/pcmkd_messages.c pcmk_handle_ping_request(pcmk__client_t *c, xmlNode *msg, uint32_t id) c 44 daemons/pacemakerd/pcmkd_messages.c if (pcmk__ipc_send_xml(c, id, reply, crm_ipc_server_event) != c 47 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(c)); c 52 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(c)); c 60 daemons/pacemakerd/pcmkd_messages.c shutdown_complete_state_reported_to = c->pid; c 70 daemons/pacemakerd/pcmkd_messages.c pcmk_handle_shutdown_request(pcmk__client_t *c, xmlNode *msg, uint32_t id, uint32_t flags) c 79 daemons/pacemakerd/pcmkd_messages.c bool allowed = pcmk_is_set(c->flags, pcmk__client_privileged); c 90 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(c)); c 97 daemons/pacemakerd/pcmkd_messages.c if (pcmk__ipc_send_xml(c, id, reply, crm_ipc_server_event) != pcmk_rc_ok) { c 99 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(c)); c 104 daemons/pacemakerd/pcmkd_messages.c pcmk__client_name(c)); c 113 daemons/pacemakerd/pcmkd_messages.c pcmk_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 115 daemons/pacemakerd/pcmkd_messages.c crm_trace("Connection %p", c); c 116 daemons/pacemakerd/pcmkd_messages.c if (pcmk__new_client(c, uid, gid) == NULL) { c 124 daemons/pacemakerd/pcmkd_messages.c pcmk_ipc_closed(qb_ipcs_connection_t * c) c 126 daemons/pacemakerd/pcmkd_messages.c pcmk__client_t *client = pcmk__find_client(c); c 131 daemons/pacemakerd/pcmkd_messages.c crm_trace("Connection %p", c); c 143 daemons/pacemakerd/pcmkd_messages.c pcmk_ipc_destroy(qb_ipcs_connection_t * c) c 145 daemons/pacemakerd/pcmkd_messages.c crm_trace("Connection %p", c); c 146 daemons/pacemakerd/pcmkd_messages.c pcmk_ipc_closed(c); c 157 daemons/pacemakerd/pcmkd_messages.c pcmk__client_t *c = pcmk__find_client(qbc); c 159 daemons/pacemakerd/pcmkd_messages.c CRM_CHECK(c != NULL, return 0); c 161 daemons/pacemakerd/pcmkd_messages.c msg = pcmk__client_data2xml(c, data, &id, &flags); c 163 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_PROTOCOL); c 169 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_INDETERMINATE); c 170 daemons/pacemakerd/pcmkd_messages.c pcmk_handle_shutdown_request(c, msg, id, flags); c 174 daemons/pacemakerd/pcmkd_messages.c "because peer cache is not used", pcmk__client_name(c)); c 175 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_OK); c 178 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_INDETERMINATE); c 179 daemons/pacemakerd/pcmkd_messages.c pcmk_handle_ping_request(c, msg, id); c 183 daemons/pacemakerd/pcmkd_messages.c crm_str(task), pcmk__client_name(c)); c 184 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_INVALID_PARAM); c 239 daemons/schedulerd/pacemaker-schedulerd.c pe_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 241 daemons/schedulerd/pacemaker-schedulerd.c crm_trace("Connection %p", c); c 242 daemons/schedulerd/pacemaker-schedulerd.c if (pcmk__new_client(c, uid, gid) == NULL) { c 256 daemons/schedulerd/pacemaker-schedulerd.c pcmk__client_t *c = pcmk__find_client(qbc); c 257 daemons/schedulerd/pacemaker-schedulerd.c xmlNode *msg = pcmk__client_data2xml(c, data, &id, &flags); c 259 daemons/schedulerd/pacemaker-schedulerd.c pcmk__ipc_send_ack(c, id, flags, "ack", CRM_EX_INDETERMINATE); c 263 daemons/schedulerd/pacemaker-schedulerd.c process_pe_message(msg, data_xml, c); c 271 daemons/schedulerd/pacemaker-schedulerd.c pe_ipc_closed(qb_ipcs_connection_t * c) c 273 daemons/schedulerd/pacemaker-schedulerd.c pcmk__client_t *client = pcmk__find_client(c); c 278 daemons/schedulerd/pacemaker-schedulerd.c crm_trace("Connection %p", c); c 284 daemons/schedulerd/pacemaker-schedulerd.c pe_ipc_destroy(qb_ipcs_connection_t * c) c 286 daemons/schedulerd/pacemaker-schedulerd.c crm_trace("Connection %p", c); c 287 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 420 lib/cib/cib_utils.c xmlNode * c = copy_xml(current_cib); c 423 lib/cib/cib_utils.c test_rc = xml_apply_patchset(c, local_diff, manage_counters); c 426 lib/cib/cib_utils.c save_xml_to_file(c, "PatchApply:calculated", NULL); c 432 lib/cib/cib_utils.c free_xml(c); c 794 lib/cluster/membership.c for (const char *c = uname; *c; ++c) { c 795 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 1408 lib/common/ipc_client.c qb_ipcc_connection_t *c; c 1410 lib/common/ipc_client.c c = qb_ipcc_connect(name, 0); c 1411 lib/common/ipc_client.c if (c == NULL) { c 1417 lib/common/ipc_client.c qb_rc = qb_ipcc_fd_get(c, &fd); c 1425 lib/common/ipc_client.c auth_rc = pcmk__crm_ipc_is_authentic_process(c, fd, refuid, refgid, &found_pid, c 1466 lib/common/ipc_client.c if (c != NULL) { c 1467 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 99 lib/common/ipc_server.c pcmk__client_name(pcmk__client_t *c) c 101 lib/common/ipc_server.c if (c == NULL) { c 104 lib/common/ipc_server.c } else if (c->name != NULL) { c 105 lib/common/ipc_server.c return c->name; c 107 lib/common/ipc_server.c } else if (c->id != NULL) { c 108 lib/common/ipc_server.c return c->id; c 132 lib/common/ipc_server.c qb_ipcs_connection_t *c = NULL; c 138 lib/common/ipc_server.c c = qb_ipcs_connection_first_get(service); c 140 lib/common/ipc_server.c while (c != NULL) { c 141 lib/common/ipc_server.c qb_ipcs_connection_t *last = c; c 143 lib/common/ipc_server.c c = qb_ipcs_connection_next_get(service, last); c 164 lib/common/ipc_server.c client_from_connection(qb_ipcs_connection_t *c, void *key, uid_t uid_client) c 173 lib/common/ipc_server.c if (c) { c 181 lib/common/ipc_server.c client->ipcs = c; c 183 lib/common/ipc_server.c client->pid = pcmk__client_pid(c); c 185 lib/common/ipc_server.c key = c; c 224 lib/common/ipc_server.c pcmk__new_client(qb_ipcs_connection_t *c, uid_t uid_client, gid_t gid_client) c 231 lib/common/ipc_server.c CRM_CHECK(c != NULL, return NULL); c 246 lib/common/ipc_server.c qb_ipcs_connection_auth_set(c, -1, gid_cluster, S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP); c 250 lib/common/ipc_server.c client = client_from_connection(c, NULL, uid_client); c 296 lib/common/ipc_server.c add_event(pcmk__client_t *c, struct iovec *iov) c 298 lib/common/ipc_server.c if (c->event_queue == NULL) { c 299 lib/common/ipc_server.c c->event_queue = g_queue_new(); c 301 lib/common/ipc_server.c g_queue_push_tail(c->event_queue, iov); c 305 lib/common/ipc_server.c pcmk__free_client(pcmk__client_t *c) c 307 lib/common/ipc_server.c if (c == NULL) { c 312 lib/common/ipc_server.c if (c->ipcs) { c 314 lib/common/ipc_server.c c, c->ipcs, g_hash_table_size(client_connections) - 1); c 315 lib/common/ipc_server.c g_hash_table_remove(client_connections, c->ipcs); c 319 lib/common/ipc_server.c c, g_hash_table_size(client_connections) - 1); c 320 lib/common/ipc_server.c g_hash_table_remove(client_connections, c->id); c 324 lib/common/ipc_server.c if (c->event_timer) { c 325 lib/common/ipc_server.c g_source_remove(c->event_timer); c 328 lib/common/ipc_server.c if (c->event_queue) { c 329 lib/common/ipc_server.c crm_debug("Destroying %d events", g_queue_get_length(c->event_queue)); c 330 lib/common/ipc_server.c g_queue_free_full(c->event_queue, free_event); c 333 lib/common/ipc_server.c free(c->id); c 334 lib/common/ipc_server.c free(c->name); c 335 lib/common/ipc_server.c free(c->user); c 336 lib/common/ipc_server.c if (c->remote) { c 337 lib/common/ipc_server.c if (c->remote->auth_timeout) { c 338 lib/common/ipc_server.c g_source_remove(c->remote->auth_timeout); c 340 lib/common/ipc_server.c free(c->remote->buffer); c 341 lib/common/ipc_server.c free(c->remote); c 343 lib/common/ipc_server.c free(c); c 371 lib/common/ipc_server.c pcmk__client_pid(qb_ipcs_connection_t *c) c 376 lib/common/ipc_server.c qb_ipcs_connection_stats_get(c, &stats, 0); c 392 lib/common/ipc_server.c pcmk__client_data2xml(pcmk__client_t *c, void *data, uint32_t *id, c 416 lib/common/ipc_server.c pcmk__set_client_flags(c, pcmk__client_proxied); c 447 lib/common/ipc_server.c static int crm_ipcs_flush_events(pcmk__client_t *c); c 452 lib/common/ipc_server.c pcmk__client_t *c = data; c 454 lib/common/ipc_server.c c->event_timer = 0; c 455 lib/common/ipc_server.c crm_ipcs_flush_events(c); c 467 lib/common/ipc_server.c delay_next_flush(pcmk__client_t *c, unsigned int queue_len) c 472 lib/common/ipc_server.c c->event_timer = g_timeout_add(delay, crm_ipcs_flush_events_cb, c); c 484 lib/common/ipc_server.c crm_ipcs_flush_events(pcmk__client_t *c) c 491 lib/common/ipc_server.c if (c == NULL) { c 494 lib/common/ipc_server.c } else if (c->event_timer) { c 496 lib/common/ipc_server.c crm_trace("Timer active for %p - %d", c->ipcs, c->event_timer); c 500 lib/common/ipc_server.c if (c->event_queue) { c 501 lib/common/ipc_server.c queue_len = g_queue_get_length(c->event_queue); c 507 lib/common/ipc_server.c if (c->event_queue) { c 509 lib/common/ipc_server.c event = g_queue_peek_head(c->event_queue); c 515 lib/common/ipc_server.c qb_rc = qb_ipcs_event_sendv(c->ipcs, event, 2); c 520 lib/common/ipc_server.c event = g_queue_pop_head(c->event_queue); c 526 lib/common/ipc_server.c header->qb.id, c->ipcs, c->pid, (long long) qb_rc); c 529 lib/common/ipc_server.c header->qb.id, c->ipcs, c->pid, (long long) qb_rc, c 538 lib/common/ipc_server.c sent, queue_len, c->ipcs, c->pid, c 548 lib/common/ipc_server.c if (queue_len > QB_MAX(c->queue_max, PCMK_IPC_DEFAULT_QUEUE_MAX)) { c 549 lib/common/ipc_server.c if ((c->queue_backlog <= 1) || (queue_len < c->queue_backlog)) { c 552 lib/common/ipc_server.c CRM_XS " %p", c->pid, queue_len, c->ipcs); c 555 lib/common/ipc_server.c CRM_XS " %p", c->pid, queue_len, c->ipcs); c 556 lib/common/ipc_server.c c->queue_backlog = 0; c 557 lib/common/ipc_server.c qb_ipcs_disconnect(c->ipcs); c 562 lib/common/ipc_server.c c->queue_backlog = queue_len; c 563 lib/common/ipc_server.c delay_next_flush(c, queue_len); c 567 lib/common/ipc_server.c c->queue_backlog = 0; c 671 lib/common/ipc_server.c pcmk__ipc_send_iov(pcmk__client_t *c, struct iovec *iov, uint32_t flags) c 677 lib/common/ipc_server.c if (c->flags & pcmk__client_proxied) { c 694 lib/common/ipc_server.c crm_trace("Sending the original to %p[%d]", c->ipcs, c->pid); c 695 lib/common/ipc_server.c add_event(c, iov); c 700 lib/common/ipc_server.c crm_trace("Sending a copy to %p[%d]", c->ipcs, c->pid); c 709 lib/common/ipc_server.c add_event(c, iov_copy); c 717 lib/common/ipc_server.c qb_rc = qb_ipcs_response_sendv(c->ipcs, iov, 2); c 724 lib/common/ipc_server.c header->qb.id, c->pid, pcmk_rc_str(rc), c 725 lib/common/ipc_server.c header->qb.size, (long long) qb_rc, c->ipcs); c 729 lib/common/ipc_server.c header->qb.id, (long long) qb_rc, c->ipcs, c->pid); c 738 lib/common/ipc_server.c rc = crm_ipcs_flush_events(c); c 740 lib/common/ipc_server.c crm_ipcs_flush_events(c); c 744 lib/common/ipc_server.c crm_trace("Client %p disconnected", c->ipcs); c 750 lib/common/ipc_server.c pcmk__ipc_send_xml(pcmk__client_t *c, uint32_t request, xmlNode *message, c 756 lib/common/ipc_server.c if (c == NULL) { c 763 lib/common/ipc_server.c rc = pcmk__ipc_send_iov(c, iov, flags); c 767 lib/common/ipc_server.c c->pid, pcmk_rc_str(rc), rc); c 788 lib/common/ipc_server.c pcmk__ipc_send_ack_as(const char *function, int line, pcmk__client_t *c, c 798 lib/common/ipc_server.c pcmk__client_name(c), tag, status); c 799 lib/common/ipc_server.c c->request_id = 0; c 803 lib/common/ipc_server.c rc = pcmk__ipc_send_xml(c, request, ack, flags); c 838 lib/common/mainloop.c mainloop_gio_destroy(gpointer c) c 840 lib/common/mainloop.c mainloop_io_t *client = c; c 846 lib/common/mainloop.c crm_trace("Destroying client %s[%p]", c_name, c); c 866 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 479 lib/common/xml.c #define attr_matches(c, n, v) pcmk__str_eq(crm_element_value((c), (n)), \ c 1129 lib/common/xml.c char *c; c 1131 lib/common/xml.c for (c = id; *c; ++c) { c 1133 lib/common/xml.c switch (*c) { c 1136 lib/common/xml.c *c = '.'; c 1988 lib/common/xml.c pcmk__buffer_add_char(char **buffer, int *offset, int *max, char c) c 1990 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 1048 tools/crm_mon.c get_option_desc(char c) c 1053 tools/crm_mon.c if (entry->short_name == c) { c 1073 tools/crm_mon.c int c; c 1079 tools/crm_mon.c c = getchar(); c 1081 tools/crm_mon.c switch (c) {