messageExecutive.h

Go to the documentation of this file.

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


#pragma once

#include "vrfmsgs/simMessage.h"
#include <vlutil/vlTime.h>
#include <readerWriter/noArgumentCallbackList.h>

#include <map>
#include <list>

#include <tbb/recursive_mutex.h>

typedef DtCallbackList<DtSimMessage*>::DtCallbackFunctionType DtMessageCallbackFcn;


#include "vrfmsgs/vrfmsgsDefines.h"
#include <vector>

class DT_DLL_vrfmsgs DtMessageExecutive
{
public:

   DtMessageExecutive();

   virtual ~DtMessageExecutive();

   virtual void addSimMessageCallback(DtMessageCallbackFcn fcn, 
      void* usrData);

   virtual void removeSimMessageCallback(DtMessageCallbackFcn fcn, 
      void* usrData);

   virtual void processMessage(const DtSimMessage& msg);

public:
   static unsigned generateMessageId();

   static int maximumContentSize();
   static void setMaximumContentSize(int sz);

   static unsigned maximumSignalDataSize();

   static DtTime timeoutCheckInterval();
   static void setTimeoutCheckInterval(DtTime nSecs);
   static DtTime timeoutDuration();
   static void setTimeoutDuration(DtTime nSecs);

protected:
   DtMessageExecutive(const DtMessageExecutive& orig);

   DtMessageExecutive& operator=(const DtMessageExecutive& orig);

   typedef DtCallbackList<DtSimMessage*> DtSimMessageCallbackList;
   mutable DtSimMessageCallbackList mySimMessageCallbackList;

   static int     theMaximumContentSize;
   static unsigned theMaxSignalDataSize;

   static unsigned   theSplitId;

   static DtTime  theTimeoutCheckInterval;
   static DtTime  theTimeoutDuration;
};

class DT_DLL_vrfmsgs DtIntMessageExecutive : public DtMessageExecutive
{
public:

   typedef std::map<int, DtSimMessageCallbackList > DtIntCallbackMap;

   DtIntMessageExecutive();

   virtual ~DtIntMessageExecutive();

   virtual void addMessageCallback(int type, DtMessageCallbackFcn fcn, 
      void* usrData);

   virtual void removeMessageCallback(int type, DtMessageCallbackFcn fcn, 
      void* usrData);

   virtual void processMessage(const DtSimMessage& msg);

   virtual int messageType(const DtSimMessage & message) const = 0;

protected:
   DtIntMessageExecutive(const DtIntMessageExecutive& orig);

   DtIntMessageExecutive& operator=(const DtIntMessageExecutive& orig);

   DtIntCallbackMap  myIntCallbackMap;
   mutable tbb::recursive_mutex myListMutex;
};

class DT_DLL_vrfmsgs DtStringMessageExecutive : public DtMessageExecutive
{
public:

   typedef std::map<DtString, DtSimMessageCallbackList > DtStringCallbackMap;

   DtStringMessageExecutive();

   virtual ~DtStringMessageExecutive();

   virtual void addMessageCallback(const DtString& type, DtMessageCallbackFcn fcn, 
      void* usrData);

   virtual void removeMessageCallback(const DtString& type, DtMessageCallbackFcn fcn, 
      void* usrData);

   virtual void processMessage(const DtSimMessage& msg);

   virtual DtString messageType(const DtSimMessage & message) const = 0;

protected:
   DtStringMessageExecutive(const DtStringMessageExecutive& orig);

   DtStringMessageExecutive& operator=(const DtStringMessageExecutive& orig);

   DtStringCallbackMap  myStringCallbackMap;
   mutable tbb::recursive_mutex myListMutex;
};