size 108 attrd/legacy.c attrd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 113 attrd/legacy.c xmlNode *msg = crm_ipcs_recv(client, data, size, &id, &flags); size 233 attrd/main.c attrd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 238 attrd/main.c xmlNode *xml = crm_ipcs_recv(client, data, size, &id, &flags); size 74 cib/callbacks.c gboolean cib_common_callback(qb_ipcs_connection_t * c, void *data, size_t size, size 130 cib/callbacks.c cib_ipc_dispatch_rw(qb_ipcs_connection_t * c, void *data, size_t size) size 135 cib/callbacks.c return cib_common_callback(c, data, size, TRUE); size 139 cib/callbacks.c cib_ipc_dispatch_ro(qb_ipcs_connection_t * c, void *data, size_t size) size 144 cib/callbacks.c return cib_common_callback(c, data, size, FALSE); size 249 cib/callbacks.c cib_common_callback(qb_ipcs_connection_t * c, void *data, size_t size, gboolean privileged) size 255 cib/callbacks.c xmlNode *op_request = crm_ipcs_recv(cib_client, data, size, &id, &flags); size 1539 cib/callbacks.c cib_ccm_msg_callback(oc_ed_t event, void *cookie, size_t size, const void *data) size 85 cib/callbacks.h extern void cib_ccm_msg_callback(oc_ed_t event, void *cookie, size_t size, const void *data); size 708 crmd/control.c crmd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 714 crmd/control.c xmlNode *msg = crm_ipcs_recv(client, data, size, &id, &flags); size 42 crmd/heartbeat.c void crmd_ccm_msg_callback(oc_ed_t event, void *cookie, size_t size, const void *data); size 304 crmd/heartbeat.c crmd_ccm_msg_callback(oc_ed_t event, void *cookie, size_t size, const void *data) size 95 fencing/main.c st_ipc_dispatch(qb_ipcs_connection_t * qbc, void *data, size_t size) size 109 fencing/main.c request = crm_ipcs_recv(c, data, size, &id, &flags); size 39 include/crm/cluster/internal.h uint32_t size; size 52 include/crm/cluster/internal.h uint32_t size; size 201 include/crm/cluster/internal.h } else if (host->size > 0) { size 208 include/crm/cluster/internal.h # define ais_data_len(msg) (msg->is_compressed?msg->compressed_size:msg->size) size 124 include/crm/common/ipcs.h xmlNode *crm_ipcs_recv(crm_client_t * c, void *data, size_t size, uint32_t * id, uint32_t * flags); size 310 include/crm_internal.h int size __attribute__ ((aligned(8))); size 315 include/crm_internal.h int size __attribute__ ((aligned(8))); size 340 include/crm_internal.h static inline void *realloc_safe(void *ptr, size_t size) size 342 include/crm_internal.h void *ret = realloc(ptr, size); size 877 lib/ais/plugin.c ais_msg->size = swab32(ais_msg->size); size 884 lib/ais/plugin.c ais_msg->host.size = swab32(ais_msg->host.size); size 890 lib/ais/plugin.c ais_msg->sender.size = swab32(ais_msg->sender.size); size 893 lib/ais/plugin.c ais_msg->header.size = swab32(ais_msg->header.size); size 909 lib/ais/plugin.c if (ais_msg->host.size == 0 || ais_str_eq(ais_msg->host.uname, local_uname)) { size 932 lib/ais/plugin.c ais_msg->header.size = swab32(ais_msg->header.size); size 971 lib/ais/plugin.c res_overlay->header.size = sizeof(cs_ipc_header_response_t); size 973 lib/ais/plugin.c pcmk_api->ipc_response_send(conn, res_overlay, res_overlay->header.size); size 1053 lib/ais/plugin.c mutable->sender.size = local_uname_len; size 1055 lib/ais/plugin.c memcpy(mutable->sender.uname, local_uname, mutable->sender.size); size 1179 lib/ais/plugin.c int size = 0; size 1182 lib/ais/plugin.c size = 256; size 1183 lib/ais/plugin.c ais_malloc0(data.string, size); size 1194 lib/ais/plugin.c snprintf(data.string, size, size 1200 lib/ais/plugin.c size = strlen(data.string); size 1201 lib/ais/plugin.c data.string = realloc_safe(data.string, size + 9); /* 9 = </nodes> + nul */ size 1202 lib/ais/plugin.c sprintf(data.string + size, "</nodes>"); size 1247 lib/ais/plugin.c int size = 256; size 1250 lib/ais/plugin.c ais_malloc0(data, size); size 1252 lib/ais/plugin.c snprintf(data, size, "<quorum id=\"" U64T "\" quorate=\"%s\" expected=\"%u\" actual=\"%u\"/>", size 1321 lib/ais/plugin.c resp.header.size = sizeof(struct crm_ais_nodeid_resp_s); size 1330 lib/ais/plugin.c pcmk_api->ipc_response_send(conn, &resp, resp.header.size); size 1361 lib/ais/plugin.c int tmp_size = msg->header.size - sizeof(AIS_Message); size 1363 lib/ais/plugin.c if (sane && msg->header.size == 0) { size 1373 lib/ais/plugin.c AIS_CHECK(msg->header.size > sizeof(AIS_Message), size 1375 lib/ais/plugin.c msg->header.id, msg->header.size, size 1399 lib/ais/plugin.c for (lpc = (str_size - 10); lpc < msg->size; lpc++) { size 1414 lib/ais/plugin.c ais_data_len(msg), msg->header.size)); size 1421 lib/ais/plugin.c ais_data_len(msg), msg->header.size); size 1427 lib/ais/plugin.c ais_data_len(msg), msg->header.size); size 1468 lib/ais/plugin.c if (mutable->host.size == 0 || ais_str_eq(local_uname, mutable->host.uname)) { size 1568 lib/ais/plugin.c AIS_ASSERT(ais_msg->header.size == (sizeof(AIS_Message) + ais_data_len(ais_msg))); size 1581 lib/ais/plugin.c mutable->sender.size = local_uname_len; size 1583 lib/ais/plugin.c memcpy(mutable->sender.uname, local_uname, mutable->sender.size); size 1586 lib/ais/plugin.c iovec.iov_len = mutable->header.size; size 1637 lib/ais/plugin.c msg->header.size = sizeof(struct crm_identify_msg_s); size 1662 lib/ais/plugin.c iovec.iov_len = msg->header.size; size 390 lib/ais/utils.c int size = 1; /* nul */ size 395 lib/ais/utils.c size = strlen(data); size 397 lib/ais/utils.c offset = size; size 399 lib/ais/utils.c size += fixed_len; size 400 lib/ais/utils.c size += 32; /* node->id */ size 401 lib/ais/utils.c size += 100; /* node->seq, node->born */ size 402 lib/ais/utils.c size += strlen(node->state); size 404 lib/ais/utils.c size += (7 + strlen(node->uname)); size 407 lib/ais/utils.c size += (6 + strlen(node->addr)); size 410 lib/ais/utils.c size += (9 + strlen(node->version)); size 412 lib/ais/utils.c data = realloc_safe(data, size); size 414 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "<node id=\"%u\" ", node->id); size 416 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "uname=\"%s\" ", node->uname); size 418 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "state=\"%s\" ", node->state); size 419 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "born=\"" U64T "\" ", node->born); size 420 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "seen=\"" U64T "\" ", node->last_seen); size 421 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "votes=\"%d\" ", node->votes); size 422 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "processes=\"%u\" ", node->processes); size 424 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "addr=\"%s\" ", node->addr); size 427 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "version=\"%s\" ", node->version); size 429 lib/ais/utils.c offset += snprintf(data + offset, size - offset, "/>"); size 445 lib/ais/utils.c msg->host.size = msg->sender.type; size 458 lib/ais/utils.c unsigned int new_size = msg->size + 1; size 469 lib/ais/utils.c ais_info("rc=%d, new=%u expected=%u", rc, new_size, msg->size); size 472 lib/ais/utils.c AIS_ASSERT(new_size == msg->size); size 494 lib/ais/utils.c ais_msg->header.size = total_size; size 498 lib/ais/utils.c ais_msg->size = data_len; size 507 lib/ais/utils.c ais_msg->host.size = strlen(host); size 509 lib/ais/utils.c memcpy(ais_msg->host.uname, host, ais_msg->host.size); size 514 lib/ais/utils.c ais_msg->host.size = 0; size 543 lib/ais/utils.c rc = pcmk_api->ipc_dispatch_send(conn, ais_msg, ais_msg->header.size); size 573 lib/ais/utils.c ais_msg->header.size = total_size; size 576 lib/ais/utils.c ais_msg->size = data_len; size 581 lib/ais/utils.c ais_msg->host.size = 0; size 587 lib/ais/utils.c ais_msg->sender.size = local_uname_len; size 589 lib/ais/utils.c memcpy(ais_msg->sender.uname, local_uname, ais_msg->sender.size); size 381 lib/cluster/corosync.c int tmp_size = msg->header.size - sizeof(AIS_Message); size 383 lib/cluster/corosync.c if (sane && msg->header.size == 0) { size 413 lib/cluster/corosync.c for (lpc = (str_size - 10); lpc < msg->size; lpc++) { size 426 lib/cluster/corosync.c msg->sender.pid, msg->is_compressed, ais_data_len(msg), msg->header.size); size 433 lib/cluster/corosync.c ais_data_len(msg), msg->header.size); size 254 lib/cluster/cpg.c } else if (msg->host.size != 0 && safe_str_neq(msg->host.uname, local_name)) { size 261 lib/cluster/cpg.c if (msg->sender.size == 0) { size 272 lib/cluster/cpg.c msg->sender.size = strlen(peer->uname); size 274 lib/cluster/cpg.c memcpy(msg->sender.uname, peer->uname, msg->sender.size); size 281 lib/cluster/cpg.c ais_data_len(msg), msg->size, msg->compressed_size); size 290 lib/cluster/cpg.c if (msg->is_compressed && msg->size > 0) { size 293 lib/cluster/cpg.c unsigned int new_size = msg->size + 1; size 310 lib/cluster/cpg.c CRM_ASSERT(new_size == msg->size); size 356 lib/cluster/cpg.c msg->header.size, msg->size, msg->compressed_size); size 574 lib/cluster/cpg.c msg->host.size = strlen(node->uname); size 576 lib/cluster/cpg.c memcpy(msg->host.uname, node->uname, msg->host.size); size 588 lib/cluster/cpg.c msg->sender.size = local_name_len; size 590 lib/cluster/cpg.c if(local_name && msg->sender.size) { size 591 lib/cluster/cpg.c memcpy(msg->sender.uname, local_name, msg->sender.size); size 594 lib/cluster/cpg.c msg->size = 1 + strlen(data); size 595 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + msg->size; size 597 lib/cluster/cpg.c if (msg->size < CRM_BZ2_THRESHOLD) { size 598 lib/cluster/cpg.c msg = realloc_safe(msg, msg->header.size); size 599 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); size 606 lib/cluster/cpg.c if (crm_compress_string(uncompressed, msg->size, 0, &compressed, &new_size)) { size 608 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + new_size; size 609 lib/cluster/cpg.c msg = realloc_safe(msg, msg->header.size); size 616 lib/cluster/cpg.c msg = realloc_safe(msg, msg->header.size); size 617 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); size 626 lib/cluster/cpg.c iov->iov_len = msg->header.size; size 635 lib/cluster/cpg.c msg->size, data); size 57 lib/cluster/heartbeat.c int size = orig_len * 10; size 95 lib/cluster/heartbeat.c size = orig_len * 10 + 1; /* +1 because an exact 10x compression factor happens occasionally */ size 109 lib/cluster/heartbeat.c uncompressed = realloc_safe(uncompressed, size); size 110 lib/cluster/heartbeat.c memset(uncompressed, 0, size); size 111 lib/cluster/heartbeat.c used = size - 1; /* always leave room for a trailing '\0' size 119 lib/cluster/heartbeat.c size = size * 2; size 121 lib/cluster/heartbeat.c if (size > 0) { size 128 lib/cluster/heartbeat.c name, (int)orig_len, size, rc); size 130 lib/cluster/heartbeat.c } else if (used >= size) { size 131 lib/cluster/heartbeat.c CRM_ASSERT(used < size); size 92 lib/cluster/legacy.c header.size = sizeof(cs_ipc_header_response_t); size 95 lib/cluster/legacy.c iov.iov_len = header.size; size 101 lib/cluster/legacy.c CRM_CHECK(answer.header.size == sizeof(struct crm_ais_nodeid_resp_s), size 103 lib/cluster/legacy.c answer.header.id, answer.header.size, answer.header.error)); size 163 lib/cluster/legacy.c CRM_CHECK(header->size == sizeof(cs_ipc_header_response_t), size 165 lib/cluster/legacy.c header->id, header->size, class, header->error)); size 167 lib/cluster/legacy.c CRM_ASSERT(buf_len >= header->size); size 734 lib/cluster/legacy.c int tmp_size = msg->header.size - sizeof(AIS_Message); size 736 lib/cluster/legacy.c if (sane && msg->header.size == 0) { size 766 lib/cluster/legacy.c for (lpc = (str_size - 10); lpc < msg->size; lpc++) { size 779 lib/cluster/legacy.c msg->sender.pid, msg->is_compressed, ais_data_len(msg), msg->header.size); size 786 lib/cluster/legacy.c ais_data_len(msg), msg->header.size); size 445 lib/common/ipc.c crm_ipcs_recv(crm_client_t * c, void *data, size_t size, uint32_t * id, uint32_t * flags) size 679 lib/common/ipc.c header->qb.size = iov[0].iov_len + iov[1].iov_len; size 683 lib/common/ipc.c CRM_ASSERT(header->qb.size > 0); size 684 lib/common/ipc.c return header->qb.size; size 731 lib/common/ipc.c if (rc < header->qb.size) { size 733 lib/common/ipc.c header->qb.id, c->ipcs, c->pid, header->qb.size, pcmk_strerror(rc), rc); size 1077 lib/common/ipc.c client->name, header->qb.id, header->qb.size, client->msg_size, size 1264 lib/common/ipc.c client->name, header->qb.id, header->qb.size, ms_timeout); size 1272 lib/common/ipc.c client->name, header->qb.id, header->qb.size); size 1277 lib/common/ipc.c header->qb.id, client->name, header->qb.size); size 1301 lib/common/ipc.c crm_trace("Received response %d, size=%u, rc=%ld, text: %.200s", hdr->qb.id, hdr->qb.size, size 113 lib/gnu/md5.c size_t size = (bytes < 56) ? 64 / 4 : 64 * 2 / 4; size 121 lib/gnu/md5.c ctx->buffer[size - 2] = SWAP (ctx->total[0] << 3); size 122 lib/gnu/md5.c ctx->buffer[size - 1] = SWAP ((ctx->total[1] << 3) | (ctx->total[0] >> 29)); size 124 lib/gnu/md5.c memcpy (&((char *) ctx->buffer)[bytes], fillbuf, (size - 2) * 4 - bytes); size 127 lib/gnu/md5.c md5_process_block (ctx->buffer, size * 4, ctx); size 1013 lib/lrmd/lrmd_client.c key->size = key_cache_len; size 1050 lib/lrmd/lrmd_client.c key->size = cur_len; size 1058 lib/lrmd/lrmd_client.c key_cache = calloc(1, key->size + 1); size 1059 lib/lrmd/lrmd_client.c memcpy(key_cache, key->data, key->size); size 1061 lib/lrmd/lrmd_client.c key_cache_len = key->size; size 221 lrmd/ipc_proxy.c ipc_proxy_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 246 lrmd/ipc_proxy.c request = crm_ipcs_recv(client, data, size, &id, &flags); size 124 lrmd/main.c lrmd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 129 lrmd/main.c xmlNode *request = crm_ipcs_recv(client, data, size, &id, &flags); size 482 mcp/pacemaker.c pcmk_ipc_dispatch(qb_ipcs_connection_t * qbc, void *data, size_t size) size 488 mcp/pacemaker.c xmlNode *msg = crm_ipcs_recv(c, data, size, &id, &flags); size 65 pengine/main.c pe_ipc_dispatch(qb_ipcs_connection_t * qbc, void *data, size_t size) size 70 pengine/main.c xmlNode *msg = crm_ipcs_recv(c, data, size, &id, &flags); size 417 tools/crm_node.c ccm_age_callback(oc_ed_t event, void *cookie, size_t size, const void *data)