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 105 daemons/execd/pacemaker-execd.c lrmd_ipc_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 222 daemons/execd/remoted_proxy.c ipc_proxy_dispatch(qb_ipcs_connection_t * c, void *data, size_t size) size 87 daemons/fenced/pacemaker-fenced.c st_ipc_dispatch(qb_ipcs_connection_t * qbc, void *data, size_t size) size 151 daemons/pacemakerd/pcmkd_messages.c pcmk_ipc_dispatch(qb_ipcs_connection_t * qbc, void *data, size_t size) size 252 daemons/schedulerd/pacemaker-schedulerd.c pe_ipc_dispatch(qb_ipcs_connection_t * qbc, void *data, size_t size) size 272 include/crm/common/internal.h pcmk__realloc(void *ptr, size_t size) size 277 include/crm/common/internal.h CRM_ASSERT(size > 0); size 279 include/crm/common/internal.h new_ptr = realloc(ptr, size); size 51 lib/cluster/cpg.c uint32_t size; size 65 lib/cluster/cpg.c uint32_t size; size 76 lib/cluster/cpg.c #define msg_data_len(msg) (msg->is_compressed?msg->compressed_size:msg->size) size 307 lib/cluster/cpg.c } else if (host->size > 0) { size 365 lib/cluster/cpg.c int32_t payload_size = msg->header.size - sizeof(pcmk__cpg_msg_t); size 373 lib/cluster/cpg.c (int) msg->header.size, size 397 lib/cluster/cpg.c (int) msg->header.size, (int) msg_data_len(msg), size 407 lib/cluster/cpg.c (((msg->size > 1) && (msg->data[msg->size - 2] == '\0')) size 408 lib/cluster/cpg.c || (msg->data[msg->size - 1] != '\0'))) { size 413 lib/cluster/cpg.c (unsigned long long) msg->size, size 420 lib/cluster/cpg.c (int) msg->header.size, (msg->is_compressed? "compressed " : ""), size 463 lib/cluster/cpg.c } else if (msg->host.size != 0 && !pcmk__str_eq(msg->host.uname, local_name, pcmk__str_casei)) { size 470 lib/cluster/cpg.c if (msg->sender.size == 0) { size 481 lib/cluster/cpg.c msg->sender.size = strlen(peer->uname); size 483 lib/cluster/cpg.c memcpy(msg->sender.uname, peer->uname, msg->sender.size); size 490 lib/cluster/cpg.c msg_data_len(msg), msg->size, msg->compressed_size); size 499 lib/cluster/cpg.c if (msg->is_compressed && msg->size > 0) { size 502 lib/cluster/cpg.c unsigned int new_size = msg->size + 1; size 520 lib/cluster/cpg.c CRM_ASSERT(new_size == msg->size); size 543 lib/cluster/cpg.c msg->header.size, msg->size, msg->compressed_size); size 957 lib/cluster/cpg.c msg->host.size = strlen(node->uname); size 959 lib/cluster/cpg.c memcpy(msg->host.uname, node->uname, msg->host.size); size 971 lib/cluster/cpg.c msg->sender.size = local_name_len; size 973 lib/cluster/cpg.c if ((local_name != NULL) && (msg->sender.size != 0)) { size 974 lib/cluster/cpg.c memcpy(msg->sender.uname, local_name, msg->sender.size); size 977 lib/cluster/cpg.c msg->size = 1 + strlen(data); size 978 lib/cluster/cpg.c msg->header.size = sizeof(pcmk__cpg_msg_t) + msg->size; size 980 lib/cluster/cpg.c if (msg->size < CRM_BZ2_THRESHOLD) { size 981 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); size 982 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); size 989 lib/cluster/cpg.c if (pcmk__compress(uncompressed, (unsigned int) msg->size, 0, size 992 lib/cluster/cpg.c msg->header.size = sizeof(pcmk__cpg_msg_t) + new_size; size 993 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); size 1002 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); size 1003 lib/cluster/cpg.c memcpy(msg->data, data, msg->size); size 1012 lib/cluster/cpg.c iov->iov_len = msg->header.size; size 1021 lib/cluster/cpg.c msg->size, data); size 1035 lib/common/ipc_client.c client->server_name, header->qb.id, header->qb.size, size 1219 lib/common/ipc_client.c client->server_name, header->qb.id, header->qb.size, ms_timeout); size 659 lib/common/ipc_server.c header->qb.size = iov[0].iov_len + iov[1].iov_len; size 663 lib/common/ipc_server.c CRM_ASSERT(header->qb.size > 0); size 665 lib/common/ipc_server.c *bytes = header->qb.size; size 718 lib/common/ipc_server.c if (qb_rc < header->qb.size) { size 725 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 1047 lib/lrmd/lrmd_client.c dest->data = gnutls_malloc(source->size); size 1049 lib/lrmd/lrmd_client.c memcpy(dest->data, source->data, source->size); size 1050 lib/lrmd/lrmd_client.c dest->size = source->size; size 1058 lib/lrmd/lrmd_client.c datum->size = 0; size 1080 lib/lrmd/lrmd_client.c key->size = 0; size 1091 lib/lrmd/lrmd_client.c if (key->size == buf_len) { size 1092 lib/lrmd/lrmd_client.c buf_len = key->size + KEY_READ_LEN; size 1096 lib/lrmd/lrmd_client.c key->data[key->size++] = (unsigned char) next; size 1100 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)