serverFederateAmbassadorBase.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 1992-2025 MAK Technologies, Inc
** All rights reserved.
******************************************************************************/


#pragma once

#if DtHLA

#include "clientServerExConnDllDefines.h"
#include "fedAmbCallback.h"
#include "fedAmbCallbackBuffer.h"

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

namespace MAKTrafficClientServerExConn
{
   class DtServerExerciseConnection;
   class DtClientExerciseConnection;

   class DT_DLL_CSEC DtServerFederateAmbassadorBase
   {
   protected:
      DtServerFederateAmbassadorBase( const DtServerFederateAmbassadorBase& src );
      DtServerFederateAmbassadorBase& operator=( const DtServerFederateAmbassadorBase& src );

   public:
      DtServerFederateAmbassadorBase();

      virtual ~DtServerFederateAmbassadorBase()
         throw( RTI::FederateInternalError );

      virtual void setServerConnection(DtServerExerciseConnection* serverConnection);

      virtual void setReceiveSelfReflect(unsigned long clientID, bool enableReceiveSelfReflect);

      virtual bool receiveSelfReflectEnabled(unsigned long clientID) const;

      virtual int invokeCallbacks(DtClientExerciseConnection* client,
         double maximum=-1, double minimum=0);

      virtual bool flush(DtTime sleepTime, DtTime maxTime);

      virtual void clear();

      virtual bool transferSelfReflects(unsigned int clientID);

      virtual double transferSelfReflects();

      virtual void clearOpenSlots();

      virtual void resetConnection(unsigned int clientID);

      virtual void resetConnections();

   public:

      static void setQueueSize(unsigned int size);

   protected:

      virtual void pushCallback(DtTaCallback* callback, unsigned int clientID=0,
         bool callIsSelfReflect=false);

      virtual void pushSelfReflect(DtTaCallback* callback, unsigned int clientID);

      virtual void addConnection(DtClientExerciseConnection* conn);

      virtual void removeConnection(DtClientExerciseConnection* conn);

      virtual bool flushCallback(int callbackIndex, DtTime sleepTime, DtTime timeToQuit);

      virtual void clearSelfReflects(unsigned int clientID);

      virtual void clearSelfReflects();

   protected:

      static void addConnection(DtClientExerciseConnection* conn, void* usr);

      static void removeConnection(DtClientExerciseConnection* conn, void* usr);

   protected:

      DtServerExerciseConnection* myServerConnection;

      DtTaCallbackVector myFedAmbCallbackQueue;

      DtTaCallbackQueueVector myClientSelfReflectQueues;

      DtTaCallbackQueueVector myServerSelfReflectQueues;

      unsigned int myNumberPendingCallbacks;

      unsigned int myNextCallbackIndex;

      std::vector<unsigned int> myConnectionCallbackIndex;

      std::set<unsigned int> myConnectionIDs;

      std::set<unsigned int> myReceiveSelfReflectIDs;

      DtClock myClock;

      int myNewestIndex;

      unsigned int myOldestIndex;

   protected:

      static unsigned int theQueueSize;

   };
}

#endif