pControlMessage.h

Go to the documentation of this file.

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


#pragma once

#include <portal/pMessage.h>

namespace MAKVrExchange
{

   class DtPortalConnection;

   class DT_DLL_LIBPORTAL DtPortalControlMessage : public DtPortalMessage
   {
   public:

      typedef void (*MessageCbFcn)( const DtPortalMessage& message, void* usr );

   public:

      DtPortalControlMessage( DtPortalMessageKind kind );

      DtPortalControlMessage( const DtPortalControlMessage& original );

      virtual ~DtPortalControlMessage();


      DtDEC_ATTRIBUTE( DtString, BrokerName, brokerName );

      DtDEC_ATTRIBUTE( DtU32, BrokerId, brokerId );

      DtDEC_ATTRIBUTE( DtU32, BrokerType, brokerType );


   public:

      virtual unsigned int netSize() const;
      virtual void writeSelfToBuffer( void* buffer, int bufferSize ) const;
      virtual void readSelfFromBuffer( const void* buffer, int bufferSize );

      virtual std::ostream& printDataToStream( std::ostream& str ) const;

   };


   template <DtPortalMessageKind V_MessageKind>
   class DtPortalControlMessageTemplate: public DtPortalControlMessage
   {
   public:

      typedef void (*DtPortalControlMessageCb)(
         const DtPortalControlMessageTemplate<V_MessageKind>& msg, void* usr );

   public:

      DtPortalControlMessageTemplate();

      virtual ~DtPortalControlMessageTemplate();

      static void addCallback( DtPortalConnection* pConn,
         DtPortalControlMessageCb cb, void* usr );

      static void removeCallback( DtPortalConnection* pConn,
         DtPortalControlMessageCb cb, void* usr );

   public:

#ifdef _WIN32
      static const DtPortalMessageKind theKind = V_MessageKind;
#else
      static const DtPortalMessageKind theKind;
#endif

      static DtPortalMessage* create();

   };


   class DT_DLL_LIBPORTAL DtFilterObjectMessage
      : public DtPortalControlMessageTemplate<DtObjectFilterKind>
   {
   public:

      typedef DtPortalControlMessageTemplate<DtObjectFilterKind> BaseClassType;

      typedef void (*MessageCallbackType)(
         const DtFilterObjectMessage& message, void* userData );

   public:

      static DtPortalMessage* create();

      DtFilterObjectMessage();

      DtFilterObjectMessage( const DtFilterObjectMessage& other );

      virtual ~DtFilterObjectMessage();

      DtFilterObjectMessage& operator = ( const DtFilterObjectMessage& other );


      bool operator == ( const DtFilterObjectMessage& other ) const;
      bool operator != ( const DtFilterObjectMessage& other ) const;


      static void addCallback( DtPortalConnection* connection,
         MessageCallbackType callbackFunction, void* userData );
      static void removeCallback( DtPortalConnection* connection,
         MessageCallbackType callbackFunction, void* userData);

      virtual unsigned int netSize() const;
      virtual void writeSelfToBuffer( void* buffer, int bufferSize ) const;
      virtual void readSelfFromBuffer( const void* buffer, int bufferSize );

      virtual std::ostream& printDataToStream( std::ostream& stream ) const;


      DtDEC_ATTRIBUTE( DtString, ObjectId, objectId );

      DtDEC_ATTRIBUTE( DtEntityIdentifier, EntityId, entityId );

      DtDEC_ATTRIBUTE( DtEntityType, EntityType, entityType );

      DtDEC_ATTRIBUTE( DtU16, FilterType, filterType );

      DtDEC_ATTRIBUTE( DtString, MarkingText, markingText );

      DtDEC_ATTRIBUTE( bool, FilterFlag, filterFlag );


   };


   typedef DtPortalControlMessageTemplate<DtBrokerShutdownRequestKind> DtPortalBrokerShutdownRequestMessage;

   typedef DtPortalControlMessageTemplate<DtBrokerEnableOneToOneKind> DtPortalBrokerEnableOneToOneMessage;


   typedef DtPortalControlMessageTemplate<DtBrokerDisableOneToOneKind> DtPortalBrokerDisableOneToOneMessage;

   typedef DtPortalControlMessageTemplate<DtBrokerExitingMessageKind>  DtBrokerExitingMessage;

   typedef DtPortalControlMessageTemplate<DtBrokerStartedMessageKind> DtBrokerStartedMessage;

   typedef DtPortalControlMessageTemplate<DtBrokerConnectingMessageKind> DtBrokerConnectingMessage;

   typedef DtPortalControlMessageTemplate<DtBrokerRunningMessageKind> DtBrokerRunningMessage;

   typedef DtPortalControlMessageTemplate<DtRequestBrokerStartMessageKind> DtBrokerStartRequest;

   typedef DtPortalControlMessageTemplate<DtRequestBrokerLaunchGuiMessageKind> DtBrokerLaunchGuiRequest;

   typedef DtPortalControlMessageTemplate<DtAbnormalBrokerExitKind> DtAbnormalBrokerExitMessage;

   typedef DtPortalControlMessageTemplate<DtHeartbeatRequestMessageKind> DtHeartbeatRequest;

   typedef DtPortalControlMessageTemplate<DtHeartbeatResponseMessageKind> DtHeartbeatResponse;

}

#define _pControlMessage_INL_
#include <portal/pControlMessage.inl>
#undef _pControlMessage_INL_