header 102 include/crm/common/cmdline_internal.h const char *header, const char *desc, header 66 lib/cluster/cpg.c struct qb_ipc_response_header header __attribute__ ((aligned(8))); header 317 lib/cluster/cpg.c int32_t payload_size = msg->header.size - sizeof(pcmk__cpg_msg_t); header 325 lib/cluster/cpg.c (int) msg->header.size, header 331 lib/cluster/cpg.c if (msg->header.error != CS_OK) { header 337 lib/cluster/cpg.c msg->header.error, header 349 lib/cluster/cpg.c (int) msg->header.size, (int) msg_data_len(msg), header 371 lib/cluster/cpg.c (int) msg->header.size, (msg->is_compressed? "compressed " : ""), header 947 lib/cluster/cpg.c msg->header.error = CS_OK; header 978 lib/cluster/cpg.c msg->header.size = sizeof(pcmk__cpg_msg_t) + msg->size; header 981 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); header 991 lib/cluster/cpg.c msg->header.size = sizeof(pcmk__cpg_msg_t) + new_size; header 992 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); header 999 lib/cluster/cpg.c msg = pcmk__realloc(msg, msg->header.size); header 1008 lib/cluster/cpg.c iov->iov_len = msg->header.size; header 134 lib/common/cmdline.c const char *header, const char *desc, header 139 lib/common/cmdline.c group = g_option_group_new(name, header, desc, NULL, NULL); header 324 lib/common/crmcommon_private.h bool pcmk__valid_ipc_header(const pcmk__ipc_header_t *header); header 1099 lib/common/ipc_client.c pcmk__ipc_header_t *header = NULL; header 1103 lib/common/ipc_client.c header = (pcmk__ipc_header_t *)(void *) buffer; header 1119 lib/common/ipc_client.c } else if (bytes != header->size + sizeof(pcmk__ipc_header_t)) { header 1127 lib/common/ipc_client.c client->server_name, header->qb.id, header->qb.size, header 1175 lib/common/ipc_client.c pcmk__ipc_header_t *header = NULL; header 1182 lib/common/ipc_client.c header = (pcmk__ipc_header_t *)(void*) client->buffer->data; header 1183 lib/common/ipc_client.c return header->flags; header 1300 lib/common/ipc_client.c pcmk__ipc_header_t *header = NULL; header 1316 lib/common/ipc_client.c header = (pcmk__ipc_header_t *)(void *) buffer; header 1318 lib/common/ipc_client.c if (!pcmk__valid_ipc_header(header)) { header 1321 lib/common/ipc_client.c } else if (!pcmk_is_set(header->flags, crm_ipc_multipart) header 1322 lib/common/ipc_client.c || pcmk_is_set(header->flags, crm_ipc_multipart_end)) { header 1360 lib/common/ipc_client.c pcmk__ipc_header_t *header; header 1411 lib/common/ipc_client.c header = iov[0].iov_base; header 1412 lib/common/ipc_client.c pcmk__set_ipc_flags(header->flags, client->server_name, flags); header 1419 lib/common/ipc_client.c if (pcmk_is_set(header->flags, crm_ipc_multipart)) { header 1420 lib/common/ipc_client.c bool is_end = pcmk_is_set(header->flags, crm_ipc_multipart_end); header 1423 lib/common/ipc_client.c client->server_name, header->qb.id, is_end ? "final " : "", header 1424 lib/common/ipc_client.c index, header->qb.size, ms_timeout); header 1429 lib/common/ipc_client.c client->server_name, header->qb.id, header->qb.size, header 1477 lib/common/ipc_client.c client->server_name, header->qb.id); header 1482 lib/common/ipc_client.c rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes, reply); header 1506 lib/common/ipc_client.c QB_XS " rc=%d", client->server_name, header->qb.id, rc); header 1510 lib/common/ipc_client.c client->server_name, header->qb.id, pcmk_strerror(rc), header 1516 lib/common/ipc_client.c client->server_name, header->qb.id, header 45 lib/common/ipc_common.c pcmk__valid_ipc_header(const pcmk__ipc_header_t *header) header 47 lib/common/ipc_common.c if (header == NULL) { header 51 lib/common/ipc_common.c } else if (header->version > PCMK__IPC_VERSION) { header 53 lib/common/ipc_common.c header->version, PCMK__IPC_VERSION); header 102 lib/common/ipc_common.c pcmk__ipc_header_t *header = (pcmk__ipc_header_t *) (void *) data; header 106 lib/common/ipc_common.c if (!pcmk__valid_ipc_header(header)) { header 110 lib/common/ipc_common.c if (pcmk_is_set(header->flags, crm_ipc_multipart_end)) { header 117 lib/common/ipc_common.c CRM_CHECK(buffer != NULL && *buffer != NULL && header->part_id != 0, header 119 lib/common/ipc_common.c CRM_CHECK(full_header->qb.id == header->qb.id, return EBADMSG); header 120 lib/common/ipc_common.c g_byte_array_append(*buffer, payload, header->size); header 124 lib/common/ipc_common.c header->qb.id, header->part_id, header->qb.size); header 126 lib/common/ipc_common.c } else if (pcmk_is_set(header->flags, crm_ipc_multipart)) { header 127 lib/common/ipc_common.c if (header->part_id == 0) { header 142 lib/common/ipc_common.c pcmk__clear_ipc_flags(header->flags, "server", crm_ipc_multipart); header 145 lib/common/ipc_common.c sizeof(pcmk__ipc_header_t) + header->size - 1); header 156 lib/common/ipc_common.c CRM_CHECK(full_header->qb.id == header->qb.id, return EBADMSG); header 157 lib/common/ipc_common.c g_byte_array_append(*buffer, payload, header->size - 1); header 162 lib/common/ipc_common.c header->qb.id, header->part_id, header->qb.size); header 174 lib/common/ipc_common.c sizeof(pcmk__ipc_header_t) + header->size); header 177 lib/common/ipc_common.c header->qb.id, header->qb.size); header 404 lib/common/ipc_server.c pcmk__ipc_header_t *header = (void *) c->buffer->data; header 405 lib/common/ipc_server.c char *text = (char *) header + sizeof(pcmk__ipc_header_t); header 407 lib/common/ipc_server.c if (!pcmk__valid_ipc_header(header)) { header 412 lib/common/ipc_server.c *id = header->qb.id; header 416 lib/common/ipc_server.c *flags = header->flags; header 419 lib/common/ipc_server.c if (pcmk_is_set(header->flags, crm_ipc_proxied)) { header 427 lib/common/ipc_server.c pcmk__assert(text[header->size - 1] == 0); header 491 lib/common/ipc_server.c pcmk__ipc_header_t *header = NULL; header 530 lib/common/ipc_server.c header = event[0].iov_base; header 532 lib/common/ipc_server.c header->qb.id, c->ipcs, c->pid, qb_rc, header 604 lib/common/ipc_server.c pcmk__ipc_header_t *header = NULL; header 612 lib/common/ipc_server.c header = calloc(1, sizeof(pcmk__ipc_header_t)); header 613 lib/common/ipc_server.c if (header == NULL) { header 621 lib/common/ipc_server.c iov[0].iov_base = header; header 623 lib/common/ipc_server.c header->version = PCMK__IPC_VERSION; header 654 lib/common/ipc_server.c header->size = payload_size + 1; header 662 lib/common/ipc_server.c iov[1].iov_len = header->size; header 669 lib/common/ipc_server.c header->size = payload_size + 1; header 672 lib/common/ipc_server.c iov[1].iov_len = header->size; header 675 lib/common/ipc_server.c header->part_id = index; header 676 lib/common/ipc_server.c header->qb.size = iov[0].iov_len + iov[1].iov_len; header 677 lib/common/ipc_server.c header->qb.id = (int32_t)request; /* Replying to a specific request */ header 680 lib/common/ipc_server.c pcmk__set_ipc_flags(header->flags, "multipart ipc", header 683 lib/common/ipc_server.c pcmk__set_ipc_flags(header->flags, "multipart ipc", header 688 lib/common/ipc_server.c pcmk__assert(header->qb.size > 0); header 690 lib/common/ipc_server.c *bytes = header->qb.size; header 707 lib/common/ipc_server.c id_for_server_event(pcmk__ipc_header_t *header) header 711 lib/common/ipc_server.c if (pcmk_is_set(header->flags, crm_ipc_multipart) && (header->part_id != 0)) { header 723 lib/common/ipc_server.c pcmk__ipc_header_t *header = iov[0].iov_base; header 735 lib/common/ipc_server.c pcmk__set_ipc_flags(header->flags, "server event", flags); header 745 lib/common/ipc_server.c if (header->qb.id == 0) { header 746 lib/common/ipc_server.c header->qb.id = id_for_server_event(header); header 774 lib/common/ipc_server.c CRM_LOG_ASSERT(header->qb.id != 0); /* Replying to a specific request */ header 776 lib/common/ipc_server.c if (pcmk_is_set(header->flags, crm_ipc_multipart_end)) { header 777 lib/common/ipc_server.c part_text = crm_strdup_printf(" (final part %d) ", header->part_id); header 778 lib/common/ipc_server.c } else if (pcmk_is_set(header->flags, crm_ipc_multipart)) { header 779 lib/common/ipc_server.c if (header->part_id == 0) { header 780 lib/common/ipc_server.c part_text = crm_strdup_printf(" (initial part %d) ", header->part_id); header 782 lib/common/ipc_server.c part_text = crm_strdup_printf(" (part %d) ", header->part_id); header 789 lib/common/ipc_server.c if (qb_rc < header->qb.size) { header 796 lib/common/ipc_server.c header->qb.id, part_text, c->pid, pcmk_rc_str(rc), header 797 lib/common/ipc_server.c header->qb.size, qb_rc, c->ipcs); header 801 lib/common/ipc_server.c header->qb.id, part_text, qb_rc, c->ipcs, c->pid); header 99 lib/common/remote.c struct remote_header_v0 *header = (struct remote_header_v0 *)remote->buffer; header 103 lib/common/remote.c } else if(header->endian != ENDIAN_LOCAL) { header 104 lib/common/remote.c uint32_t endian = __swab32(header->endian); header 110 lib/common/remote.c ENDIAN_LOCAL, header->endian, endian); header 114 lib/common/remote.c header->id = __swab64(header->id); header 115 lib/common/remote.c header->flags = __swab64(header->flags); header 116 lib/common/remote.c header->endian = __swab32(header->endian); header 118 lib/common/remote.c header->version = __swab32(header->version); header 119 lib/common/remote.c header->size_total = __swab32(header->size_total); header 120 lib/common/remote.c header->payload_offset = __swab32(header->payload_offset); header 121 lib/common/remote.c header->payload_compressed = __swab32(header->payload_compressed); header 122 lib/common/remote.c header->payload_uncompressed = __swab32(header->payload_uncompressed); header 125 lib/common/remote.c return header; header 246 lib/common/remote.c struct remote_header_v0 *header; header 255 lib/common/remote.c header = pcmk__assert_alloc(1, sizeof(struct remote_header_v0)); header 257 lib/common/remote.c iov[0].iov_base = header; header 264 lib/common/remote.c header->id = id; header 265 lib/common/remote.c header->endian = ENDIAN_LOCAL; header 266 lib/common/remote.c header->version = REMOTE_MSG_VERSION; header 267 lib/common/remote.c header->payload_offset = iov[0].iov_len; header 268 lib/common/remote.c header->payload_uncompressed = iov[1].iov_len; header 269 lib/common/remote.c header->size_total = iov[0].iov_len + iov[1].iov_len; header 295 lib/common/remote.c struct remote_header_v0 *header = localized_remote_header(remote); header 297 lib/common/remote.c if (header == NULL) { header 302 lib/common/remote.c if (header->payload_compressed) { header 304 lib/common/remote.c unsigned int size_u = 1 + header->payload_uncompressed; header 306 lib/common/remote.c pcmk__assert_alloc(1, header->payload_offset + size_u); header 309 lib/common/remote.c header->payload_compressed, size_u); header 311 lib/common/remote.c rc = BZ2_bzBuffToBuffDecompress(uncompressed + header->payload_offset, &size_u, header 312 lib/common/remote.c remote->buffer + header->payload_offset, header 313 lib/common/remote.c header->payload_compressed, 1, 0); header 316 lib/common/remote.c if (rc != pcmk_rc_ok && header->version > REMOTE_MSG_VERSION) { header 318 lib/common/remote.c header->version, REMOTE_MSG_VERSION); header 329 lib/common/remote.c pcmk__assert(size_u == header->payload_uncompressed); header 331 lib/common/remote.c memcpy(uncompressed, remote->buffer, header->payload_offset); /* Preserve the header */ header 332 lib/common/remote.c remote->buffer_size = header->payload_offset + size_u; header 336 lib/common/remote.c header = localized_remote_header(remote); header 342 lib/common/remote.c CRM_LOG_ASSERT(remote->buffer[sizeof(struct remote_header_v0) + header->payload_uncompressed - 1] == 0); header 344 lib/common/remote.c xml = pcmk__xml_parse(remote->buffer + header->payload_offset); header 345 lib/common/remote.c if (xml == NULL && header->version > REMOTE_MSG_VERSION) { header 347 lib/common/remote.c header->version, REMOTE_MSG_VERSION); header 350 lib/common/remote.c crm_err("Couldn't parse: '%.120s'", remote->buffer + header->payload_offset); header 438 lib/common/remote.c struct remote_header_v0 *header = localized_remote_header(remote); header 441 lib/common/remote.c if(header) { header 443 lib/common/remote.c read_len = header->size_total; header 501 lib/common/remote.c header = localized_remote_header(remote); header 502 lib/common/remote.c if(header) { header 503 lib/common/remote.c if(remote->buffer_offset < header->size_total) { header 505 lib/common/remote.c remote->buffer_offset, header->size_total);