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            318 lib/cluster/cpg.c     int32_t payload_size = msg->header.size - sizeof(pcmk__cpg_msg_t);
header            326 lib/cluster/cpg.c                 (int) msg->header.size,
header            332 lib/cluster/cpg.c     if (msg->header.error != CS_OK) {
header            338 lib/cluster/cpg.c                 msg->header.error,
header            350 lib/cluster/cpg.c                 (int) msg->header.size, (int) msg_data_len(msg),
header            373 lib/cluster/cpg.c               (int) msg->header.size, (msg->is_compressed? "compressed " : ""),
header            946 lib/cluster/cpg.c     msg->header.error = CS_OK;
header            977 lib/cluster/cpg.c     msg->header.size = sizeof(pcmk__cpg_msg_t) + msg->size;
header            980 lib/cluster/cpg.c         msg = pcmk__realloc(msg, msg->header.size);
header            990 lib/cluster/cpg.c             msg->header.size = sizeof(pcmk__cpg_msg_t) + new_size;
header            991 lib/cluster/cpg.c             msg = pcmk__realloc(msg, msg->header.size);
header           1000 lib/cluster/cpg.c             msg = pcmk__realloc(msg, msg->header.size);
header           1009 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            309 lib/common/crmcommon_private.h bool pcmk__valid_ipc_header(const pcmk__ipc_header_t *header);
header           1079 lib/common/ipc_client.c     pcmk__ipc_header_t *header = (pcmk__ipc_header_t *)(void*)client->buffer;
header           1081 lib/common/ipc_client.c     if (header->size_compressed) {
header           1083 lib/common/ipc_client.c         unsigned int size_u = 1 + header->size_uncompressed;
header           1089 lib/common/ipc_client.c                  header->size_compressed, size_u);
header           1092 lib/common/ipc_client.c                                         client->buffer + sizeof(pcmk__ipc_header_t), header->size_compressed, 1, 0);
header           1102 lib/common/ipc_client.c         pcmk__assert(size_u == header->size_uncompressed);
header           1105 lib/common/ipc_client.c         header = (pcmk__ipc_header_t *)(void*)uncompressed;
header           1113 lib/common/ipc_client.c                                 + header->size_uncompressed - 1] == 0);
header           1120 lib/common/ipc_client.c     pcmk__ipc_header_t *header = NULL;
header           1135 lib/common/ipc_client.c         header = (pcmk__ipc_header_t *)(void*)client->buffer;
header           1136 lib/common/ipc_client.c         if (!pcmk__valid_ipc_header(header)) {
header           1141 lib/common/ipc_client.c                   client->server_name, header->qb.id, header->qb.size,
header           1158 lib/common/ipc_client.c     if (header) {
header           1160 lib/common/ipc_client.c         return header->size_uncompressed;
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;
header           1183 lib/common/ipc_client.c     return header->flags;
header           1269 lib/common/ipc_client.c     pcmk__ipc_header_t *header;
header           1310 lib/common/ipc_client.c     header = iov[0].iov_base;
header           1311 lib/common/ipc_client.c     pcmk__set_ipc_flags(header->flags, client->server_name, flags);
header           1318 lib/common/ipc_client.c     if(header->size_compressed) {
header           1329 lib/common/ipc_client.c               client->server_name, header->qb.id, header->qb.size, ms_timeout);
header           1352 lib/common/ipc_client.c                       client->server_name, header->qb.id);
header           1356 lib/common/ipc_client.c         rc = internal_ipc_get_reply(client, header->qb.id, ms_timeout, &bytes);
header           1381 lib/common/ipc_client.c                   rc, hdr->qb.id, client->server_name, header->qb.id,
header           1390 lib/common/ipc_client.c                   client->server_name, header->qb.id, rc);
header           1396 lib/common/ipc_client.c                    QB_XS " rc=%d", client->server_name, header->qb.id, rc);
header           1400 lib/common/ipc_client.c                  client->server_name, header->qb.id, pcmk_strerror(rc),
header           1406 lib/common/ipc_client.c                  client->server_name, header->qb.id,
header            107 lib/common/ipc_common.c pcmk__valid_ipc_header(const pcmk__ipc_header_t *header)
header            109 lib/common/ipc_common.c     if (header == NULL) {
header            113 lib/common/ipc_common.c     } else if (header->version > PCMK__IPC_VERSION) {
header            115 lib/common/ipc_common.c                 header->version, PCMK__IPC_VERSION);
header            402 lib/common/ipc_server.c     pcmk__ipc_header_t *header = data;
header            404 lib/common/ipc_server.c     if (!pcmk__valid_ipc_header(header)) {
header            412 lib/common/ipc_server.c         *flags = header->flags;
header            415 lib/common/ipc_server.c     if (pcmk_is_set(header->flags, crm_ipc_proxied)) {
header            423 lib/common/ipc_server.c     if (header->size_compressed) {
header            425 lib/common/ipc_server.c         unsigned int size_u = 1 + header->size_uncompressed;
header            429 lib/common/ipc_server.c                   header->size_compressed, size_u);
header            431 lib/common/ipc_server.c         rc = BZ2_bzBuffToBuffDecompress(uncompressed, &size_u, text, header->size_compressed, 1, 0);
header            444 lib/common/ipc_server.c     pcmk__assert(text[header->size_uncompressed - 1] == 0);
header            510 lib/common/ipc_server.c         pcmk__ipc_header_t *header = NULL;
header            529 lib/common/ipc_server.c         header = event[0].iov_base;
header            530 lib/common/ipc_server.c         if (header->size_compressed) {
header            532 lib/common/ipc_server.c                       header->qb.id, c->ipcs, c->pid, (long long) qb_rc);
header            535 lib/common/ipc_server.c                       header->qb.id, c->ipcs, c->pid, (long long) qb_rc,
header            599 lib/common/ipc_server.c     pcmk__ipc_header_t *header = NULL;
header            607 lib/common/ipc_server.c     header = calloc(1, sizeof(pcmk__ipc_header_t));
header            608 lib/common/ipc_server.c     if (header == NULL) {
header            624 lib/common/ipc_server.c     iov[0].iov_base = header;
header            626 lib/common/ipc_server.c     header->version = PCMK__IPC_VERSION;
header            627 lib/common/ipc_server.c     header->size_uncompressed = 1 + buffer->len;
header            628 lib/common/ipc_server.c     total = iov[0].iov_len + header->size_uncompressed;
header            632 lib/common/ipc_server.c         iov[1].iov_len = header->size_uncompressed;
header            641 lib/common/ipc_server.c                            (unsigned int) header->size_uncompressed,
header            645 lib/common/ipc_server.c             pcmk__set_ipc_flags(header->flags, "send data", crm_ipc_compressed);
header            646 lib/common/ipc_server.c             header->size_compressed = new_size;
header            648 lib/common/ipc_server.c             iov[1].iov_len = header->size_compressed;
header            651 lib/common/ipc_server.c             biggest = QB_MAX(header->size_compressed, biggest);
header            655 lib/common/ipc_server.c             biggest = QB_MAX(header->size_uncompressed, biggest);
header            660 lib/common/ipc_server.c                     header->size_uncompressed, max_send_size, 4 * biggest);
header            669 lib/common/ipc_server.c     header->qb.size = iov[0].iov_len + iov[1].iov_len;
header            670 lib/common/ipc_server.c     header->qb.id = (int32_t)request;    /* Replying to a specific request */
header            673 lib/common/ipc_server.c     pcmk__assert(header->qb.size > 0);
header            675 lib/common/ipc_server.c         *bytes = header->qb.size;
header            690 lib/common/ipc_server.c     pcmk__ipc_header_t *header = iov[0].iov_base;
header            704 lib/common/ipc_server.c     pcmk__set_ipc_flags(header->flags, "server event", flags);
header            706 lib/common/ipc_server.c         header->qb.id = id++;   /* We don't really use it, but doesn't hurt to set one */
header            730 lib/common/ipc_server.c         CRM_LOG_ASSERT(header->qb.id != 0);     /* Replying to a specific request */
header            733 lib/common/ipc_server.c         if (qb_rc < header->qb.size) {
header            739 lib/common/ipc_server.c                        header->qb.id, c->pid, pcmk_rc_str(rc),
header            740 lib/common/ipc_server.c                        header->qb.size, (long long) qb_rc, c->ipcs);
header            744 lib/common/ipc_server.c                       header->qb.id, (long long) 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            252 lib/common/remote.c     struct remote_header_v0 *header;
header            261 lib/common/remote.c     header = pcmk__assert_alloc(1, sizeof(struct remote_header_v0));
header            263 lib/common/remote.c     iov[0].iov_base = header;
header            270 lib/common/remote.c     header->id = id;
header            271 lib/common/remote.c     header->endian = ENDIAN_LOCAL;
header            272 lib/common/remote.c     header->version = REMOTE_MSG_VERSION;
header            273 lib/common/remote.c     header->payload_offset = iov[0].iov_len;
header            274 lib/common/remote.c     header->payload_uncompressed = iov[1].iov_len;
header            275 lib/common/remote.c     header->size_total = iov[0].iov_len + iov[1].iov_len;
header            301 lib/common/remote.c     struct remote_header_v0 *header = localized_remote_header(remote);
header            303 lib/common/remote.c     if (header == NULL) {
header            308 lib/common/remote.c     if (header->payload_compressed) {
header            310 lib/common/remote.c         unsigned int size_u = 1 + header->payload_uncompressed;
header            312 lib/common/remote.c             pcmk__assert_alloc(1, header->payload_offset + size_u);
header            315 lib/common/remote.c                  header->payload_compressed, size_u);
header            317 lib/common/remote.c         rc = BZ2_bzBuffToBuffDecompress(uncompressed + header->payload_offset, &size_u,
header            318 lib/common/remote.c                                         remote->buffer + header->payload_offset,
header            319 lib/common/remote.c                                         header->payload_compressed, 1, 0);
header            322 lib/common/remote.c         if (rc != pcmk_rc_ok && header->version > REMOTE_MSG_VERSION) {
header            324 lib/common/remote.c                      header->version, REMOTE_MSG_VERSION);
header            335 lib/common/remote.c         pcmk__assert(size_u == header->payload_uncompressed);
header            337 lib/common/remote.c         memcpy(uncompressed, remote->buffer, header->payload_offset);       /* Preserve the header */
header            338 lib/common/remote.c         remote->buffer_size = header->payload_offset + size_u;
header            342 lib/common/remote.c         header = localized_remote_header(remote);
header            348 lib/common/remote.c     CRM_LOG_ASSERT(remote->buffer[sizeof(struct remote_header_v0) + header->payload_uncompressed - 1] == 0);
header            350 lib/common/remote.c     xml = pcmk__xml_parse(remote->buffer + header->payload_offset);
header            351 lib/common/remote.c     if (xml == NULL && header->version > REMOTE_MSG_VERSION) {
header            353 lib/common/remote.c                  header->version, REMOTE_MSG_VERSION);
header            356 lib/common/remote.c         crm_err("Couldn't parse: '%.120s'", remote->buffer + header->payload_offset);
header            448 lib/common/remote.c     struct remote_header_v0 *header = localized_remote_header(remote);
header            451 lib/common/remote.c     if(header) {
header            453 lib/common/remote.c         read_len = header->size_total;
header            514 lib/common/remote.c     header = localized_remote_header(remote);
header            515 lib/common/remote.c     if(header) {
header            516 lib/common/remote.c         if(remote->buffer_offset < header->size_total) {
header            519 lib/common/remote.c                       header->size_total);