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.3"
    #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];
      
      char                  domain[MADARA_DOMAIN_MAX_LENGTH];
      
      char                  originator[MAX_ORIGINATOR_LENGTH];
      
      uint32_t              type;

      uint32_t              updates;
      
      uint32_t              quality;
      
      uint64_t              clock;

      uint64_t              timestamp;

      unsigned char         ttl;
    };
  }
}


#endif   // _MADARA_MESSAGE_HEADER_H_