MessageHeader.h

Go to the documentation of this file.

#ifndef _MADARA_MESSAGE_HEADER_H_
#define _MADARA_MESSAGE_HEADER_H_
 
#include "madara/utility/StdInt.h"
#include "madara/MadaraExport.h"
#include <string>
#include <string.h>
 
namespace madara
{
namespace transport
{
#define MADARA_IDENTIFIER_LENGTH 8
#define MADARA_IDENTIFIER "KaRL1.5"
#define MADARA_DOMAIN_MAX_LENGTH 32
#define PAIR_COUNT_TYPE uint32_t
#define KNOWLEDGE_QUALITY_TYPE uint32_t
#define CLOCK_TYPE uint64_t
#define MAX_KNOWLEDGE_KEY_LENGTH 64
#define MAX_ORIGINATOR_LENGTH 64
#define KNOWLEDGE_VALUE_TYPE madara::knowledge::KnowledgeRecord
 
static const int MAX_PACKET_SIZE = 512000;  // 512kb
 
class MADARA_EXPORT MessageHeader
{
public:
  MessageHeader();
 
  virtual ~MessageHeader();
 
  virtual uint32_t encoded_size(void) const;
 
  static uint32_t static_encoded_size(void);
 
  virtual const char* read(const char* buffer, int64_t& buffer_remaining);
 
  virtual char* write(char* buffer, int64_t& buffer_remaining);
 
  virtual std::string to_string(void);
 
  virtual bool equals(const MessageHeader& other);
 
  static uint64_t get_size(const char* buffer);
 
  static inline bool message_header_test(const char* buffer)
  {
    return strncmp(&(buffer[8]), MADARA_IDENTIFIER, 7) == 0;
  }
 
  uint64_t size;
 
  char madara_id[MADARA_IDENTIFIER_LENGTH] = {
    '\0','\0','\0','\0','\0','\0','\0','\0'
  };
 
  char domain[MADARA_DOMAIN_MAX_LENGTH] = {
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0'
  };
 
  char originator[MAX_ORIGINATOR_LENGTH] = {
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0',
    '\0','\0','\0','\0','\0','\0','\0','\0'
  };
 
  uint32_t type;
 
  uint32_t updates;
 
  uint32_t quality;
 
  uint64_t clock;
 
  uint64_t timestamp;
 
  unsigned char ttl;
};
}
}
 
#endif  // _MADARA_MESSAGE_HEADER_H_