Message.h

#pragma once
 
#include "../Memory/MemoryBuffer.h"
#include "../Platform/Threads.h"
 
#include <memory>
#include <mutex>
#include <vector>
 
namespace Cogs {
  namespace Network {
    class COGSFOUNDATION_API Message final : public Memory::MemoryBuffer {
      friend class MessageHub;
    public:
      using   Ptr         = std::shared_ptr<Message>;
 
                          Message();
                          Message(uint32_t id, const Message& message);
                          Message(const Message& src) = delete;
 
      static  Ptr         allocate(uint32_t id);
      static  Ptr         duplicate(const Message& src);
      static  void        flush();
 
              uint32_t    getID() const             { return identifier; }
 
    private:
      using   Pool        = std::vector<Message*>;
 
      static  Pool        messagePool;        // List of free messages that can be reused.
      static  Mutex       mutex;
              uint32_t    identifier = 0;     // ID of this message.
 
                          Message(Message&&) = delete;
              Message&    operator =(const Message&) = delete;
              Message&    operator =(Message&&) = delete;
 
      static  void        deleteMessage(Message* msg);
    };
  }
}