size 223 daemons/attrd/pacemaker-attrd.c attrd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 60 daemons/based/based_callbacks.c gboolean cib_common_callback(qb_ipcs_connection_t * c, void *data, size_t size, size 85 daemons/based/based_callbacks.c cib_ipc_dispatch_rw(qb_ipcs_connection_t * c, void *data, size_t size) size 90 daemons/based/based_callbacks.c return cib_common_callback(c, data, size, TRUE); size 94 daemons/based/based_callbacks.c cib_ipc_dispatch_ro(qb_ipcs_connection_t * c, void *data, size_t size) size 99 daemons/based/based_callbacks.c return cib_common_callback(c, data, size, FALSE); size 207 daemons/based/based_callbacks.c cib_common_callback(qb_ipcs_connection_t * c, void *data, size_t size, gboolean privileged) size 373 daemons/controld/controld_control.c dispatch_controller_ipc(qb_ipcs_connection_t * c, void *data, size_t size) size 109 daemons/execd/pacemaker-execd.c lrmd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 215 daemons/execd/remoted_proxy.c ipc_proxy_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 79 daemons/fenced/pacemaker-fenced.c st_ipc_dispatch(qb_ipcs_connection_t * qbc, void *data, size_t size) size 562 daemons/pacemakerd/pacemakerd.c pcmk_ipc_dispatch(qb_ipcs_connection_t * qbc, void *data, size_t size) size 222 daemons/schedulerd/pacemaker-schedulerd.c pe_ipc_dispatch(qb_ipcs_connection_t * qbc, void *data, size_t size) size 38 include/crm/cluster/internal.h uint32_t size; size 49 include/crm/cluster/internal.h int size __attribute__ ((aligned(8))); size 63 include/crm/cluster/internal.h uint32_t size; size 145 include/crm/cluster/internal.h } else if (host->size > 0) { size 152 include/crm/cluster/internal.h # define ais_data_len(msg) (msg->is_compressed?msg->compressed_size:msg->size) size 307 include/crm/common/internal.h pcmk__realloc(void *ptr, size_t size) size 312 include/crm/common/internal.h CRM_ASSERT(size > 0); size 314 include/crm/common/internal.h new_ptr = realloc(ptr, size); size 425 lib/cluster/corosync.c int tmp_size = msg->header.size - sizeof(AIS_Message); size 427 lib/cluster/corosync.c if (sane && msg->header.size == 0) { size 457 lib/cluster/corosync.c for (lpc = (str_size - 10); lpc < msg->size; lpc++) { size 470 lib/cluster/corosync.c msg->sender.pid, msg->is_compressed, ais_data_len(msg), msg->header.size); size 477 lib/cluster/corosync.c ais_data_len(msg), msg->header.size); size 271 lib/cluster/cpg.c } else if (msg->host.size != 0 && !pcmk__str_eq(msg->host.uname, local_name, pcmk__str_casei)) { size 278 lib/cluster/cpg.c if (msg->sender.size == 0) { size 289 lib/cluster/cpg.c msg->sender.size = strlen(peer->uname); size 291 lib/cluster/cpg.c memcpy(msg->sender.uname, peer->uname, msg->sender.size); size 298 lib/cluster/cpg.c ais_data_len(msg), msg->size, msg->compressed_size); size 307 lib/cluster/cpg.c if (msg->is_compressed && msg->size > 0) { size 310 lib/cluster/cpg.c unsigned int new_size = msg->size + 1; size 328 lib/cluster/cpg.c CRM_ASSERT(new_size == msg->size); size 358 lib/cluster/cpg.c msg->header.size, msg->size, msg->compressed_size); size 702 lib/cluster/cpg.c msg->host.size = strlen(node->uname); size 704 lib/cluster/cpg.c memcpy(msg->host.uname, node->uname, msg->host.size); size 716 lib/cluster/cpg.c msg->sender.size = local_name_len; size 718 lib/cluster/cpg.c if(local_name && msg->sender.size) { size 719 lib/cluster/cpg.c memcpy(msg->sender.uname, local_name, msg->sender.size); size 722 lib/cluster/cpg.c msg->size = 1 + strlen(data); size 723 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + msg->size; size 725 lib/cluster/cpg.c if (msg->size < CRM_BZ2_THRESHOLD) { size 726 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); size 727 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); size 734 lib/cluster/cpg.c if (pcmk__compress(uncompressed, (unsigned int) msg->size, 0, size 737 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + new_size; size 738 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); size 747 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); size 748 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); size 757 lib/cluster/cpg.c iov->iov_len = msg->header.size; size 766 lib/cluster/cpg.c msg->size, data); size 1027 lib/common/ipc_client.c client->name, header->qb.id, header->qb.size, client->msg_size, size 1208 lib/common/ipc_client.c client->name, header->qb.id, header->qb.size, ms_timeout); size 650 lib/common/ipc_server.c header->qb.size = iov[0].iov_len + iov[1].iov_len; size 654 lib/common/ipc_server.c CRM_ASSERT(header->qb.size > 0); size 656 lib/common/ipc_server.c *bytes = header->qb.size; size 709 lib/common/ipc_server.c if (qb_rc < header->qb.size) { size 716 lib/common/ipc_server.c header->qb.size, (long long) qb_rc, c->ipcs); size 117 lib/common/md5.c size_t size = (bytes < 56) ? 64 / 4 : 64 * 2 / 4; size 125 lib/common/md5.c ctx->buffer[size - 2] = SWAP (ctx->total[0] << 3); size 126 lib/common/md5.c ctx->buffer[size - 1] = SWAP ((ctx->total[1] << 3) | (ctx->total[0] >> 29)); size 128 lib/common/md5.c memcpy (&((char *) ctx->buffer)[bytes], fillbuf, (size - 2) * 4 - bytes); size 131 lib/common/md5.c md5_process_block (ctx->buffer, size * 4, ctx); size 117 lib/gnu/md5.c size_t size = (bytes < 56) ? 64 / 4 : 64 * 2 / 4; size 125 lib/gnu/md5.c ctx->buffer[size - 2] = SWAP (ctx->total[0] << 3); size 126 lib/gnu/md5.c ctx->buffer[size - 1] = SWAP ((ctx->total[1] << 3) | (ctx->total[0] >> 29)); size 128 lib/gnu/md5.c memcpy (&((char *) ctx->buffer)[bytes], fillbuf, (size - 2) * 4 - bytes); size 131 lib/gnu/md5.c md5_process_block (ctx->buffer, size * 4, ctx); size 1046 lib/lrmd/lrmd_client.c dest->data = gnutls_malloc(source->size); size 1048 lib/lrmd/lrmd_client.c memcpy(dest->data, source->data, source->size); size 1049 lib/lrmd/lrmd_client.c dest->size = source->size; size 1057 lib/lrmd/lrmd_client.c datum->size = 0; size 1092 lib/lrmd/lrmd_client.c key->size = 0; size 1102 lib/lrmd/lrmd_client.c if (key->size == buf_len) { size 1103 lib/lrmd/lrmd_client.c buf_len = key->size + KEY_READ_LEN; size 1107 lib/lrmd/lrmd_client.c key->data[key->size++] = (unsigned char) next; size 1111 lib/lrmd/lrmd_client.c if (key->size == 0) { size 180 maint/mocked/based.c mock_based_dispatch_command(qb_ipcs_connection_t *c, void *data, size_t size)