pConnection.h

Go to the documentation of this file.

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


#pragma once

#ifdef BuildWEBLVC
#include "../../brokers/webLvcBroker/webLvcBrokerApp/webLvcVersion.h"
#else
#include <portal/portalVersion.h>
#endif
#include <portal/pMessageFactory.h>
#include <portal/vrxExceptions.h>

#include <vlutil/vlString.h>

#include <list>
#include <map>

class DtInetTcpSocket;

namespace MAKVrExchange
{

   class DtPortalInteraction;
   class DtPortalObject;
   class DtSubscribableMessageQueue;

   //
   class DT_DLL_LIBPORTAL DtPortalConnection
   {

   public:

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

      //
      DtPortalConnection(const DtString &brokerName, DtU8 brokerId,
                         const DtString &controlQueueName,
                         const DtString &interactionQueueName,
                         const DtString &objectQueueName,
                         int port = 5111,
                         int commandLineArgc = 0,
                         char ** commandLineArgv = 0);
      virtual ~DtPortalConnection();

   private:

      DtPortalConnection(const DtPortalConnection &other);

      DtPortalConnection& operator=(const DtPortalConnection &other);

   public:

      virtual DtPortalMessageFactory* messageFactory();

      virtual void send(const DtPortalMessage& message) ;

      virtual void send(const DtPortalInteraction& inter) ;

      virtual void send(const DtPortalObject& inter);

      //
      virtual void drainInput(int maxControlMessages = -1,
                              int maxInterMessages = -1, int maxObjectMessages = -1);

      virtual DtU8 brokerId() const;

      virtual void setBrokerId(DtU8);

      virtual const DtString& brokerName() const;

      virtual DtClock* clock();

      virtual void addMessageCallback( DtPortalMessageKind msgKnd, MessageCbFcn fnc, void* usr );

      virtual void addMessageCallback( MessageCbFcn fnc, void* usr );

      virtual void removeMessageCallback( DtPortalMessageKind msgKnd, MessageCbFcn fnc, void* usr );

      virtual void removeMessageCallback( MessageCbFcn fnc, void* usr );


      virtual double receivedMessagesPerSecond() const;

      virtual double sentMessagesPerSecond() const;

      DtString lookupBrokerName( const DtU16& brokerId) const;

      DtU16 lookupBrokerId( const DtString& brokerName ) const;

      virtual void processRemoveBrokerMessage( const DtU32 id);

      virtual void processAddBrokerMessage(const DtString& name, const DtU32 id);

   public:

      static const DtString version();

      static const DtString build();

   protected:


      virtual void processMessage(const DtPortalMessage& message) const;

      virtual void drainControlQueue(int maxMessages) const;

      virtual void drainInteractionQueue(int maxMessages) const;

      virtual void drainObjectQueue(int maxMessages) const;

      virtual void drainQueue( DtSubscribableMessageQueue *messageQueue, const int maxMessages ) const;

      virtual void cleanupMessageQueues();

      virtual bool isQueueManagerOk();

   protected:

      DtSubscribableMessageQueue *myControlMessageQueue;
      DtSubscribableMessageQueue *myInteractionMessageQueue;
      DtSubscribableMessageQueue *myObjectMessageQueue;

      DtString                    myBrokerName;
      DtU8                        myBrokerId;
      DtU32                       myObjectSerialNumber;
      DtU32                       myInteractionSerialNumber;
      DtU32                       myControlSerialNumber;
      DtPortalMessageFactory      myMessageFactory;
      DtInetTcpSocket             *myTcpSocket;
      DtClock                     myClock;
      DtU32                       mySentControlMessages;
      DtU32                       mySentInteractionMessages;
      DtU32                       mySentObjectMessages;
      mutable DtU32               myMutableReceivedMessages;
      DtTime                      myLastTcpHeartbeat;
      bool                        myOneTimeSendBrokerIdFlag;

      struct CallbackPair { MessageCbFcn fcn; void *userData; };
      typedef std::list<CallbackPair> CallbackPairList;
      CallbackPairList myNoTypeCbList;
      CallbackPairList myCbList[DtMaxPortalMessageKinds];

      typedef std::map<DtU16, DtString> BrokerIdToNameMap;
      BrokerIdToNameMap myBrokerIdToNameMap;

   };

}