header 45 include/crm/cluster/internal.h cs_ipc_header_response_t header __attribute__ ((aligned(8))); header 60 include/crm/cluster/internal.h cs_ipc_header_response_t header __attribute__ ((aligned(8))); header 68 include/crm/cluster/internal.h cs_ipc_header_response_t header __attribute__ ((aligned(8))); header 85 lib/ais/plugin.c cs_ipc_header_request_t header __attribute__ ((aligned(8))); header 893 lib/ais/plugin.c ais_msg->header.size = swab32(ais_msg->header.size); header 894 lib/ais/plugin.c ais_msg->header.id = swab32(ais_msg->header.id); header 895 lib/ais/plugin.c ais_msg->header.error = swab32(ais_msg->header.error); header 932 lib/ais/plugin.c ais_msg->header.size = swab32(ais_msg->header.size); header 933 lib/ais/plugin.c ais_msg->header.id = swab32(ais_msg->header.id); header 957 lib/ais/plugin.c cs_ipc_header_response_t header __attribute((aligned(8))); header 970 lib/ais/plugin.c res_overlay->header.id = CRM_MESSAGE_IPC_ACK; header 971 lib/ais/plugin.c res_overlay->header.size = sizeof(cs_ipc_header_response_t); header 972 lib/ais/plugin.c res_overlay->header.error = CS_OK; header 973 lib/ais/plugin.c pcmk_api->ipc_response_send(conn, res_overlay, res_overlay->header.size); header 1320 lib/ais/plugin.c resp.header.id = crm_class_nodeid; header 1321 lib/ais/plugin.c resp.header.size = sizeof(struct crm_ais_nodeid_resp_s); header 1322 lib/ais/plugin.c resp.header.error = CS_OK; header 1330 lib/ais/plugin.c pcmk_api->ipc_response_send(conn, &resp, resp.header.size); header 1361 lib/ais/plugin.c int tmp_size = msg->header.size - sizeof(AIS_Message); header 1363 lib/ais/plugin.c if (sane && msg->header.size == 0) { header 1368 lib/ais/plugin.c if (sane && msg->header.error != CS_OK) { header 1369 lib/ais/plugin.c ais_err("Message header contains an error: %d", msg->header.error); header 1373 lib/ais/plugin.c AIS_CHECK(msg->header.size > sizeof(AIS_Message), header 1375 lib/ais/plugin.c msg->header.id, msg->header.size, header 1414 lib/ais/plugin.c ais_data_len(msg), msg->header.size)); header 1421 lib/ais/plugin.c ais_data_len(msg), msg->header.size); header 1427 lib/ais/plugin.c ais_data_len(msg), msg->header.size); header 1530 lib/ais/plugin.c if (mutable->header.id == service_id) { header 1531 lib/ais/plugin.c mutable->header.id = 0; /* reset this back to zero for IPC messages */ header 1533 lib/ais/plugin.c } else if (mutable->header.id != 0) { header 1534 lib/ais/plugin.c ais_err("reset header id back to zero from %d", mutable->header.id); header 1535 lib/ais/plugin.c mutable->header.id = 0; /* reset this back to zero for IPC messages */ header 1568 lib/ais/plugin.c AIS_ASSERT(ais_msg->header.size == (sizeof(AIS_Message) + ais_data_len(ais_msg))); header 1577 lib/ais/plugin.c mutable->header.error = CS_OK; header 1578 lib/ais/plugin.c mutable->header.id = SERVICE_ID_MAKE(PCMK_SERVICE_ID, 0); header 1586 lib/ais/plugin.c iovec.iov_len = mutable->header.size; header 1637 lib/ais/plugin.c msg->header.size = sizeof(struct crm_identify_msg_s); header 1641 lib/ais/plugin.c msg->header.id = SERVICE_ID_MAKE(PCMK_SERVICE_ID, 1); header 1662 lib/ais/plugin.c iovec.iov_len = msg->header.size; header 494 lib/ais/utils.c ais_msg->header.size = total_size; header 495 lib/ais/utils.c ais_msg->header.error = CS_OK; header 496 lib/ais/utils.c ais_msg->header.id = 0; header 543 lib/ais/utils.c rc = pcmk_api->ipc_dispatch_send(conn, ais_msg, ais_msg->header.size); header 572 lib/ais/utils.c ais_msg->header.id = class; header 573 lib/ais/utils.c ais_msg->header.size = total_size; header 574 lib/ais/utils.c ais_msg->header.error = CS_OK; header 381 lib/cluster/corosync.c int tmp_size = msg->header.size - sizeof(AIS_Message); header 383 lib/cluster/corosync.c if (sane && msg->header.size == 0) { header 388 lib/cluster/corosync.c if (sane && msg->header.error != CS_OK) { header 389 lib/cluster/corosync.c crm_warn("Message header contains an error: %d", msg->header.error); header 426 lib/cluster/corosync.c msg->sender.pid, msg->is_compressed, ais_data_len(msg), msg->header.size); header 433 lib/cluster/corosync.c ais_data_len(msg), msg->header.size); header 284 lib/cluster/cpg.c *kind = msg->header.id; header 328 lib/cluster/cpg.c if (msg->header.id != crm_class_members) { header 333 lib/cluster/cpg.c if (msg->header.id == crm_class_rmpeer) { header 356 lib/cluster/cpg.c msg->header.size, msg->size, msg->compressed_size); header 565 lib/cluster/cpg.c msg->header.id = class; header 566 lib/cluster/cpg.c msg->header.error = CS_OK; header 595 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + msg->size; header 598 lib/cluster/cpg.c msg = realloc_safe(msg, msg->header.size); header 608 lib/cluster/cpg.c msg->header.size = sizeof(AIS_Message) + new_size; header 609 lib/cluster/cpg.c msg = realloc_safe(msg, msg->header.size); header 616 lib/cluster/cpg.c msg = realloc_safe(msg, msg->header.size); header 626 lib/cluster/cpg.c iov->iov_len = msg->header.size; header 78 lib/cluster/legacy.c cs_ipc_header_response_t header; header 90 lib/cluster/legacy.c header.error = CS_OK; header 91 lib/cluster/legacy.c header.id = crm_class_nodeid; header 92 lib/cluster/legacy.c header.size = sizeof(cs_ipc_header_response_t); header 94 lib/cluster/legacy.c iov.iov_base = &header; header 95 lib/cluster/legacy.c iov.iov_len = header.size; header 101 lib/cluster/legacy.c CRM_CHECK(answer.header.size == sizeof(struct crm_ais_nodeid_resp_s), header 103 lib/cluster/legacy.c answer.header.id, answer.header.size, answer.header.error)); header 104 lib/cluster/legacy.c CRM_CHECK(answer.header.id == crm_class_nodeid, header 105 lib/cluster/legacy.c crm_err("Bad response id: %d", answer.header.id)); header 119 lib/cluster/legacy.c } else if (answer.header.error != CS_OK) { header 142 lib/cluster/legacy.c cs_ipc_header_response_t *header = (cs_ipc_header_response_t *)(void*)buf; header 163 lib/cluster/legacy.c CRM_CHECK(header->size == sizeof(cs_ipc_header_response_t), header 165 lib/cluster/legacy.c header->id, header->size, class, header->error)); header 167 lib/cluster/legacy.c CRM_ASSERT(buf_len >= header->size); header 168 lib/cluster/legacy.c CRM_CHECK(header->id == CRM_MESSAGE_IPC_ACK, header 169 lib/cluster/legacy.c crm_err("Bad response id (%d) for request (%d)", header->id, header 170 lib/cluster/legacy.c ais_msg->header.id)); header 171 lib/cluster/legacy.c CRM_CHECK(header->error == CS_OK, rc = header->error); header 224 lib/cluster/legacy.c if (msg->header.id == crm_class_members || msg->header.id == crm_class_quorum) { header 734 lib/cluster/legacy.c int tmp_size = msg->header.size - sizeof(AIS_Message); header 736 lib/cluster/legacy.c if (sane && msg->header.size == 0) { header 741 lib/cluster/legacy.c if (sane && msg->header.error != CS_OK) { header 742 lib/cluster/legacy.c crm_warn("Message header contains an error: %d", msg->header.error); header 779 lib/cluster/legacy.c msg->sender.pid, msg->is_compressed, ais_data_len(msg), msg->header.size); header 786 lib/cluster/legacy.c ais_data_len(msg), msg->header.size); header 450 lib/common/ipc.c struct crm_ipc_response_header *header = data; header 456 lib/common/ipc.c *flags = header->flags; header 459 lib/common/ipc.c if (is_set(header->flags, crm_ipc_proxied)) { header 466 lib/common/ipc.c if(header->version > PCMK_IPC_VERSION) { header 468 lib/common/ipc.c header->version, PCMK_IPC_VERSION); header 472 lib/common/ipc.c if (header->size_compressed) { header 474 lib/common/ipc.c unsigned int size_u = 1 + header->size_uncompressed; header 478 lib/common/ipc.c header->size_compressed, size_u); header 480 lib/common/ipc.c rc = BZ2_bzBuffToBuffDecompress(uncompressed, &size_u, text, header->size_compressed, 1, 0); header 490 lib/common/ipc.c CRM_ASSERT(text[header->size_uncompressed - 1] == 0); header 545 lib/common/ipc.c struct crm_ipc_response_header *header = NULL; header 554 lib/common/ipc.c header = event[0].iov_base; header 555 lib/common/ipc.c if (header->size_compressed) { header 557 lib/common/ipc.c header->qb.id, c->ipcs, c->pid, (long long) rc); header 560 lib/common/ipc.c header->qb.id, c->ipcs, c->pid, (long long) rc, header 616 lib/common/ipc.c struct crm_ipc_response_header *header = calloc(1, sizeof(struct crm_ipc_response_header)); header 633 lib/common/ipc.c iov[0].iov_base = header; header 635 lib/common/ipc.c header->version = PCMK_IPC_VERSION; header 636 lib/common/ipc.c header->size_uncompressed = 1 + strlen(buffer); header 637 lib/common/ipc.c total = iov[0].iov_len + header->size_uncompressed; header 641 lib/common/ipc.c iov[1].iov_len = header->size_uncompressed; header 647 lib/common/ipc.c (buffer, header->size_uncompressed, max_send_size, &compressed, &new_size)) { header 649 lib/common/ipc.c header->flags |= crm_ipc_compressed; header 650 lib/common/ipc.c header->size_compressed = new_size; header 652 lib/common/ipc.c iov[1].iov_len = header->size_compressed; header 657 lib/common/ipc.c biggest = QB_MAX(header->size_compressed, biggest); header 663 lib/common/ipc.c biggest = QB_MAX(header->size_uncompressed, biggest); header 668 lib/common/ipc.c header->size_uncompressed, max_send_size, 4 * biggest); header 672 lib/common/ipc.c free(header); header 679 lib/common/ipc.c header->qb.size = iov[0].iov_len + iov[1].iov_len; header 680 lib/common/ipc.c header->qb.id = (int32_t)request; /* Replying to a specific request */ header 683 lib/common/ipc.c CRM_ASSERT(header->qb.size > 0); header 684 lib/common/ipc.c return header->qb.size; header 692 lib/common/ipc.c struct crm_ipc_response_header *header = iov[0].iov_base; header 704 lib/common/ipc.c header->flags |= flags; header 706 lib/common/ipc.c header->qb.id = id++; /* We don't really use it, but doesn't hurt to set one */ header 728 lib/common/ipc.c CRM_LOG_ASSERT(header->qb.id != 0); /* Replying to a specific request */ header 731 lib/common/ipc.c if (rc < header->qb.size) { header 733 lib/common/ipc.c header->qb.id, c->ipcs, c->pid, header->qb.size, pcmk_strerror(rc), rc); header 737 lib/common/ipc.c header->qb.id, (long long) rc, c->ipcs, c->pid); header 1006 lib/common/ipc.c struct crm_ipc_response_header *header = (struct crm_ipc_response_header *)(void*)client->buffer; header 1008 lib/common/ipc.c if (header->size_compressed) { header 1010 lib/common/ipc.c unsigned int size_u = 1 + header->size_uncompressed; header 1016 lib/common/ipc.c header->size_compressed, size_u); header 1019 lib/common/ipc.c client->buffer + hdr_offset, header->size_compressed, 1, 0); header 1035 lib/common/ipc.c CRM_ASSERT(size_u == header->size_uncompressed); header 1038 lib/common/ipc.c header = (struct crm_ipc_response_header *)(void*)uncompressed; header 1045 lib/common/ipc.c CRM_ASSERT(client->buffer[hdr_offset + header->size_uncompressed - 1] == 0); header 1052 lib/common/ipc.c struct crm_ipc_response_header *header = NULL; header 1069 lib/common/ipc.c header = (struct crm_ipc_response_header *)(void*)client->buffer; header 1070 lib/common/ipc.c if(header->version > PCMK_IPC_VERSION) { header 1072 lib/common/ipc.c header->version, PCMK_IPC_VERSION); header 1077 lib/common/ipc.c client->name, header->qb.id, header->qb.size, client->msg_size, header 1088 lib/common/ipc.c if (header) { header 1090 lib/common/ipc.c return header->size_uncompressed; header 1105 lib/common/ipc.c struct crm_ipc_response_header *header = NULL; header 1112 lib/common/ipc.c header = (struct crm_ipc_response_header *)(void*)client->buffer; header 1113 lib/common/ipc.c return header->flags; header 1206 lib/common/ipc.c struct crm_ipc_response_header *header; header 1246 lib/common/ipc.c header = iov[0].iov_base; header 1247 lib/common/ipc.c header->flags |= flags; header 1254 lib/common/ipc.c if(header->size_compressed) { header 1264 lib/common/ipc.c client->name, header->qb.id, header->qb.size, ms_timeout); header 1272 lib/common/ipc.c client->name, header->qb.id, header->qb.size); header 1277 lib/common/ipc.c header->qb.id, client->name, header->qb.size); header 1282 lib/common/ipc.c rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout); header 1318 lib/common/ipc.c header->qb.id, client->name, client->ipc, pcmk_strerror(rc), rc, ms_timeout); header 1323 lib/common/ipc.c header->qb.id, client->name, client->ipc, pcmk_strerror(rc), rc); header 1326 lib/common/ipc.c free(header); header 112 lib/common/remote.c struct crm_remote_header_v0 *header = (struct crm_remote_header_v0 *)remote->buffer; header 116 lib/common/remote.c } else if(header->endian != ENDIAN_LOCAL) { header 117 lib/common/remote.c uint32_t endian = __swab32(header->endian); header 122 lib/common/remote.c ENDIAN_LOCAL, header->endian, endian); header 126 lib/common/remote.c header->id = __swab64(header->id); header 127 lib/common/remote.c header->flags = __swab64(header->flags); header 128 lib/common/remote.c header->endian = __swab32(header->endian); header 130 lib/common/remote.c header->version = __swab32(header->version); header 131 lib/common/remote.c header->size_total = __swab32(header->size_total); header 132 lib/common/remote.c header->payload_offset = __swab32(header->payload_offset); header 133 lib/common/remote.c header->payload_compressed = __swab32(header->payload_compressed); header 134 lib/common/remote.c header->payload_uncompressed = __swab32(header->payload_uncompressed); header 137 lib/common/remote.c return header; header 342 lib/common/remote.c struct crm_remote_header_v0 *header; header 349 lib/common/remote.c header = calloc(1, sizeof(struct crm_remote_header_v0)); header 350 lib/common/remote.c iov[0].iov_base = header; header 357 lib/common/remote.c header->id = id; header 358 lib/common/remote.c header->endian = ENDIAN_LOCAL; header 359 lib/common/remote.c header->version = REMOTE_MSG_VERSION; header 360 lib/common/remote.c header->payload_offset = iov[0].iov_len; header 361 lib/common/remote.c header->payload_uncompressed = iov[1].iov_len; header 362 lib/common/remote.c header->size_total = iov[0].iov_len + iov[1].iov_len; header 387 lib/common/remote.c struct crm_remote_header_v0 *header = crm_remote_header(remote); header 389 lib/common/remote.c if (remote->buffer == NULL || header == NULL) { header 394 lib/common/remote.c if (header->payload_compressed) { header 396 lib/common/remote.c unsigned int size_u = 1 + header->payload_uncompressed; header 397 lib/common/remote.c char *uncompressed = calloc(1, header->payload_offset + size_u); header 400 lib/common/remote.c header->payload_compressed, size_u); header 402 lib/common/remote.c rc = BZ2_bzBuffToBuffDecompress(uncompressed + header->payload_offset, &size_u, header 403 lib/common/remote.c remote->buffer + header->payload_offset, header 404 lib/common/remote.c header->payload_compressed, 1, 0); header 406 lib/common/remote.c if (rc != BZ_OK && header->version > REMOTE_MSG_VERSION) { header 408 lib/common/remote.c header->version, REMOTE_MSG_VERSION); header 418 lib/common/remote.c CRM_ASSERT(size_u == header->payload_uncompressed); header 420 lib/common/remote.c memcpy(uncompressed, remote->buffer, header->payload_offset); /* Preserve the header */ header 421 lib/common/remote.c remote->buffer_size = header->payload_offset + size_u; header 425 lib/common/remote.c header = crm_remote_header(remote); header 431 lib/common/remote.c CRM_LOG_ASSERT(remote->buffer[sizeof(struct crm_remote_header_v0) + header->payload_uncompressed - 1] == 0); header 433 lib/common/remote.c xml = string2xml(remote->buffer + header->payload_offset); header 434 lib/common/remote.c if (xml == NULL && header->version > REMOTE_MSG_VERSION) { header 436 lib/common/remote.c header->version, REMOTE_MSG_VERSION); header 439 lib/common/remote.c crm_err("Couldn't parse: '%.120s'", remote->buffer + header->payload_offset); header 520 lib/common/remote.c struct crm_remote_header_v0 *header = crm_remote_header(remote); header 522 lib/common/remote.c if(header) { header 524 lib/common/remote.c read_len = header->size_total; header 590 lib/common/remote.c header = crm_remote_header(remote); header 591 lib/common/remote.c if(header) { header 592 lib/common/remote.c if(remote->buffer_offset < header->size_total) { header 595 lib/common/remote.c header->size_total);