include/vrfMsgTransport/splitMessageCollector.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 1999-2001 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: splitMessageCollector.h,v $ $Revision: 1.2 $ $State: Exp $
*******************************************************************************/


#ifndef DtSplitMessageCollector_H_
#define DtSplitMessageCollector_H_

#include "vrfMsgTransport/vrfMsgTransportDefines.h"

#include <map>

#include <vlpi/simulationAddress.h>
#include <vrfutil/splitContentTimer.h>

class DtVrfMessageInterface;
class DtSimInterfaceMessage;
class DtSplitMessageKey;

class DT_DLL_vrfMsgTransport DtSplitMessageCollector
{
public:
   typedef std::map<DtSplitMessageKey, std::map<int, DtSimInterfaceMessage> > DtSplitMap;

public:

   DtSplitMessageCollector();

   virtual ~DtSplitMessageCollector();

   virtual void processSplitContentTimeout(const DtSplitMessageKey& key);

   virtual bool reassembleMessage(const DtSplitMessageKey& key,
      int nOriginalContentType,
      DtVrfMessageInterface& vrfMsgIf);

   virtual bool receiveMessage(
      const DtSimInterfaceMessage& msg,
      DtVrfMessageInterface& vrfMsgIf);

   virtual void timeoutOldSplits();

   virtual const DtSplitContentTimer& splitContentTimer() const;
   virtual DtSplitContentTimer& splitContentTimer();

   static void splitContentTimeoutCbk(const DtSplitMessageKey& key, void *pUsr);

protected:

   DtSplitMessageCollector(const DtSplitMessageCollector& orig);

   const DtSplitMessageCollector& operator=(
      const DtSplitMessageCollector& orig);

protected:
   DtSplitMap           mySplitMessages;
   DtSplitContentTimer  mySplitContentTimer;
};

inline const DtSplitContentTimer& DtSplitMessageCollector::splitContentTimer() const
{
   return (mySplitContentTimer);
}

inline DtSplitContentTimer& DtSplitMessageCollector::splitContentTimer()
{
   return (mySplitContentTimer);
}

#endif