peerToPeerSockMgr.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 1992, 1997 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: peerToPeerSockMgr.h,v $ $Revision: 1.10 $ $State: Exp $
*********************************************************************/
#ifndef DtPeerToPeerTcpSockMgr_H_
#define DtPeerToPeerTcpSockMgr_H_


#include "rtiMsConfig.h"
#include <vector>
#include <map>
#include <vlutil/vlTime.h>
#include <tcpMsgSocketMgr.h>

typedef void (*DtSocketEstablishedCallback)(DtTcpMsgSocket* sock, void* usr);

class DtSocketCbInfo
{
public:

   DtSocketCbInfo(DtSocketEstablishedCallback cb, void* usr)
   {
      myCb = cb;
      myUsr = usr;
   }

   DtSocketEstablishedCallback myCb;
   void *myUsr;
};

class DT_DLL_FORWARDER DtPeerToPeerTcpSockMgr : public DtTcpMsgSocketMgr
{
public:

   DtPeerToPeerTcpSockMgr( int port,
      std::shared_ptr<DtMsgHeaderReader> hdrRdr,
      size_t recvBufferSize, int maxForwarderQueue, int reconnectTries = 0, float reconnectDelay = 0.0f);

   virtual ~DtPeerToPeerTcpSockMgr();

   virtual DtTcpMsgSocket* connectToPeer( const MAKRti::DtInetAddr& addr,
      MAKRti::DtInetDevice* hostIf = 0);

   virtual DtTcpMsgSocket* connectToPeer( const MAKRti::DtInetAddr& addr,
      int port, MAKRti::DtInetDevice* hostIf = 0);

   virtual void removeAndDeletePeerConnection(DtTcpMsgSocket* sock,
      bool abort = true );
   
   unsigned int abortPendingConnections();

   unsigned int pendingConnectionsAborted();

   virtual bool repairPeerSocket(DtTcpMsgSocket* oldSock);
   
   virtual void processConnections();

   void unlockProcessConnections()
   {
      myProcessingConnections = false;
   }

   void lockProcessConnections()
   {
      myProcessingConnections = true;
   }



   virtual void addSocketEstablishedCallback(
      DtSocketEstablishedCallback cb, void* usr);
   virtual void removeSocketEstablishedCallback(
      DtSocketEstablishedCallback cb, void* usr);
   
   //virtual void replacePeerSocket(DtTcpMsgSocket* oldSock, DtTcpMsgSocket* newSock);

private:      
   DtPeerToPeerTcpSockMgr( const DtPeerToPeerTcpSockMgr& orig );
   DtPeerToPeerTcpSockMgr& operator=( const DtPeerToPeerTcpSockMgr& orig );

protected:


   int    myPort;
   
   MAKRti::DtClock myClock;

   unsigned int myPendingConnectionsAborted;
   
   std::map<DtTcpMsgSocket*, MAKRti::DtTime> myPendingConnections;

   bool myProcessingConnections;

   std::list<DtSocketCbInfo> myEstablishedCallbacks;


   int myReconnectTries;


   float myReconnectDelay;
};

#endif