IpcProcessMessageProtocol.h

#pragma once
 
#include <Foundation/Basics.h>
#include <Foundation/Communication/RemoteInterface.h>
#include <Foundation/Communication/RemoteMessage.h>
#include <Foundation/Types/UniquePtr.h>
 
class plIpcChannel;
class plMessageLoop;
 
 
class PL_FOUNDATION_DLL plIpcProcessMessageProtocol
{
public:
  plIpcProcessMessageProtocol(plIpcChannel* pChannel);
  ~plIpcProcessMessageProtocol();
 
  bool Send(plProcessMessage* pMsg);
 
 
  bool ProcessMessages();
  plResult WaitForMessages(plTime timeout = plTime::MakeZero());
 
public:
  plEvent<const plProcessMessage*> m_MessageEvent; 
 
private:
  void EnqueueMessage(plUniquePtr<plProcessMessage>&& msg);
  void SwapWorkQueue(plDeque<plUniquePtr<plProcessMessage>>& messages);
  void ReceiveMessageData(plArrayPtr<const plUInt8> data);
 
private:
  plIpcChannel* m_pChannel = nullptr;
 
  plMutex m_IncomingQueueMutex;
  plDeque<plUniquePtr<plProcessMessage>> m_IncomingQueue;
};