header 56 include/crm/cluster/internal.h cs_ipc_header_response_t header __attribute__ ((aligned(8))); header 102 include/crm/common/cmdline_internal.h const char *header, const char *desc, header 425 lib/cluster/corosync.c int tmp_size = msg->header.size - sizeof(AIS_Message); header 427 lib/cluster/corosync.c if (sane && msg->header.size == 0) { header 432 lib/cluster/corosync.c if (sane && msg->header.error != CS_OK) { header 433 lib/cluster/corosync.c crm_warn("Message header contains an error: %d", msg->header.error); header 470 lib/cluster/corosync.c msg->sender.pid, msg->is_compressed, ais_data_len(msg), msg->header.size); header 477 lib/cluster/corosync.c ais_data_len(msg), msg->header.size); header 301 lib/cluster/cpg.c *kind = msg->header.id; header 358 lib/cluster/cpg.c msg->header.size, msg->size, msg->compressed_size); header 693 lib/cluster/cpg.c msg->header.id = msg_class; header 694 lib/cluster/cpg.c msg->header.error = CS_OK; header 723 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + msg->size; header 726 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); header 737 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + new_size; header 738 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); header 747 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); header 757 lib/cluster/cpg.c iov->iov_len = msg->header.size; header 139 lib/common/cmdline.c const char *header, const char *desc, header 144 lib/common/cmdline.c group = g_option_group_new(name, header, desc, NULL, NULL); header 265 lib/common/crmcommon_private.h bool pcmk__valid_ipc_header(const pcmk__ipc_header_t *header); header 958 lib/common/ipc_client.c pcmk__ipc_header_t *header = (pcmk__ipc_header_t *)(void*)client->buffer; header 960 lib/common/ipc_client.c if (header->size_compressed) { header 962 lib/common/ipc_client.c unsigned int size_u = 1 + header->size_uncompressed; header 968 lib/common/ipc_client.c header->size_compressed, size_u); header 971 lib/common/ipc_client.c client->buffer + sizeof(pcmk__ipc_header_t), header->size_compressed, 1, 0); header 988 lib/common/ipc_client.c CRM_ASSERT(size_u == header->size_uncompressed); header 991 lib/common/ipc_client.c header = (pcmk__ipc_header_t *)(void*)uncompressed; header 998 lib/common/ipc_client.c CRM_ASSERT(client->buffer[sizeof(pcmk__ipc_header_t) + header->size_uncompressed - 1] == 0); header 1005 lib/common/ipc_client.c pcmk__ipc_header_t *header = NULL; header 1021 lib/common/ipc_client.c header = (pcmk__ipc_header_t *)(void*)client->buffer; header 1022 lib/common/ipc_client.c if (!pcmk__valid_ipc_header(header)) { header 1027 lib/common/ipc_client.c client->name, header->qb.id, header->qb.size, client->msg_size, header 1038 lib/common/ipc_client.c if (header) { header 1040 lib/common/ipc_client.c return header->size_uncompressed; header 1055 lib/common/ipc_client.c pcmk__ipc_header_t *header = NULL; header 1062 lib/common/ipc_client.c header = (pcmk__ipc_header_t *)(void*)client->buffer; header 1063 lib/common/ipc_client.c return header->flags; header 1148 lib/common/ipc_client.c pcmk__ipc_header_t *header; header 1189 lib/common/ipc_client.c header = iov[0].iov_base; header 1190 lib/common/ipc_client.c pcmk__set_ipc_flags(header->flags, client->name, flags); header 1197 lib/common/ipc_client.c if(header->size_compressed) { header 1208 lib/common/ipc_client.c client->name, header->qb.id, header->qb.size, ms_timeout); header 1231 lib/common/ipc_client.c client->name, header->qb.id); header 1235 lib/common/ipc_client.c rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes); header 1260 lib/common/ipc_client.c rc, hdr->qb.id, client->name, header->qb.id, header 1269 lib/common/ipc_client.c client->name, header->qb.id, rc); header 1275 lib/common/ipc_client.c CRM_XS " rc=%d", client->name, header->qb.id, rc); header 1279 lib/common/ipc_client.c client->name, header->qb.id, pcmk_strerror(rc), ms_timeout, header 1285 lib/common/ipc_client.c client->name, header->qb.id, header 75 lib/common/ipc_common.c pcmk__valid_ipc_header(const pcmk__ipc_header_t *header) header 77 lib/common/ipc_common.c if (header == NULL) { header 81 lib/common/ipc_common.c } else if (header->version > PCMK__IPC_VERSION) { header 83 lib/common/ipc_common.c header->version, PCMK__IPC_VERSION); header 389 lib/common/ipc_server.c pcmk__ipc_header_t *header = data; header 391 lib/common/ipc_server.c if (!pcmk__valid_ipc_header(header)) { header 399 lib/common/ipc_server.c *flags = header->flags; header 402 lib/common/ipc_server.c if (pcmk_is_set(header->flags, crm_ipc_proxied)) { header 410 lib/common/ipc_server.c if (header->size_compressed) { header 412 lib/common/ipc_server.c unsigned int size_u = 1 + header->size_uncompressed; header 416 lib/common/ipc_server.c header->size_compressed, size_u); header 418 lib/common/ipc_server.c rc = BZ2_bzBuffToBuffDecompress(uncompressed, &size_u, text, header->size_compressed, 1, 0); header 429 lib/common/ipc_server.c CRM_ASSERT(text[header->size_uncompressed - 1] == 0); header 495 lib/common/ipc_server.c pcmk__ipc_header_t *header = NULL; header 514 lib/common/ipc_server.c header = event[0].iov_base; header 515 lib/common/ipc_server.c if (header->size_compressed) { header 517 lib/common/ipc_server.c header->qb.id, c->ipcs, c->pid, (long long) qb_rc); header 520 lib/common/ipc_server.c header->qb.id, c->ipcs, c->pid, (long long) qb_rc, header 586 lib/common/ipc_server.c pcmk__ipc_header_t *header = NULL; header 592 lib/common/ipc_server.c header = calloc(1, sizeof(pcmk__ipc_header_t)); header 593 lib/common/ipc_server.c if (header == NULL) { header 607 lib/common/ipc_server.c iov[0].iov_base = header; header 609 lib/common/ipc_server.c header->version = PCMK__IPC_VERSION; header 610 lib/common/ipc_server.c header->size_uncompressed = 1 + strlen(buffer); header 611 lib/common/ipc_server.c total = iov[0].iov_len + header->size_uncompressed; header 615 lib/common/ipc_server.c iov[1].iov_len = header->size_uncompressed; header 620 lib/common/ipc_server.c if (pcmk__compress(buffer, (unsigned int) header->size_uncompressed, header 624 lib/common/ipc_server.c pcmk__set_ipc_flags(header->flags, "send data", crm_ipc_compressed); header 625 lib/common/ipc_server.c header->size_compressed = new_size; header 627 lib/common/ipc_server.c iov[1].iov_len = header->size_compressed; header 632 lib/common/ipc_server.c biggest = QB_MAX(header->size_compressed, biggest); header 636 lib/common/ipc_server.c biggest = QB_MAX(header->size_uncompressed, biggest); header 641 lib/common/ipc_server.c header->size_uncompressed, max_send_size, 4 * biggest); header 650 lib/common/ipc_server.c header->qb.size = iov[0].iov_len + iov[1].iov_len; header 651 lib/common/ipc_server.c header->qb.id = (int32_t)request; /* Replying to a specific request */ header 654 lib/common/ipc_server.c CRM_ASSERT(header->qb.size > 0); header 656 lib/common/ipc_server.c *bytes = header->qb.size; header 666 lib/common/ipc_server.c pcmk__ipc_header_t *header = iov[0].iov_base; header 680 lib/common/ipc_server.c pcmk__set_ipc_flags(header->flags, "server event", flags); header 682 lib/common/ipc_server.c header->qb.id = id++; /* We don't really use it, but doesn't hurt to set one */ header 706 lib/common/ipc_server.c CRM_LOG_ASSERT(header->qb.id != 0); /* Replying to a specific request */ header 709 lib/common/ipc_server.c if (qb_rc < header->qb.size) { header 715 lib/common/ipc_server.c header->qb.id, c->pid, pcmk_rc_str(rc), header 716 lib/common/ipc_server.c header->qb.size, (long long) qb_rc, c->ipcs); header 720 lib/common/ipc_server.c header->qb.id, (long long) qb_rc, c->ipcs, c->pid); header 100 lib/common/remote.c struct remote_header_v0 *header = (struct remote_header_v0 *)remote->buffer; header 104 lib/common/remote.c } else if(header->endian != ENDIAN_LOCAL) { header 105 lib/common/remote.c uint32_t endian = __swab32(header->endian); header 111 lib/common/remote.c ENDIAN_LOCAL, header->endian, endian); header 115 lib/common/remote.c header->id = __swab64(header->id); header 116 lib/common/remote.c header->flags = __swab64(header->flags); header 117 lib/common/remote.c header->endian = __swab32(header->endian); header 119 lib/common/remote.c header->version = __swab32(header->version); header 120 lib/common/remote.c header->size_total = __swab32(header->size_total); header 121 lib/common/remote.c header->payload_offset = __swab32(header->payload_offset); header 122 lib/common/remote.c header->payload_compressed = __swab32(header->payload_compressed); header 123 lib/common/remote.c header->payload_uncompressed = __swab32(header->payload_uncompressed); header 126 lib/common/remote.c return header; header 508 lib/common/remote.c struct remote_header_v0 *header; header 515 lib/common/remote.c header = calloc(1, sizeof(struct remote_header_v0)); header 516 lib/common/remote.c CRM_ASSERT(header != NULL); header 518 lib/common/remote.c iov[0].iov_base = header; header 525 lib/common/remote.c header->id = id; header 526 lib/common/remote.c header->endian = ENDIAN_LOCAL; header 527 lib/common/remote.c header->version = REMOTE_MSG_VERSION; header 528 lib/common/remote.c header->payload_offset = iov[0].iov_len; header 529 lib/common/remote.c header->payload_uncompressed = iov[1].iov_len; header 530 lib/common/remote.c header->size_total = iov[0].iov_len + iov[1].iov_len; header 556 lib/common/remote.c struct remote_header_v0 *header = localized_remote_header(remote); header 558 lib/common/remote.c if (header == NULL) { header 563 lib/common/remote.c if (header->payload_compressed) { header 565 lib/common/remote.c unsigned int size_u = 1 + header->payload_uncompressed; header 566 lib/common/remote.c char *uncompressed = calloc(1, header->payload_offset + size_u); header 569 lib/common/remote.c header->payload_compressed, size_u); header 571 lib/common/remote.c rc = BZ2_bzBuffToBuffDecompress(uncompressed + header->payload_offset, &size_u, header 572 lib/common/remote.c remote->buffer + header->payload_offset, header 573 lib/common/remote.c header->payload_compressed, 1, 0); header 575 lib/common/remote.c if (rc != BZ_OK && header->version > REMOTE_MSG_VERSION) { header 577 lib/common/remote.c header->version, REMOTE_MSG_VERSION); header 588 lib/common/remote.c CRM_ASSERT(size_u == header->payload_uncompressed); header 590 lib/common/remote.c memcpy(uncompressed, remote->buffer, header->payload_offset); /* Preserve the header */ header 591 lib/common/remote.c remote->buffer_size = header->payload_offset + size_u; header 595 lib/common/remote.c header = localized_remote_header(remote); header 601 lib/common/remote.c CRM_LOG_ASSERT(remote->buffer[sizeof(struct remote_header_v0) + header->payload_uncompressed - 1] == 0); header 603 lib/common/remote.c xml = string2xml(remote->buffer + header->payload_offset); header 604 lib/common/remote.c if (xml == NULL && header->version > REMOTE_MSG_VERSION) { header 606 lib/common/remote.c header->version, REMOTE_MSG_VERSION); header 609 lib/common/remote.c crm_err("Couldn't parse: '%.120s'", remote->buffer + header->payload_offset); header 702 lib/common/remote.c struct remote_header_v0 *header = localized_remote_header(remote); header 706 lib/common/remote.c if(header) { header 708 lib/common/remote.c read_len = header->size_total; header 777 lib/common/remote.c header = localized_remote_header(remote); header 778 lib/common/remote.c if(header) { header 779 lib/common/remote.c if(remote->buffer_offset < header->size_total) { header 782 lib/common/remote.c header->size_total);