Message.cpp

#include "Message.h"
 
Cogs::Network::Message::Pool  Cogs::Network::Message::messagePool;       // List of free messages that can be reused.
Cogs::Mutex                   Cogs::Network::Message::mutex;
 
Cogs::Network::Message::Ptr Cogs::Network::Message::allocate(uint32_t id) {
  Message*          message = nullptr;
  std::unique_lock  lock(mutex);
 
  if (!messagePool.empty()) {
    message = messagePool.back();
    messagePool.pop_back();
  }
  else {
    message = new Message();
  }
 
  message->identifier = id;
  return Ptr(message, &deleteMessage);
}
 
Cogs::Network::Message::Ptr Cogs::Network::Message::duplicate(const Message& src) {
  Ptr msg = allocate(src.getID());
 
  msg->write(src.data(), src.size());
  return msg;
}
 
void Cogs::Network::Message::flush() {
  std::unique_lock  lock(mutex);
 
  for (Message* message : messagePool) {
    delete message;
  }
  messagePool.clear();
}
 
Cogs::Network::Message::Message() : MemoryBuffer(1024, true) {
}
 
Cogs::Network::Message::Message(uint32_t id, const Message& message) : MemoryBuffer(message.data(), message.size()) {
  identifier = id;
}
 
void Cogs::Network::Message::deleteMessage(Message* message) {
  std::unique_lock  lock(mutex);
 
  message->resize(0);
  messagePool.push_back(message);
}