messageInterface.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2013 MAK Technologies, Inc.
 * All rights reserved.
 ****************************************************************************/


#if DtTENA

#pragma once

#include <vlTena/exerciseConn.h>
#include <vlutil/vlMachineTypes.h>

namespace MAKVrExchange
{

   namespace DtTenaBroker
   {

      class DtInteraction;

      class DT_DLL_VLTENA DtMessageInterface
      {
      public:

         DtMessageInterface();

         virtual ~DtMessageInterface();

         virtual void send( const DtInteraction& inter, DtExerciseConn& exConn ) const = 0;

         virtual void addCallback( DtExerciseConn* conn, void* usr ) = 0;

         virtual void removeCallback( DtExerciseConn* conn, void* usr ) = 0;

         virtual void setSendDelayTime( double delayTimeInSeconds );

         virtual double sendDelayTime() const;

      protected:

         double mySendDelayTime;

      };

   }
}

#define DtDEFINE_MSG_CALLBACKINFO(localName)                                   \
   class localName##MessageCallbackInfo                                        \
   {                                                                           \
   public:                                                                     \
   localName##MessageCallbackInfo(DtExerciseConn* exConn,                      \
      localName##Interface* iface) :                                           \
      myExConn(exConn),                                                        \
      myInterface(iface) { }                                                   \
      \
      DtExerciseConn* exConn() { return myExConn;}                             \
      localName##Interface* interface() { return myInterface;}                 \
   protected:                                                                  \
   DtExerciseConn* myExConn;                                                   \
   localName##Interface* myInterface;                                          \
   };                                                                          \
   typedef DCT::Utils::SmartPtr<localName##MessageCallbackInfo>                \
      localName##MessageCallbackInfoPtr;

#define DtDEFINE_MESSAGE_CALLBACK(localName, omNamespace)                      \
   class localName##MessageCallback :                                          \
public virtual TENA::Middleware::Callback::Callback                            \
{                                                                              \
public:                                                                        \
localName##MessageCallback( const omNamespace::Pointer& message,               \
   const localName##MessageCallbackInfoPtr& callbackInfo) :                    \
   myCallbackInfo(callbackInfo),                                               \
   myMessage(message) { }                                                      \
   \
   virtual ~localName##MessageCallback() {}                                    \
   \
   virtual void execute()                                                      \
   {                                                                           \
      localName##Interaction* interaction =                                    \
      static_cast<localName##Interaction*>(localName##Interaction::create());  \
      localName##Interface::decode(myMessage, interaction);                    \
      myCallbackInfo->exConn()->applyInteractionCallback(interaction->name(),  \
         interaction);                                                         \
         myCallbackInfo->exConn()->incrementNumberOfMessagesProcessed();       \
         delete interaction;                                                   \
   }                                                                           \
protected:                                                                     \
localName##MessageCallbackInfoPtr myCallbackInfo;                              \
omNamespace::Pointer myMessage;                                                \
};

#define DtDEFINE_MESSAGE_CALLBACK_FACTORY(localName, omNamespace)              \
   class localName##MessageCallbackFactory :                                   \
public virtual omNamespace::MessageCallbackFactory                             \
{                                                                              \
public:                                                                        \
localName##MessageCallbackFactory(                                             \
   const localName##MessageCallbackInfoPtr& cbInfo) :                          \
   myCallbackInfo(cbInfo) { }                                                  \
   \
   virtual ~localName##MessageCallbackFactory() { }                            \
   \
   virtual std::auto_ptr<TENA::Middleware::Callback::Callback>                 \
   create(const omNamespace::Pointer& message)                                 \
   {                                                                           \
      return std::auto_ptr<TENA::Middleware::Callback::Callback>(              \
         new localName##MessageCallback(message, myCallbackInfo));             \
   }                                                                           \
protected:                                                                     \
localName##MessageCallbackInfoPtr myCallbackInfo;                              \
};

#define DtDEFINE_MESSAGE_SUB_INFO(localName, omNamespace)                      \
   class localName##SubscriptionInfo : public omNamespace::SubscriptionInfo    \
   {                                                                           \
   public:                                                                     \
   localName##SubscriptionInfo(const localName##MessageCallbackInfoPtr& cbInfo)\
   : omNamespace::SubscriptionInfo(                                            \
      omNamespace::MessageCallbackFactoryPtr(                                  \
         new localName##MessageCallbackFactory(cbInfo)))  { }                  \
         \
         virtual ~localName##SubscriptionInfo() { }                            \
   };

#endif // DtTENA