tExerciseConn.h

Go to the documentation of this file.

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


#if DtTENA

#ifndef tExerciseConn_H_
#define tExerciseConn_H_

#include <TENA/Middleware/config.h>
#include <TENA/Middleware/SDO/ID.h>
#include "baseExConn.h"
#include "tInterCbMgr.h"
#include "globalObjDes.h"
#include "eventId.h"

#include <set>


class DtExerciseConnInitializer;
class DtLromMapper;
class DtInteraction;
class DtDynamicLibrary;
class DtAmoPublisher;

class DT_DLL_VL DtExerciseConn : public DtBaseExerciseConn
{
public:
   typedef DtLromMapper* (*DtLromMapperCreator)(void* usr);
   
   typedef void (*DtLromMapperDeletor)(DtLromMapper*);

public:
   DtExerciseConn(const DtExerciseConnInitializer& init);

   DtExerciseConn(int site, int app, DtLromMapper* mapper, const DtString& execName,
      const DtString& sessionName, const DtString& orbDefaultInitRef, bool useAmo = true,
      TENA::Middleware::CommunicationProperties transport = TENA::Middleware::Reliable);

   virtual ~DtExerciseConn();

private:
   DtExerciseConn(const DtExerciseConn& other);

   DtExerciseConn& operator=(const DtExerciseConn& other);

public:
   virtual TENA::Middleware::SessionPtr sessionPtr();

   virtual void send(const DtStateMsg& msg);

   virtual void send(const DtInteraction& msg);

   virtual void sendStamped(const DtStateMsg& msg);

   virtual void sendStamped(const DtInteraction& msg);

   static DtString vrlinkVersion();

   virtual int siteId() const;

   virtual int applicationId() const;

   virtual void drainInput(int usecs = 20);

   virtual void addInteractionCallback(const DtString& name,
      DtReceiveInteractionCb cb, void* userData);

   virtual void removeInteractionCallback(const DtString& name,
      DtReceiveInteractionCb cb, void* userData);

   virtual void applyInteractionCallback(const DtString& name,
      DtInteraction* interaction);

   virtual DtLromMapper *lromMapper();

   virtual const DtGlobalObjectDesignator& nextMessageId();

   virtual const DtEventId& nextEventId();

   virtual void setReflecting();

   virtual bool reflecting() const;

   virtual DtAmoPublisher* amoPublisher();

   virtual void setTransportType(TENA::Middleware::CommunicationProperties transportType);

   virtual TENA::Middleware::CommunicationProperties transportType() const;

   virtual void incrementNumberOfObjectsServed();

   virtual void decrementNumberOfObjectsServed();

   virtual void incrementNumberOfProxies();

   virtual void decrementNumberOfProxies();
protected:
   void initializeLromMapper(const DtString& lromMapperLibName, void* initData);

   void getFuncsFromSharedLib(DtDynamicLibrary& dso, DtLromMapperCreator* creator, 
      DtLromMapperDeletor* deletor);

protected:

   TENA::Middleware::RuntimePtr myRuntimePtr;
   TENA::Middleware::ExecutionPtr myExecutionPtr;
   TENA::Middleware::SessionPtr mySessionPtr;
   TENA::Middleware::CommunicationProperties myTransportType;

   int mySiteId;
   int myApplicationId;
   int myAvailEventNum;
   DtGlobalObjectDesignator myCurrentMessageId;
   DtEventID myCurrentEventId;
   DtString myExecutionName;
   DtString mySessionName;
   DtInteractionCallbackManager myInteractionCallbackManager;
   DtLromMapper *myLromMapper;
   DtLromMapperCreator myDsoCreator;
   DtLromMapperDeletor myDsoDeletor;
   bool myUseLromMapperDeletor;
   bool myReflecting;
   DtAmoPublisher* myAmoPublisher;
   DtTime myLastAmoUpdate;

   DtDynamicLibrary* myLromMapperDso;
};

#endif
#endif