eventManagerTCP.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2019 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/

#pragma once

#include <vrfMsgTransport/eventManager.h>
#include <vlutil/vlInetTcpSocket.h>
#include <vrfMsgTransport/dataEvent.h>


class DtInetSocket;

struct MsgInfo
{
   short site;
   short host;
};

struct DtTCPHeader
{
   MsgInfo sender;
   MsgInfo receiver;
   unsigned int sequenceNumber;
   unsigned int bufSize;
   int messageVersion;
   unsigned int datumParam;
};

class DtEventManagerTCP : public makVrfEvents::DtEventManager
{
public:
   DtEventManagerTCP();

   virtual ~DtEventManagerTCP();

   virtual void sendEvent(const makVrfEvents::DtEvent&) override;

protected:
   virtual void addEvent(const makVrfEvents::DtEvent&, bool& selfReflecting) override;

   virtual void processPdu(void* buffer, int size);

   virtual bool pduHeader(DtTCPHeader&, DtInetSocket*);

   virtual bool processSocket(DtInetSocket*);

   virtual char* getPacketForNetwork(const makVrfEvents::DtDataEvent& inter, size_t& length) const;
   virtual makVrfEvents::DtDataEvent* createDataInteraction(void* buffer, size_t size) const;

   virtual bool sendEventTCP(const makVrfEvents::DtDataEvent& e);

   virtual bool sendPacketOnNetwork(char* buffer, size_t length) = 0;

   virtual bool hasNetworkConnection() const = 0;
};