exerciseConn.h

Go to the documentation of this file.

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


#if DtTENA

#pragma once

// If <WinSock.h> or <WinSock2.h> is included before <TENA/Middleware/config.h>;
// a compile warning "warning C4005: 'FD_SETSIZE' : macro redefinition" will be
// issued. To prevent this, undefine FD_SETSIZE before including
// <vlTena/exerciseConn.h> which includes <TENA/Middleware/config.h>
// Root cause: <TENA/Middleware/config.h> eventually includes one of the
// dct-config-msvc-?.?.h headers; all of which fail to detect if FD_SETSIZE
// was previously defined as requred.
#if !defined DCT_ace_generic_config_h && defined FD_SETSIZE
#undef FD_SETSIZE
#endif

#include <vlTena/dllExport.h>

#include <TENA/Middleware/config.h>
#include <TENA/Middleware/SDO/ID.h>

#include <vlTena/interactionCallbackManager.h>

#include <vl/globalObjectDesignator.h>
#include <vl/baseExerciseConn.h>
#include <vl/eventId.h>

#include <set>

class DtDynamicLibrary;

namespace MAKVrExchange
{

   namespace DtTenaBroker
   {

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

      class DT_DLL_VLTENA 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();

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

         virtual void send( const DtStateMsg& msg );
         virtual void sendStamped( const DtStateMsg& msg );

         virtual void send( const ::DtInteraction& msg );
         virtual void sendStamped( const ::DtInteraction& msg );

         virtual void send( const DtInteraction& 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);

      private:

         DtExerciseConn(const DtExerciseConn& other);

         DtExerciseConn& operator=(const DtExerciseConn& other);

      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 // DtTENA