serverConnectionThread.h

Go to the documentation of this file.

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


#pragma once

#include "clientServerExConnDllDefines.h"

#include <vlutil/vlRunnable.h>
#include <vlutil/vlThread.h>
#include <vl/hExerciseConn.h>
#include <vlutil/vlSmartPointers.h>
#include <vlutil/vlTime.h>

namespace MAKTrafficClientServerExConn
{
   class DtServerExerciseConnection;
   class DtServerConnectionThread;
   typedef DtBoost::shared_ptr<DtServerConnectionThread> DtServerConnectionThreadSP;
}

namespace MAKTrafficClientServerExConn
{
   class DT_DLL_CSEC DtServerConnectionThread : public DtRunnable
   {
   private:

      DtServerConnectionThread(const DtServerConnectionThread& orig);

      DtServerConnectionThread& operator=(const DtServerConnectionThread& orig);

   public:

      DtServerConnectionThread(const DtExerciseConnInitializer& init, DtExerciseConn::InitializationStatus* status = 0);

      DtServerConnectionThread(const char* execName, 
         const char* federateName,
         DtFomMapper* mapper = DtRprFomMapper::create(0),
         const char* fedFileName = 0, 
         DtExerciseConn::InitializationStatus* status = 0);

      DtServerConnectionThread(const char* execName, 
         const char* federateName,
         const char* dsoName, 
         const char* fedFileName = 0,
         void* fomMapInitData = 0, 
         DtExerciseConn::InitializationStatus* status = 0);


      virtual ~DtServerConnectionThread();

      virtual void start();

      virtual void join();

      virtual void stop(bool block);

      virtual bool running() const;

      virtual bool started() const;

      virtual void run();

      virtual void setTickMin(DtTime minValue);

      virtual DtTime tickMin() const;

      virtual void setTickMax(DtTime maxValue);

      virtual DtTime tickMax() const;

      virtual void enableAsynchronousCallbacks(DtTime sleepTime);

      virtual void disableAsynchronousCallbacks();

   protected:

      virtual void setRunning(bool value);

   protected:

      DtServerExerciseConnection* myServerConnection;

      DtBoost::shared_ptr<DtThread> myThread;

      mutable DtMutex myMutex;

      bool myRunningFlag;

      DtTime myMin;

      DtTime myMax;

      DtClock myClock;

      DtTime myCheckShutdownInterval;

      bool myAsynchronousCallbacks;

   };
}