fedAmbCallbackBuffer.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 1992-2012 VT MAK
** All rights reserved.
******************************************************************************/


#pragma once

#if DtHLA

#include "clientServerExConnDllDefines.h"

#include <vlutil/vlTime.h>
#include <vlutil/vlString.h>

#include <queue>
#include <set>
#include <vector>

namespace MAKTrafficClientServerExConn
{

   class DtClientExerciseConnection;
   class DtTaCallback;

   class DT_DLL_CSEC DtTaCallbackBuffer
   {
   public:
      
      DtTaCallbackBuffer(DtTaCallback* callbackToMake=0, unsigned int clientID=0);

      DtTaCallbackBuffer(const DtTaCallbackBuffer& orig);

      virtual ~DtTaCallbackBuffer();

      DtTaCallbackBuffer& operator=(const DtTaCallbackBuffer& orig);

      virtual DtTaCallback* callback();

      virtual unsigned int sourceClientID();

      virtual void setCallback(DtTaCallback* callbackToMake, unsigned int clientID,
         const std::set<unsigned int>& pendingCallers, const std::set<unsigned int>& callers);


      virtual bool invokeCallback(DtClientExerciseConnection* client);

      virtual void addPending(unsigned int callerID);

      virtual void removePending(unsigned int callerID);

      virtual unsigned int callbackPending(unsigned int connID=0) const;

      virtual unsigned int callbackPendingEvaluation(unsigned int connID=0) const;

      virtual bool getCallbackPending(DtString& list) const;

      virtual bool getCallbackPendingEvaluation(DtString& list) const;

      virtual void clear();

   public:

      static void setMaximumConnections(unsigned int maxConns);

      static unsigned int maximumConnections();

   protected:

      DtTaCallback* myCallback;

      std::vector<bool> myPendingCallers;

      std::vector<bool> myCallPending;

      std::vector<bool> myCallPendingEvaluation;

      unsigned int mySourceClientID;

      DtClock myClock;

   protected:
      static unsigned int theMaxConnections;
   };

   typedef std::vector<DtTaCallbackBuffer> DtTaCallbackVector;
   typedef std::queue<DtTaCallbackBuffer> DtTaCallbackQueue;
   typedef std::vector<DtTaCallbackQueue> DtTaCallbackQueueVector;

}

#endif