splitMessageCollector.h

Go to the documentation of this file.

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

#pragma once

#include <vrlinkNetworkInterface/vrlinkNetworkInterfaceDefines.h>
#include <vlutil/vlTime.h>
#include <map>

namespace makVrf
{
   class DtSplitMessageCollector;
   typedef DtSplitMessageCollector* (*DtSplitMessageCollectorCreatorFcn)();

   class DT_DLL_vrlinkNetworkInterface DtSplitMessageCollector
   {
   public:
      struct SplitInfo
      {
         int originalContentType;
         int messageId;
         int chunkSize;
         int originalMessageSize;
         int sequenceNumber;
         int totalInSequence;
         int sizeSoFar;
      };

      DtSplitMessageCollector();
      virtual ~DtSplitMessageCollector();

      virtual bool assembleMessage(const char* inputBuffer, char*& buffer, int& dataLen, int& dataType);

      virtual unsigned int dataType(const char* inputBuffer) const;

      static void setSplitMessageCollectorCreatorFunction(DtSplitMessageCollectorCreatorFcn);
      static DtSplitMessageCollector* createSplitMessageCollector();

      virtual void processTimeouts();

      void setTimeoutTime(double);
      double timeoutTime() const
      {
         return myTimeoutTime;
      }

   protected:
      static DtSplitMessageCollectorCreatorFcn theCreatorFunction;

      struct Collection
      {
         int totalReceived;
         int totalExpected;
         double timeReceived;
         char* pData;
         char* dataLen;
      };

      typedef std::map<int, Collection> CollectedMessages;
      CollectedMessages myCollectedMessages;
      DtClock myClock;
      double myTimeoutTime;
   };
}