ambImpBase.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2016 VT MAK
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include "rtiMsConfig.h"

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

#include <vector>

class DtRtiAmbassadorObserver;
class DtRtiAmbObserverList;
class DtFedAmbWrapper;
class DtFederateMgr;
class DtConnectionMgr;
class DtObjectMgr;
class DtInteractionMgr;
class DtFomClassMgr;
class DtRIDParameters;
class DtRtiAssistantLrcClient;
class DtAssistantPrinter;
#ifndef DT_NO_PLUGINS
class DtRtiPluginManager;
#endif

namespace MAKRti
{
   class DtString;
   class DtFilePrinter;
   class DtPrinter;
}
class DtPrinterBuf;
class DtBufferPrinter;

class DT_DLL_LRC DtRtiAmbassadorBaseImplementor
{
protected:

   DtRtiAmbassadorBaseImplementor();

public:

   virtual ~DtRtiAmbassadorBaseImplementor();

public:


   virtual void addObserver( const MAKRti::DtString& name, DtRtiAmbassadorObserver* observer );
   virtual DtRtiAmbassadorObserver* removeObserver( const MAKRti::DtString& name );

   virtual void addFedAmbWrapper( const MAKRti::DtString& name, DtFedAmbWrapper* wrapper );
   virtual DtFedAmbWrapper* removeFedAmbWrapper( const MAKRti::DtString& name );

   virtual bool enterServiceCall( const MAKRti::DtString& serviceCallName );

   virtual void exitServiceCall( const MAKRti::DtString& serviceCallName );

   virtual bool isConnected() const;

   virtual DtRIDParameters* params();

   virtual DtFederateMgr* validatedFedMgr(const char* serviceCallName = nullptr);


   virtual DtFederateMgr* validateIsJoined(const char* serviceCallName, bool printDiagnostic = false);
   virtual const DtFederateMgr* validateIsJoined(const char* serviceCallName, bool printDiagnostic = false) const;

   virtual DtFederateMgr* nakedFedMgr();

   virtual DtConnectionMgr* validatedConnectMgr();

   virtual DtConnectionMgr* nakedConnectMgr();

   virtual DtObjectMgr* objMgr();

   virtual DtInteractionMgr* interMgr();

   virtual DtFomClassMgr* fomMgr();

   virtual DtRtiAmbObserverList* observers();

   virtual const DtRtiAmbObserverList* observers() const;

   virtual void enableLogging();

   virtual std::shared_ptr<MAKRti::DtFilePrinter> logPrinter();

   unsigned long flags() const;

protected:

   enum DtProcessingModelOverride
   {
      DtImmediateCallbacks = 0,
      DtEvokedCallbacks,
      DtDefaultModel
   };

   virtual void setupConnection( const std::vector<MAKRti::DtString>& rid,
      DtProcessingModelOverride processingModelOverride = DtDefaultModel );

   virtual void performParameterOverrides( DtRIDParameters& ridParams,
      DtProcessingModelOverride processingModelOverride ) const;

   virtual bool completeConnection( MAKRti::DtString& errorMessage );

   virtual void clearConnection();
   virtual void clearManagers();

   virtual void shutdown();

   virtual bool performMulticastDiscovery();

   virtual void printDisabledService( const MAKRti::DtString& service );

   virtual unsigned long incrementServiceCallCount();

   virtual bool tickOnce();

   virtual void throwInternalError( const MAKRti::DtString& errorMessage ) const = 0;

   virtual void throwNotConnected( const MAKRti::DtString& errorMessage ) const = 0;

   virtual void throwNotJoined( const MAKRti::DtString& errorMessage ) const = 0;

   // Attach DtStreams to printer
   virtual void attachStreams(MAKRti::DtPrinter* printer);

   // Detach DtStreams from printer
   virtual void detachStreams(MAKRti::DtPrinter* printer);

   // Detach DtStreams from all printers
   virtual void detachAllStreams();

private:

   DtRtiAmbassadorBaseImplementor( const DtRtiAmbassadorBaseImplementor& );

   DtRtiAmbassadorBaseImplementor& operator = ( const DtRtiAmbassadorBaseImplementor& );

protected:

   DtRIDParameters* myParams;

   DtConnectionMgr* myConnectMgr;

   DtFederateMgr* myFedMgr;

#ifndef DT_NO_PLUGINS
   DtRtiPluginManager* myPluginMgr;
#endif

   DtRtiAmbObserverList* myObservers;

   DtRtiAmbObserverList* myEmptyObserverList;

   std::shared_ptr<DtRtiAssistantLrcClient> myAssistantClient;

   std::shared_ptr<MAKRti::DtFilePrinter> myLogPrinter;

   std::shared_ptr<DtAssistantPrinter> myAssistantPrinter;

   std::shared_ptr<DtPrinterBuf> myPrinterBuffer;
   std::shared_ptr<DtBufferPrinter> myBufferPrinter;


   bool myCallbacksEnabled;

   MAKRti::DtClock myClock;

   unsigned long myFlags;

   bool myUseBusyWaitForTick;

   bool myImmediateCallbackModel;

   MAKRti::DtString myErrorMessage;

};