c 490 daemons/attrd/attrd_ipc.c attrd_ipc_accept(qb_ipcs_connection_t *c, uid_t uid, gid_t gid) c 492 daemons/attrd/attrd_ipc.c crm_trace("New client connection %p", c); c 495 daemons/attrd/attrd_ipc.c pcmk__client_pid(c)); c 499 daemons/attrd/attrd_ipc.c if (pcmk__new_client(c, uid, gid) == NULL) { c 514 daemons/attrd/attrd_ipc.c attrd_ipc_closed(qb_ipcs_connection_t *c) c 516 daemons/attrd/attrd_ipc.c pcmk__client_t *client = pcmk__find_client(c); c 519 daemons/attrd/attrd_ipc.c crm_trace("Ignoring request to clean up unknown connection %p", c); c 521 daemons/attrd/attrd_ipc.c crm_trace("Cleaning up closed client connection %p", c); c 545 daemons/attrd/attrd_ipc.c attrd_ipc_destroy(qb_ipcs_connection_t *c) c 547 daemons/attrd/attrd_ipc.c crm_trace("Destroying client connection %p", c); c 548 daemons/attrd/attrd_ipc.c attrd_ipc_closed(c); c 552 daemons/attrd/attrd_ipc.c attrd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) c 556 daemons/attrd/attrd_ipc.c pcmk__client_t *client = pcmk__find_client(c); c 560 daemons/attrd/attrd_ipc.c CRM_CHECK((c != NULL) && (client != NULL), return 0); c 562 daemons/attrd/attrd_ipc.c crm_debug("No IPC data from PID %d", pcmk__client_pid(c)); c 569 daemons/attrd/attrd_ipc.c crm_debug("Unrecognizable IPC data from PID %d", pcmk__client_pid(c)); c 46 daemons/based/based_callbacks.c static gboolean cib_common_callback(qb_ipcs_connection_t *c, void *data, c 50 daemons/based/based_callbacks.c cib_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 54 daemons/based/based_callbacks.c pcmk__client_pid(c)); c 58 daemons/based/based_callbacks.c if (pcmk__new_client(c, uid, gid) == NULL) { c 65 daemons/based/based_callbacks.c cib_ipc_dispatch_rw(qb_ipcs_connection_t * c, void *data, size_t size) c 67 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); c 69 daemons/based/based_callbacks.c crm_trace("%p message from %s", c, client->id); c 70 daemons/based/based_callbacks.c return cib_common_callback(c, data, size, TRUE); c 74 daemons/based/based_callbacks.c cib_ipc_dispatch_ro(qb_ipcs_connection_t * c, void *data, size_t size) c 76 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); c 78 daemons/based/based_callbacks.c crm_trace("%p message from %s", c, client->id); c 79 daemons/based/based_callbacks.c return cib_common_callback(c, data, size, FALSE); c 84 daemons/based/based_callbacks.c cib_ipc_closed(qb_ipcs_connection_t * c) c 86 daemons/based/based_callbacks.c pcmk__client_t *client = pcmk__find_client(c); c 91 daemons/based/based_callbacks.c crm_trace("Connection %p", c); c 97 daemons/based/based_callbacks.c cib_ipc_destroy(qb_ipcs_connection_t * c) c 99 daemons/based/based_callbacks.c crm_trace("Connection %p", c); c 100 daemons/based/based_callbacks.c cib_ipc_closed(c); c 302 daemons/based/based_callbacks.c cib_common_callback(qb_ipcs_connection_t * c, void *data, size_t size, gboolean privileged) c 307 daemons/based/based_callbacks.c pcmk__client_t *cib_client = pcmk__find_client(c); c 322 daemons/based/based_callbacks.c crm_trace("Invalid message from %p", c); c 328 daemons/based/based_callbacks.c crm_trace("Invalid client %p", c); c 1290 daemons/based/based_callbacks.c qb_ipcs_connection_t *c = NULL; c 1294 daemons/based/based_callbacks.c c = qb_ipcs_connection_first_get(ipcs_rw); c 1295 daemons/based/based_callbacks.c while (c != NULL) { c 1296 daemons/based/based_callbacks.c qb_ipcs_connection_t *last = c; c 1298 daemons/based/based_callbacks.c c = qb_ipcs_connection_next_get(ipcs_rw, last); c 1306 daemons/based/based_callbacks.c c = qb_ipcs_connection_first_get(ipcs_ro); c 1307 daemons/based/based_callbacks.c while (c != NULL) { c 1308 daemons/based/based_callbacks.c qb_ipcs_connection_t *last = c; c 1310 daemons/based/based_callbacks.c c = qb_ipcs_connection_next_get(ipcs_ro, last); c 1318 daemons/based/based_callbacks.c c = qb_ipcs_connection_first_get(ipcs_shm); c 1319 daemons/based/based_callbacks.c while (c != NULL) { c 1320 daemons/based/based_callbacks.c qb_ipcs_connection_t *last = c; c 1322 daemons/based/based_callbacks.c c = qb_ipcs_connection_next_get(ipcs_shm, last); c 369 daemons/controld/controld_control.c accept_controller_client(qb_ipcs_connection_t *c, uid_t uid, gid_t gid) c 372 daemons/controld/controld_control.c if (pcmk__new_client(c, uid, gid) == NULL) { c 380 daemons/controld/controld_control.c dispatch_controller_ipc(qb_ipcs_connection_t * c, void *data, size_t size) c 384 daemons/controld/controld_control.c pcmk__client_t *client = pcmk__find_client(c); c 412 daemons/controld/controld_control.c ipc_client_disconnected(qb_ipcs_connection_t *c) c 414 daemons/controld/controld_control.c pcmk__client_t *client = pcmk__find_client(c); c 419 daemons/controld/controld_control.c c, client); c 428 daemons/controld/controld_control.c ipc_connection_destroyed(qb_ipcs_connection_t *c) c 430 daemons/controld/controld_control.c crm_trace("Connection %p", c); c 431 daemons/controld/controld_control.c ipc_client_disconnected(c); c 100 daemons/execd/pacemaker-execd.c lrmd_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 102 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 103 daemons/execd/pacemaker-execd.c if (pcmk__new_client(c, uid, gid) == NULL) { c 110 daemons/execd/pacemaker-execd.c lrmd_ipc_created(qb_ipcs_connection_t * c) c 112 daemons/execd/pacemaker-execd.c pcmk__client_t *new_client = pcmk__find_client(c); c 114 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 123 daemons/execd/pacemaker-execd.c lrmd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) c 127 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); c 147 daemons/execd/pacemaker-execd.c client->name = pcmk__itoa(pcmk__client_pid(c)); c 190 daemons/execd/pacemaker-execd.c lrmd_ipc_closed(qb_ipcs_connection_t * c) c 192 daemons/execd/pacemaker-execd.c pcmk__client_t *client = pcmk__find_client(c); c 198 daemons/execd/pacemaker-execd.c crm_trace("Connection %p", c); c 208 daemons/execd/pacemaker-execd.c lrmd_ipc_destroy(qb_ipcs_connection_t * c) c 210 daemons/execd/pacemaker-execd.c lrmd_ipc_closed(c); c 211 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, PCMK__VALUE_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 313 daemons/execd/remoted_proxy.c ipc_proxy_closed(qb_ipcs_connection_t * c) c 315 daemons/execd/remoted_proxy.c pcmk__client_t *client = pcmk__find_client(c); c 324 daemons/execd/remoted_proxy.c crm_trace("Connection %p", c); c 343 daemons/execd/remoted_proxy.c ipc_proxy_destroy(qb_ipcs_connection_t * c) c 345 daemons/execd/remoted_proxy.c crm_trace("Connection %p", c); c 346 daemons/execd/remoted_proxy.c ipc_proxy_closed(c); c 3094 daemons/fenced/fenced_commands.c is_privileged(const pcmk__client_t *c, const char *op) c 3096 daemons/fenced/fenced_commands.c if ((c == NULL) || pcmk_is_set(c->flags, pcmk__client_privileged)) { c 3100 daemons/fenced/fenced_commands.c pcmk__s(op, ""), pcmk__client_name(c)); c 70 daemons/fenced/pacemaker-fenced.c st_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 74 daemons/fenced/pacemaker-fenced.c pcmk__client_pid(c)); c 78 daemons/fenced/pacemaker-fenced.c if (pcmk__new_client(c, uid, gid) == NULL) { c 92 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, PCMK__XE_NACK, NULL, CRM_EX_PROTOCOL); c 112 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTID, c->id); c 113 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTNAME, pcmk__client_name(c)); c 121 daemons/fenced/pacemaker-fenced.c if (c->name == NULL) { c 124 daemons/fenced/pacemaker-fenced.c c->name = crm_strdup_printf("%s.%u", pcmk__s(value, "unknown"), c->pid); c 135 daemons/fenced/pacemaker-fenced.c " from client %s", flags, call_options, id, pcmk__client_name(c)); c 139 daemons/fenced/pacemaker-fenced.c CRM_LOG_ASSERT(c->request_id == 0); /* This means the client has two synchronous events in-flight */ c 140 daemons/fenced/pacemaker-fenced.c c->request_id = id; /* Reply only to the last one */ c 143 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTID, c->id); c 144 daemons/fenced/pacemaker-fenced.c crm_xml_add(request, PCMK__XA_ST_CLIENTNAME, pcmk__client_name(c)); c 148 daemons/fenced/pacemaker-fenced.c stonith_command(c, id, flags, request, NULL); c 156 daemons/fenced/pacemaker-fenced.c st_ipc_closed(qb_ipcs_connection_t * c) c 158 daemons/fenced/pacemaker-fenced.c pcmk__client_t *client = pcmk__find_client(c); c 164 daemons/fenced/pacemaker-fenced.c crm_trace("Connection %p closed", c); c 172 daemons/fenced/pacemaker-fenced.c st_ipc_destroy(qb_ipcs_connection_t * c) c 174 daemons/fenced/pacemaker-fenced.c crm_trace("Connection %p destroyed", c); c 175 daemons/fenced/pacemaker-fenced.c st_ipc_closed(c); c 170 daemons/pacemakerd/pcmkd_messages.c pcmk_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 172 daemons/pacemakerd/pcmkd_messages.c crm_trace("Connection %p", c); c 173 daemons/pacemakerd/pcmkd_messages.c if (pcmk__new_client(c, uid, gid) == NULL) { c 181 daemons/pacemakerd/pcmkd_messages.c pcmk_ipc_closed(qb_ipcs_connection_t * c) c 183 daemons/pacemakerd/pcmkd_messages.c pcmk__client_t *client = pcmk__find_client(c); c 188 daemons/pacemakerd/pcmkd_messages.c crm_trace("Connection %p", c); c 200 daemons/pacemakerd/pcmkd_messages.c pcmk_ipc_destroy(qb_ipcs_connection_t * c) c 202 daemons/pacemakerd/pcmkd_messages.c crm_trace("Connection %p", c); c 203 daemons/pacemakerd/pcmkd_messages.c pcmk_ipc_closed(c); c 213 daemons/pacemakerd/pcmkd_messages.c pcmk__client_t *c = pcmk__find_client(qbc); c 215 daemons/pacemakerd/pcmkd_messages.c CRM_CHECK(c != NULL, return 0); c 221 daemons/pacemakerd/pcmkd_messages.c msg = pcmk__client_data2xml(c, data, &id, &flags); c 223 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_ack(c, id, flags, PCMK__XE_ACK, NULL, CRM_EX_PROTOCOL); c 232 daemons/pacemakerd/pcmkd_messages.c .ipc_client = c, c 247 daemons/pacemakerd/pcmkd_messages.c pcmk__ipc_send_xml(c, id, reply, crm_ipc_server_event); c 210 daemons/schedulerd/schedulerd_messages.c pe_ipc_accept(qb_ipcs_connection_t * c, uid_t uid, gid_t gid) c 212 daemons/schedulerd/schedulerd_messages.c crm_trace("Connection %p", c); c 213 daemons/schedulerd/schedulerd_messages.c if (pcmk__new_client(c, uid, gid) == NULL) { c 225 daemons/schedulerd/schedulerd_messages.c pcmk__client_t *c = pcmk__find_client(qbc); c 228 daemons/schedulerd/schedulerd_messages.c CRM_CHECK(c != NULL, return 0); c 234 daemons/schedulerd/schedulerd_messages.c msg = pcmk__client_data2xml(c, data, &id, &flags); c 236 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_ack(c, id, flags, PCMK__XE_ACK, NULL, CRM_EX_PROTOCOL); c 244 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_ack(c, id, flags, PCMK__XE_ACK, NULL, c 246 daemons/schedulerd/schedulerd_messages.c crm_info("Ignoring IPC reply from %s", pcmk__client_name(c)); c 249 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_ack(c, id, flags, PCMK__XE_ACK, NULL, c 260 daemons/schedulerd/schedulerd_messages.c .ipc_client = c, c 275 daemons/schedulerd/schedulerd_messages.c pcmk__ipc_send_xml(c, id, reply, crm_ipc_server_event); c 305 daemons/schedulerd/schedulerd_messages.c pe_ipc_closed(qb_ipcs_connection_t * c) c 307 daemons/schedulerd/schedulerd_messages.c pcmk__client_t *client = pcmk__find_client(c); c 312 daemons/schedulerd/schedulerd_messages.c crm_trace("Connection %p", c); c 318 daemons/schedulerd/schedulerd_messages.c pe_ipc_destroy(qb_ipcs_connection_t * c) c 320 daemons/schedulerd/schedulerd_messages.c crm_trace("Connection %p", c); c 321 daemons/schedulerd/schedulerd_messages.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 217 include/crm/common/ipc_internal.h pcmk__client_t *pcmk__find_client(const qb_ipcs_connection_t *c); c 219 include/crm/common/ipc_internal.h const char *pcmk__client_name(const pcmk__client_t *c); c 223 include/crm/common/ipc_internal.h pcmk__client_t *pcmk__new_client(qb_ipcs_connection_t *c, uid_t uid, gid_t gid); c 224 include/crm/common/ipc_internal.h void pcmk__free_client(pcmk__client_t *c); c 233 include/crm/common/ipc_internal.h int pcmk__ipc_send_ack_as(const char *function, int line, pcmk__client_t *c, c 236 include/crm/common/ipc_internal.h #define pcmk__ipc_send_ack(c, req, flags, tag, ver, st) \ c 237 include/crm/common/ipc_internal.h pcmk__ipc_send_ack_as(__func__, __LINE__, (c), (req), (flags), (tag), (ver), (st)) c 242 include/crm/common/ipc_internal.h int pcmk__ipc_send_xml(pcmk__client_t *c, uint32_t request, c 244 include/crm/common/ipc_internal.h int pcmk__ipc_send_iov(pcmk__client_t *c, struct iovec *iov, uint32_t flags); c 245 include/crm/common/ipc_internal.h xmlNode *pcmk__client_data2xml(pcmk__client_t *c, void *data, c 248 include/crm/common/ipc_internal.h int pcmk__client_pid(qb_ipcs_connection_t *c); c 1031 lib/cluster/membership.c for (const char *c = uname; *c; ++c) { c 1032 lib/cluster/membership.c if ((*c >= 'A') && (*c <= 'Z')) { c 1558 lib/common/ipc_client.c qb_ipcc_connection_t *c; c 1563 lib/common/ipc_client.c c = qb_ipcc_connect_async(name, 0, c 1566 lib/common/ipc_client.c c = qb_ipcc_connect(name, 0); c 1568 lib/common/ipc_client.c if (c == NULL) { c 1584 lib/common/ipc_client.c if (qb_ipcc_connect_continue(c) != 0) { c 1588 lib/common/ipc_client.c c = NULL; // qb_ipcc_connect_continue cleaned up for us c 1593 lib/common/ipc_client.c qb_rc = qb_ipcc_fd_get(c, &fd); c 1601 lib/common/ipc_client.c auth_rc = is_ipc_provider_expected(c, fd, refuid, refgid, c 1642 lib/common/ipc_client.c if (c != NULL) { c 1643 lib/common/ipc_client.c qb_ipcc_disconnect(c); c 59 lib/common/ipc_server.c pcmk__find_client(const 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 98 lib/common/ipc_server.c pcmk__client_name(const pcmk__client_t *c) c 100 lib/common/ipc_server.c if (c == NULL) { c 103 lib/common/ipc_server.c } else if (c->name != NULL) { c 104 lib/common/ipc_server.c return c->name; c 106 lib/common/ipc_server.c } else if (c->id != NULL) { c 107 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 168 lib/common/ipc_server.c if (c) { c 175 lib/common/ipc_server.c client->ipcs = c; c 177 lib/common/ipc_server.c client->pid = pcmk__client_pid(c); c 179 lib/common/ipc_server.c key = c; c 209 lib/common/ipc_server.c pcmk__new_client(qb_ipcs_connection_t *c, uid_t uid_client, gid_t gid_client) c 216 lib/common/ipc_server.c CRM_CHECK(c != NULL, return NULL); c 231 lib/common/ipc_server.c qb_ipcs_connection_auth_set(c, -1, gid_cluster, S_IRUSR | S_IWUSR | S_IRGRP | S_IWGRP); c 235 lib/common/ipc_server.c client = client_from_connection(c, NULL, uid_client); c 275 lib/common/ipc_server.c add_event(pcmk__client_t *c, struct iovec *iov) c 277 lib/common/ipc_server.c if (c->event_queue == NULL) { c 278 lib/common/ipc_server.c c->event_queue = g_queue_new(); c 280 lib/common/ipc_server.c g_queue_push_tail(c->event_queue, iov); c 284 lib/common/ipc_server.c pcmk__free_client(pcmk__client_t *c) c 286 lib/common/ipc_server.c if (c == NULL) { c 291 lib/common/ipc_server.c if (c->ipcs) { c 293 lib/common/ipc_server.c c, c->ipcs, g_hash_table_size(client_connections) - 1); c 294 lib/common/ipc_server.c g_hash_table_remove(client_connections, c->ipcs); c 298 lib/common/ipc_server.c c, g_hash_table_size(client_connections) - 1); c 299 lib/common/ipc_server.c g_hash_table_remove(client_connections, c->id); c 303 lib/common/ipc_server.c if (c->event_timer) { c 304 lib/common/ipc_server.c g_source_remove(c->event_timer); c 307 lib/common/ipc_server.c if (c->event_queue) { c 308 lib/common/ipc_server.c crm_debug("Destroying %d events", g_queue_get_length(c->event_queue)); c 309 lib/common/ipc_server.c g_queue_free_full(c->event_queue, free_event); c 312 lib/common/ipc_server.c free(c->id); c 313 lib/common/ipc_server.c free(c->name); c 314 lib/common/ipc_server.c free(c->user); c 315 lib/common/ipc_server.c if (c->remote) { c 316 lib/common/ipc_server.c if (c->remote->auth_timeout) { c 317 lib/common/ipc_server.c g_source_remove(c->remote->auth_timeout); c 319 lib/common/ipc_server.c if (c->remote->tls_session != NULL) { c 323 lib/common/ipc_server.c gnutls_deinit(c->remote->tls_session); c 325 lib/common/ipc_server.c free(c->remote->buffer); c 326 lib/common/ipc_server.c free(c->remote); c 328 lib/common/ipc_server.c free(c); c 375 lib/common/ipc_server.c pcmk__client_pid(qb_ipcs_connection_t *c) c 380 lib/common/ipc_server.c qb_ipcs_connection_stats_get(c, &stats, 0); c 396 lib/common/ipc_server.c pcmk__client_data2xml(pcmk__client_t *c, void *data, uint32_t *id, c 420 lib/common/ipc_server.c pcmk__set_client_flags(c, pcmk__client_proxied); c 453 lib/common/ipc_server.c static int crm_ipcs_flush_events(pcmk__client_t *c); c 458 lib/common/ipc_server.c pcmk__client_t *c = data; c 460 lib/common/ipc_server.c c->event_timer = 0; c 461 lib/common/ipc_server.c crm_ipcs_flush_events(c); c 473 lib/common/ipc_server.c delay_next_flush(pcmk__client_t *c, unsigned int queue_len) c 478 lib/common/ipc_server.c c->event_timer = pcmk__create_timer(delay, crm_ipcs_flush_events_cb, c); c 490 lib/common/ipc_server.c crm_ipcs_flush_events(pcmk__client_t *c) c 497 lib/common/ipc_server.c if (c == NULL) { c 500 lib/common/ipc_server.c } else if (c->event_timer) { c 502 lib/common/ipc_server.c crm_trace("Timer active for %p - %d", c->ipcs, c->event_timer); c 506 lib/common/ipc_server.c if (c->event_queue) { c 507 lib/common/ipc_server.c queue_len = g_queue_get_length(c->event_queue); c 513 lib/common/ipc_server.c if (c->event_queue) { c 515 lib/common/ipc_server.c event = g_queue_peek_head(c->event_queue); c 521 lib/common/ipc_server.c qb_rc = qb_ipcs_event_sendv(c->ipcs, event, 2); c 526 lib/common/ipc_server.c event = g_queue_pop_head(c->event_queue); c 532 lib/common/ipc_server.c header->qb.id, c->ipcs, c->pid, (long long) qb_rc); c 535 lib/common/ipc_server.c header->qb.id, c->ipcs, c->pid, (long long) qb_rc, c 544 lib/common/ipc_server.c sent, queue_len, c->ipcs, c->pid, c 554 lib/common/ipc_server.c if (queue_len > QB_MAX(c->queue_max, PCMK_IPC_DEFAULT_QUEUE_MAX)) { c 555 lib/common/ipc_server.c if ((c->queue_backlog <= 1) || (queue_len < c->queue_backlog)) { c 558 lib/common/ipc_server.c QB_XS " %p", c->pid, queue_len, c->ipcs); c 561 lib/common/ipc_server.c QB_XS " %p", c->pid, queue_len, c->ipcs); c 562 lib/common/ipc_server.c c->queue_backlog = 0; c 563 lib/common/ipc_server.c qb_ipcs_disconnect(c->ipcs); c 568 lib/common/ipc_server.c c->queue_backlog = queue_len; c 569 lib/common/ipc_server.c delay_next_flush(c, queue_len); c 573 lib/common/ipc_server.c c->queue_backlog = 0; c 686 lib/common/ipc_server.c pcmk__ipc_send_iov(pcmk__client_t *c, struct iovec *iov, uint32_t flags) c 692 lib/common/ipc_server.c if (c->flags & pcmk__client_proxied) { c 709 lib/common/ipc_server.c crm_trace("Sending the original to %p[%d]", c->ipcs, c->pid); c 710 lib/common/ipc_server.c add_event(c, iov); c 715 lib/common/ipc_server.c crm_trace("Sending a copy to %p[%d]", c->ipcs, c->pid); c 724 lib/common/ipc_server.c add_event(c, iov_copy); c 732 lib/common/ipc_server.c qb_rc = qb_ipcs_response_sendv(c->ipcs, iov, 2); c 739 lib/common/ipc_server.c header->qb.id, c->pid, pcmk_rc_str(rc), c 740 lib/common/ipc_server.c header->qb.size, (long long) qb_rc, c->ipcs); c 744 lib/common/ipc_server.c header->qb.id, (long long) qb_rc, c->ipcs, c->pid); c 753 lib/common/ipc_server.c rc = crm_ipcs_flush_events(c); c 755 lib/common/ipc_server.c crm_ipcs_flush_events(c); c 759 lib/common/ipc_server.c crm_trace("Client %p disconnected", c->ipcs); c 765 lib/common/ipc_server.c pcmk__ipc_send_xml(pcmk__client_t *c, uint32_t request, const xmlNode *message, c 771 lib/common/ipc_server.c if (c == NULL) { c 778 lib/common/ipc_server.c rc = pcmk__ipc_send_iov(c, iov, flags); c 782 lib/common/ipc_server.c c->pid, pcmk_rc_str(rc), rc); c 835 lib/common/ipc_server.c pcmk__ipc_send_ack_as(const char *function, int line, pcmk__client_t *c, c 844 lib/common/ipc_server.c pcmk__client_name(c), tag, status); c 846 lib/common/ipc_server.c c->request_id = 0; c 847 lib/common/ipc_server.c rc = pcmk__ipc_send_xml(c, request, ack, flags); c 636 lib/common/logging.c strchrnul(const char *s, int c) c 638 lib/common/logging.c while ((*s != c) && (*s != '\0')) { c 806 lib/common/mainloop.c mainloop_gio_destroy(gpointer c) c 808 lib/common/mainloop.c mainloop_io_t *client = c; c 814 lib/common/mainloop.c crm_trace("Destroying client %s[%p]", c_name, c); c 834 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 414 lib/common/nvpair.c for (char *c = env_name; *c != '\0'; ++c) { c 415 lib/common/nvpair.c if (*c == '-') { c 416 lib/common/nvpair.c *c = '_'; c 28 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(int c, bool reference) c 32 lib/common/tests/xml/pcmk__xml_is_name_char_test.c int ref_len = g_unichar_to_utf8(c, utf8_buf); c 41 lib/common/tests/xml/pcmk__xml_is_name_char_test.c if ((c < 0xD800) || (c > 0xDFFF)) { c 68 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x00; c <= 0x7F; c++) { c 69 lib/common/tests/xml/pcmk__xml_is_name_char_test.c if (g_ascii_isalnum(c) c 70 lib/common/tests/xml/pcmk__xml_is_name_char_test.c || c == ':' || c == '_' || c == '-' || c == '.') { c 72 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 74 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 82 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x80; c <= 0xB6; c++) { c 83 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 96 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xB8; c <= 0xBF; c++) { c 97 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 104 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xC0; c <= 0xD6; c++) { c 105 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 118 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xD8; c <= 0xF6; c++) { c 119 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 132 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xF8; c <= 0x2FF; c++) { c 133 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 140 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x300; c <= 0x36F; c++) { c 141 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 148 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x370; c <= 0x37D; c++) { c 149 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 162 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x37F; c <= 0x1FFF; c++) { c 163 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 170 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x2000; c <= 0x200B; c++) { c 171 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 178 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x200C; c <= 0x200D; c++) { c 179 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 186 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x200E; c <= 0x203E; c++) { c 187 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 194 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x203F; c <= 0x2040; c++) { c 195 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 202 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x2041; c <= 0x206F; c++) { c 203 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 210 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x2070; c <= 0x218F; c++) { c 211 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 218 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x2190; c <= 0x2BFF; c++) { c 219 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 226 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x2C00; c <= 0x2FEF; c++) { c 227 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 234 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x2FF0; c <= 0x3000; c++) { c 235 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 242 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x3001; c <= 0xD7FF; c++) { c 243 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 250 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xD800; c <= 0xF8FF; c++) { c 251 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 258 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xF900; c <= 0xFDCF; c++) { c 259 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 266 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xFDD0; c <= 0xFDEF; c++) { c 267 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 274 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xFDF0; c <= 0xFFFD; c++) { c 275 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 282 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xFFFE; c <= 0xFFFF; c++) { c 283 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 290 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0x10000; c <= 0xEFFFF; c++) { c 291 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, true); c 298 lib/common/tests/xml/pcmk__xml_is_name_char_test.c for (int c = 0xF0000; c <= 0x10FFFF; c++) { c 299 lib/common/tests/xml/pcmk__xml_is_name_char_test.c assert_name_char(c, false); c 29 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(int c, bool reference) c 33 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c int ref_len = g_unichar_to_utf8(c, utf8_buf); c 42 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c if ((c < 0xD800) || (c > 0xDFFF)) { c 69 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x00; c <= 0x7F; c++) { c 70 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c if (g_ascii_isalpha(c) || c == ':' || c == '_') { c 71 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 73 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 81 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x80; c <= 0xBF; c++) { c 82 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 89 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0xC0; c <= 0xD6; c++) { c 90 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 103 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0xD8; c <= 0xF6; c++) { c 104 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 117 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0xF8; c <= 0x2FF; c++) { c 118 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 125 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x300; c <= 0x36F; c++) { c 126 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 133 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x370; c <= 0x37D; c++) { c 134 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 147 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x37F; c <= 0x1FFF; c++) { c 148 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 155 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x2000; c <= 0x200B; c++) { c 156 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 163 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x200C; c <= 0x200D; c++) { c 164 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 171 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x200E; c <= 0x206F; c++) { c 172 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 179 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x2070; c <= 0x218F; c++) { c 180 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 187 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x2190; c <= 0x2BFF; c++) { c 188 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 195 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x2C00; c <= 0x2FEF; c++) { c 196 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 203 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x2FF0; c <= 0x3000; c++) { c 204 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 211 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x3001; c <= 0xD7FF; c++) { c 212 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 219 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0xD800; c <= 0xF8FF; c++) { c 220 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 227 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0xF900; c <= 0xFDCF; c++) { c 228 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 235 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0xFDD0; c <= 0xFDEF; c++) { c 236 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 243 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0xFDF0; c <= 0xFFFD; c++) { c 244 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 251 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0xFFFE; c <= 0xFFFF; c++) { c 252 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 259 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0x10000; c <= 0xEFFFF; c++) { c 260 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, true); c 267 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c for (int c = 0xF0000; c <= 0x10FFFF; c++) { c 268 lib/common/tests/xml/pcmk__xml_is_name_start_char_test.c assert_name_start_char(c, false); c 522 lib/common/xml.c int c = 0; c 543 lib/common/xml.c c = xmlGetUTF8Char((pcmkXmlStr) utf8, len); c 544 lib/common/xml.c if (c < 0) { c 556 lib/common/xml.c return (c == '_') c 557 lib/common/xml.c || (c == ':') c 558 lib/common/xml.c || ((c >= 'a') && (c <= 'z')) c 559 lib/common/xml.c || ((c >= 'A') && (c <= 'Z')) c 560 lib/common/xml.c || ((c >= 0xC0) && (c <= 0xD6)) c 561 lib/common/xml.c || ((c >= 0xD8) && (c <= 0xF6)) c 562 lib/common/xml.c || ((c >= 0xF8) && (c <= 0x2FF)) c 563 lib/common/xml.c || ((c >= 0x370) && (c <= 0x37D)) c 564 lib/common/xml.c || ((c >= 0x37F) && (c <= 0x1FFF)) c 565 lib/common/xml.c || ((c >= 0x200C) && (c <= 0x200D)) c 566 lib/common/xml.c || ((c >= 0x2070) && (c <= 0x218F)) c 567 lib/common/xml.c || ((c >= 0x2C00) && (c <= 0x2FEF)) c 568 lib/common/xml.c || ((c >= 0x3001) && (c <= 0xD7FF)) c 569 lib/common/xml.c || ((c >= 0xF900) && (c <= 0xFDCF)) c 570 lib/common/xml.c || ((c >= 0xFDF0) && (c <= 0xFFFD)) c 571 lib/common/xml.c || ((c >= 0x10000) && (c <= 0xEFFFF)); c 593 lib/common/xml.c int c = 0; c 604 lib/common/xml.c c = xmlGetUTF8Char((pcmkXmlStr) utf8, len); c 605 lib/common/xml.c if (c < 0) { c 617 lib/common/xml.c return ((c >= 'a') && (c <= 'z')) c 618 lib/common/xml.c || ((c >= 'A') && (c <= 'Z')) c 619 lib/common/xml.c || ((c >= '0') && (c <= '9')) c 620 lib/common/xml.c || (c == '_') c 621 lib/common/xml.c || (c == ':') c 622 lib/common/xml.c || (c == '-') c 623 lib/common/xml.c || (c == '.') c 624 lib/common/xml.c || (c == 0xB7) c 625 lib/common/xml.c || ((c >= 0xC0) && (c <= 0xD6)) c 626 lib/common/xml.c || ((c >= 0xD8) && (c <= 0xF6)) c 627 lib/common/xml.c || ((c >= 0xF8) && (c <= 0x2FF)) c 628 lib/common/xml.c || ((c >= 0x300) && (c <= 0x36F)) c 629 lib/common/xml.c || ((c >= 0x370) && (c <= 0x37D)) c 630 lib/common/xml.c || ((c >= 0x37F) && (c <= 0x1FFF)) c 631 lib/common/xml.c || ((c >= 0x200C) && (c <= 0x200D)) c 632 lib/common/xml.c || ((c >= 0x203F) && (c <= 0x2040)) c 633 lib/common/xml.c || ((c >= 0x2070) && (c <= 0x218F)) c 634 lib/common/xml.c || ((c >= 0x2C00) && (c <= 0x2FEF)) c 635 lib/common/xml.c || ((c >= 0x3001) && (c <= 0xD7FF)) c 636 lib/common/xml.c || ((c >= 0xF900) && (c <= 0xFDCF)) c 637 lib/common/xml.c || ((c >= 0xFDF0) && (c <= 0xFFFD)) c 638 lib/common/xml.c || ((c >= 0x10000) && (c <= 0xEFFFF)); c 1585 lib/common/xml.c char *c; c 1587 lib/common/xml.c for (c = id; *c; ++c) { c 1588 lib/common/xml.c switch (*c) { c 1591 lib/common/xml.c *c = '.'; 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 1016 tools/crm_mon.c get_option_desc(char c) c 1021 tools/crm_mon.c if (entry->short_name == c) { c 1041 tools/crm_mon.c int c; c 1069 tools/crm_mon.c c = getchar(); c 1071 tools/crm_mon.c switch (c) {