header            102 include/crm/common/cmdline_internal.h                          const char *header, const char *desc,
header             58 lib/cluster/cpg.c     struct qb_ipc_response_header header __attribute__ ((aligned(8)));
header            365 lib/cluster/cpg.c     int32_t payload_size = msg->header.size - sizeof(pcmk__cpg_msg_t);
header            373 lib/cluster/cpg.c                 (int) msg->header.size,
header            379 lib/cluster/cpg.c     if (msg->header.error != CS_OK) {
header            385 lib/cluster/cpg.c                 msg->header.error,
header            397 lib/cluster/cpg.c                 (int) msg->header.size, (int) msg_data_len(msg),
header            420 lib/cluster/cpg.c               (int) msg->header.size, (msg->is_compressed? "compressed " : ""),
header            493 lib/cluster/cpg.c         *kind = msg->header.id;
header            543 lib/cluster/cpg.c             msg->header.size, msg->size, msg->compressed_size);
header            948 lib/cluster/cpg.c     msg->header.id = msg_class;
header            949 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            992 lib/cluster/cpg.c             msg->header.size = sizeof(pcmk__cpg_msg_t) + new_size;
header            993 lib/cluster/cpg.c             msg = pcmk__realloc(msg, msg->header.size);
header           1002 lib/cluster/cpg.c             msg = pcmk__realloc(msg, msg->header.size);
header           1012 lib/cluster/cpg.c     iov->iov_len = msg->header.size;
header            133 lib/common/cmdline.c                     const char *header, const char *desc,
header            138 lib/common/cmdline.c     group = g_option_group_new(name, header, desc, NULL, NULL);
header            259 lib/common/crmcommon_private.h bool pcmk__valid_ipc_header(const pcmk__ipc_header_t *header);
header            966 lib/common/ipc_client.c     pcmk__ipc_header_t *header = (pcmk__ipc_header_t *)(void*)client->buffer;
header            968 lib/common/ipc_client.c     if (header->size_compressed) {
header            970 lib/common/ipc_client.c         unsigned int size_u = 1 + header->size_uncompressed;
header            976 lib/common/ipc_client.c                  header->size_compressed, size_u);
header            979 lib/common/ipc_client.c                                         client->buffer + sizeof(pcmk__ipc_header_t), header->size_compressed, 1, 0);
header            996 lib/common/ipc_client.c         CRM_ASSERT(size_u == header->size_uncompressed);
header            999 lib/common/ipc_client.c         header = (pcmk__ipc_header_t *)(void*)uncompressed;
header           1006 lib/common/ipc_client.c     CRM_ASSERT(client->buffer[sizeof(pcmk__ipc_header_t) + header->size_uncompressed - 1] == 0);
header           1013 lib/common/ipc_client.c     pcmk__ipc_header_t *header = NULL;
header           1029 lib/common/ipc_client.c         header = (pcmk__ipc_header_t *)(void*)client->buffer;
header           1030 lib/common/ipc_client.c         if (!pcmk__valid_ipc_header(header)) {
header           1035 lib/common/ipc_client.c                   client->server_name, header->qb.id, header->qb.size,
header           1048 lib/common/ipc_client.c     if (header) {
header           1050 lib/common/ipc_client.c         return header->size_uncompressed;
header           1065 lib/common/ipc_client.c     pcmk__ipc_header_t *header = NULL;
header           1072 lib/common/ipc_client.c     header = (pcmk__ipc_header_t *)(void*)client->buffer;
header           1073 lib/common/ipc_client.c     return header->flags;
header           1159 lib/common/ipc_client.c     pcmk__ipc_header_t *header;
header           1200 lib/common/ipc_client.c     header = iov[0].iov_base;
header           1201 lib/common/ipc_client.c     pcmk__set_ipc_flags(header->flags, client->server_name, flags);
header           1208 lib/common/ipc_client.c     if(header->size_compressed) {
header           1219 lib/common/ipc_client.c               client->server_name, header->qb.id, header->qb.size, ms_timeout);
header           1242 lib/common/ipc_client.c                       client->server_name, header->qb.id);
header           1246 lib/common/ipc_client.c         rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes);
header           1271 lib/common/ipc_client.c                   rc, hdr->qb.id, client->server_name, header->qb.id,
header           1280 lib/common/ipc_client.c                   client->server_name, header->qb.id, rc);
header           1286 lib/common/ipc_client.c                    CRM_XS " rc=%d", client->server_name, header->qb.id, rc);
header           1290 lib/common/ipc_client.c                  client->server_name, header->qb.id, pcmk_strerror(rc),
header           1296 lib/common/ipc_client.c                  client->server_name, header->qb.id,
header             81 lib/common/ipc_common.c pcmk__valid_ipc_header(const pcmk__ipc_header_t *header)
header             83 lib/common/ipc_common.c     if (header == NULL) {
header             87 lib/common/ipc_common.c     } else if (header->version > PCMK__IPC_VERSION) {
header             89 lib/common/ipc_common.c                 header->version, PCMK__IPC_VERSION);
header            398 lib/common/ipc_server.c     pcmk__ipc_header_t *header = data;
header            400 lib/common/ipc_server.c     if (!pcmk__valid_ipc_header(header)) {
header            408 lib/common/ipc_server.c         *flags = header->flags;
header            411 lib/common/ipc_server.c     if (pcmk_is_set(header->flags, crm_ipc_proxied)) {
header            419 lib/common/ipc_server.c     if (header->size_compressed) {
header            421 lib/common/ipc_server.c         unsigned int size_u = 1 + header->size_uncompressed;
header            425 lib/common/ipc_server.c                   header->size_compressed, size_u);
header            427 lib/common/ipc_server.c         rc = BZ2_bzBuffToBuffDecompress(uncompressed, &size_u, text, header->size_compressed, 1, 0);
header            438 lib/common/ipc_server.c     CRM_ASSERT(text[header->size_uncompressed - 1] == 0);
header            504 lib/common/ipc_server.c         pcmk__ipc_header_t *header = NULL;
header            523 lib/common/ipc_server.c         header = event[0].iov_base;
header            524 lib/common/ipc_server.c         if (header->size_compressed) {
header            526 lib/common/ipc_server.c                       header->qb.id, c->ipcs, c->pid, (long long) qb_rc);
header            529 lib/common/ipc_server.c                       header->qb.id, c->ipcs, c->pid, (long long) qb_rc,
header            595 lib/common/ipc_server.c     pcmk__ipc_header_t *header = NULL;
header            601 lib/common/ipc_server.c     header = calloc(1, sizeof(pcmk__ipc_header_t));
header            602 lib/common/ipc_server.c     if (header == NULL) {
header            616 lib/common/ipc_server.c     iov[0].iov_base = header;
header            618 lib/common/ipc_server.c     header->version = PCMK__IPC_VERSION;
header            619 lib/common/ipc_server.c     header->size_uncompressed = 1 + strlen(buffer);
header            620 lib/common/ipc_server.c     total = iov[0].iov_len + header->size_uncompressed;
header            624 lib/common/ipc_server.c         iov[1].iov_len = header->size_uncompressed;
header            629 lib/common/ipc_server.c         if (pcmk__compress(buffer, (unsigned int) header->size_uncompressed,
header            633 lib/common/ipc_server.c             pcmk__set_ipc_flags(header->flags, "send data", crm_ipc_compressed);
header            634 lib/common/ipc_server.c             header->size_compressed = new_size;
header            636 lib/common/ipc_server.c             iov[1].iov_len = header->size_compressed;
header            641 lib/common/ipc_server.c             biggest = QB_MAX(header->size_compressed, biggest);
header            645 lib/common/ipc_server.c             biggest = QB_MAX(header->size_uncompressed, biggest);
header            650 lib/common/ipc_server.c                     header->size_uncompressed, max_send_size, 4 * biggest);
header            659 lib/common/ipc_server.c     header->qb.size = iov[0].iov_len + iov[1].iov_len;
header            660 lib/common/ipc_server.c     header->qb.id = (int32_t)request;    /* Replying to a specific request */
header            663 lib/common/ipc_server.c     CRM_ASSERT(header->qb.size > 0);
header            665 lib/common/ipc_server.c         *bytes = header->qb.size;
header            675 lib/common/ipc_server.c     pcmk__ipc_header_t *header = iov[0].iov_base;
header            689 lib/common/ipc_server.c     pcmk__set_ipc_flags(header->flags, "server event", flags);
header            691 lib/common/ipc_server.c         header->qb.id = id++;   /* We don't really use it, but doesn't hurt to set one */
header            715 lib/common/ipc_server.c         CRM_LOG_ASSERT(header->qb.id != 0);     /* Replying to a specific request */
header            718 lib/common/ipc_server.c         if (qb_rc < header->qb.size) {
header            724 lib/common/ipc_server.c                        header->qb.id, c->pid, pcmk_rc_str(rc),
header            725 lib/common/ipc_server.c                        header->qb.size, (long long) qb_rc, c->ipcs);
header            729 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            495 lib/common/remote.c     struct remote_header_v0 *header;
header            502 lib/common/remote.c     header = calloc(1, sizeof(struct remote_header_v0));
header            503 lib/common/remote.c     CRM_ASSERT(header != NULL);
header            505 lib/common/remote.c     iov[0].iov_base = header;
header            512 lib/common/remote.c     header->id = id;
header            513 lib/common/remote.c     header->endian = ENDIAN_LOCAL;
header            514 lib/common/remote.c     header->version = REMOTE_MSG_VERSION;
header            515 lib/common/remote.c     header->payload_offset = iov[0].iov_len;
header            516 lib/common/remote.c     header->payload_uncompressed = iov[1].iov_len;
header            517 lib/common/remote.c     header->size_total = iov[0].iov_len + iov[1].iov_len;
header            543 lib/common/remote.c     struct remote_header_v0 *header = localized_remote_header(remote);
header            545 lib/common/remote.c     if (header == NULL) {
header            550 lib/common/remote.c     if (header->payload_compressed) {
header            552 lib/common/remote.c         unsigned int size_u = 1 + header->payload_uncompressed;
header            553 lib/common/remote.c         char *uncompressed = calloc(1, header->payload_offset + size_u);
header            556 lib/common/remote.c                  header->payload_compressed, size_u);
header            558 lib/common/remote.c         rc = BZ2_bzBuffToBuffDecompress(uncompressed + header->payload_offset, &size_u,
header            559 lib/common/remote.c                                         remote->buffer + header->payload_offset,
header            560 lib/common/remote.c                                         header->payload_compressed, 1, 0);
header            562 lib/common/remote.c         if (rc != BZ_OK && header->version > REMOTE_MSG_VERSION) {
header            564 lib/common/remote.c                      header->version, REMOTE_MSG_VERSION);
header            575 lib/common/remote.c         CRM_ASSERT(size_u == header->payload_uncompressed);
header            577 lib/common/remote.c         memcpy(uncompressed, remote->buffer, header->payload_offset);       /* Preserve the header */
header            578 lib/common/remote.c         remote->buffer_size = header->payload_offset + size_u;
header            582 lib/common/remote.c         header = localized_remote_header(remote);
header            588 lib/common/remote.c     CRM_LOG_ASSERT(remote->buffer[sizeof(struct remote_header_v0) + header->payload_uncompressed - 1] == 0);
header            590 lib/common/remote.c     xml = string2xml(remote->buffer + header->payload_offset);
header            591 lib/common/remote.c     if (xml == NULL && header->version > REMOTE_MSG_VERSION) {
header            593 lib/common/remote.c                  header->version, REMOTE_MSG_VERSION);
header            596 lib/common/remote.c         crm_err("Couldn't parse: '%.120s'", remote->buffer + header->payload_offset);
header            689 lib/common/remote.c     struct remote_header_v0 *header = localized_remote_header(remote);
header            693 lib/common/remote.c     if(header) {
header            695 lib/common/remote.c         read_len = header->size_total;
header            764 lib/common/remote.c     header = localized_remote_header(remote);
header            765 lib/common/remote.c     if(header) {
header            766 lib/common/remote.c         if(remote->buffer_offset < header->size_total) {
header            769 lib/common/remote.c                       header->size_total);