ambImpBase.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2010 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/

#pragma once


#include "rtiMsConfig.h"

#include <vlutil/vlTime.h>
#include <vlutil/vlSmartPointers.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 DT_DLL_LRC DtRtiAmbassadorBaseImplementor
{
protected:

   DtRtiAmbassadorBaseImplementor();

public:

   virtual ~DtRtiAmbassadorBaseImplementor();

private:
   
   DtRtiAmbassadorBaseImplementor(DtRtiAmbassadorBaseImplementor const& );

   DtRtiAmbassadorBaseImplementor& operator= (DtRtiAmbassadorBaseImplementor const& );

public:


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

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


   virtual DtFederateMgr* validateIsJoined(const char*  serviceCallName);
   virtual const DtFederateMgr* validateIsJoined(const char*  serviceCallName) const;

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

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

   virtual bool isConnected() const;

   virtual DtRIDParameters* params();

   virtual DtFederateMgr* validatedFedMgr();

   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 DtBoost::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 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;

protected:

   DtRIDParameters* myParams;

   DtConnectionMgr* myConnectMgr;

   DtFederateMgr* myFedMgr;

#ifndef DT_NO_PLUGINS

   DtRtiPluginManager* myPluginMgr;
#endif

   DtRtiAmbObserverList* myObservers;

   DtRtiAmbObserverList* myEmptyObserverList;

   DtBoost::shared_ptr<DtRtiAssistantLrcClient> myAssistantClient;

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

   DtBoost::shared_ptr< DtAssistantPrinter > myAssistantPrinter;

   bool myCallbacksEnabled;

   MAKRti::DtClock myClock;

   unsigned long myFlags;

   bool myUseBusyWaitForTick;
};