remoteAssistantInfoMgr.h

Go to the documentation of this file.

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


#pragma once

#include "rtiMsConfig.h"
#include "assistantMgr.h"
#include <assistant/assistantInfo.h>
#include "assistantAppUtil.h"

class DtAssistantConnectionInfoMgr;

class DtRtiAssistantServer;
class DtRtiAssistantPeer;
class DtAssistantSignalRouter;
class DtAssistantToAssistantConnectionMsg;

typedef std::map< DtAssistantConnectionStruct, DtTime, cmpByConnectionId > DtAssistantPendingConnectionsWithTimeouts;


class DT_DLL_ASSISTANTAPP DtRemoteAssistantInfoMgr : public DtAssistantMgr
{
   Q_OBJECT;
public:

   DtRemoteAssistantInfoMgr(DtBoost::shared_ptr<DtRtiAssistantServer> server,
      DtBoost::shared_ptr<DtRtiAssistantPeer> peer, DtAssistantSignalRouter& signalRouter, DtBoost::shared_ptr<DtAssistantConnectionInfoMgr> connInfoMgr);

   virtual ~DtRemoteAssistantInfoMgr();

   virtual void initialize();
   virtual void tick();
   
   static void processAssistantToAssistantConnectionMsg(const DtAssistantToAssistantConnectionMsg& msg, void* usr);
   virtual void processAssistantToAssistantConnectionMsg(const DtAssistantToAssistantConnectionMsg& msg);
   static void handleAssistantConnectionLost(const DtAssistantConnectionStruct& sock, void* usr);
   virtual void handleAssistantConnectionLost(const DtAssistantConnectionStruct& sock);
signals:

   void assistantToAssistantConnectionAdded(const DtAssistantConnectionStruct&);

   void assistantToAssistantConnectionRemoved(const DtAssistantConnectionStruct&);

   void assistantToAssistantConnectionChanged(const DtAssistantConnectionStruct&, DtAssistantConnectionState);

   void queryAssistantInfo(const DtAssistantUuid&, DtAssistantInfo* infoIn);

public slots:

   void processConnectionAdded(const DtAssistantConnectionStruct& conn);

   void processConnectionRemoved(const DtAssistantConnectionStruct& conn);

   void processConnectionConnect(const DtAssistantConnectionStruct& conn);
   void processConnectionDisconnect(const DtAssistantConnectionStruct& conn);

   virtual void processAssistantFound(const DtAssistantInfo&);
   virtual void processAssistantLost(const DtAssistantInfo&);
   void assistantConnectionInfoUpdated(const DtAssistantConnectionStruct&, const DtAssistantConnectionStruct&);
protected:
   void processTimeouts();
   void processPendingSyns(const DtTime& now);
   void processPendingSynAcks(const DtTime& now);
   void processPendingAssistantInfos(const DtTime& now);
   void processPendingFins(const DtTime& now);
   void timeoutConnection(const DtAssistantConnectionStruct&, DtTime = 0.0);
   void resetConnection(const DtAssistantConnectionStruct);
   void handleSyn(const DtAssistantToAssistantConnectionMsg& msg);
   void handleSynAck(const DtAssistantToAssistantConnectionMsg& msg);
   void handleAck(const DtAssistantToAssistantConnectionMsg& msg);
   void handleFin(const DtAssistantToAssistantConnectionMsg& msg);
   void handleRst(const DtAssistantToAssistantConnectionMsg& msg);
   void handleFinAck(const DtAssistantToAssistantConnectionMsg& msg);
   bool isAlreadyConnected(const DtAssistantToAssistantConnectionMsg& msg, bool wanOnly = false) const;
   bool allowConnections() const;
   DtAssistantConnectionId newConnectionId() const;
   void addAssistantConnection(const DtAssistantConnectionStruct& connection, bool remote);
   void removeAssistantConnection(const DtAssistantConnectionStruct& connection);
   void connectingAssistantConnection(const DtAssistantConnectionStruct& uuid, const DtAssistantConnectionId& otherConnId);
   void disconnectingAssistantConnection(const DtAssistantConnectionStruct& uuid, DtAssistantConnectionState state = DtDisconnected);
   void addPendingAssistantInfo(const DtAssistantConnectionStruct& conn);
   virtual bool isConnecting(const DtAssistantConnectionStruct& conn) const;
   DtBoost::shared_ptr<DtAssistantConnectionInfoMgr> myConnInfoMgr;

   MAKRti::DtClock myClock;
   DtTime myTimeoutCheckingTime;
   unsigned int myTimeout;
   DtAssistantPendingConnectionsWithTimeouts myPendingSyns;
   DtAssistantPendingConnectionsWithTimeouts myPendingSynAcks;
   DtAssistantPendingConnectionsWithTimeouts myPendingFins;
   std::map< DtAssistantUuid, DtTime > myPendingAssistantInfos;
   std::map< DtAssistantUuid, std::pair< DtAssistantConnectionStruct, DtAssistantConnectionId > > myAssistantUuidToConnectionMap;

};