tcpRtiConnMgr.h

Go to the documentation of this file.

/*********************************************************************
 ** Copyright (c) 2006 MaK Technologies, Inc.
 ** All rights reserved.
 *********************************************************************/
/*******************************************************************************
 ** $RCSfile: tcpRtiConnMgr.h,v $ $Revision: 1.9 $ $State: Exp $
 *******************************************************************************/

#ifndef DtTcpRtiConnectionMgr_H_
#define DtTcpRtiConnectionMgr_H_

#include <rtiMsConfig.h>
#include "wwwSpyRtiConnMgr.h"
#include "webSpyUtils.h"
#include <vlutil/vlString.h>
#include <memory>
#include <map>


class DtWebSpyServer;
class DtRtiMsg;
class DtTcpMsgSocket;
class DtTcpMsgSocketMgr;


class DT_DLL_WWW DtTcpRtiConnectionMgr : public DtWebSpyRtiConnectionMgr
{
private:
   DtTcpRtiConnectionMgr( const DtTcpRtiConnectionMgr& );
   DtTcpRtiConnectionMgr& operator=( DtTcpRtiConnectionMgr& );

public:
   
   static DtWebSpyRtiConnectionMgr* create( DtWebSpyServer& parent );

public:
   virtual ~DtTcpRtiConnectionMgr();

   virtual bool tick( unsigned int timeout = 0 );

   virtual unsigned int numConnections() const;


   virtual void postCommand( const DtWebSpyUtils::ConnectionIdentifier& connInfo,
      std::auto_ptr<DtRtiMsg> command );

public:

   static void tcpSocketAdditionCb( DtTcpMsgSocket* sock, void* usr );
   static void tcpSocketRemovalCb( DtTcpMsgSocket* sock, void* usr );

protected:

   DtTcpRtiConnectionMgr( DtWebSpyServer& parent );

   virtual void testConnections();
   
   virtual bool readAndForward( DtTime maxTimePerSocket );

   virtual void tcpSocketAdditionCb( DtTcpMsgSocket* sock );
   virtual void tcpSocketRemovalCb( DtTcpMsgSocket* sock );

   virtual DtWebSpyUtils::ConnectionIdentifier establishConnection( DtTcpMsgSocket* sock );


   virtual std::auto_ptr<DtRtiMsg> netRead( DtTcpMsgSocket* sock, int *retCode) const;

protected:

   typedef std::map< DtTcpMsgSocket*, DtWebSpyUtils::ConnectionIdentifier > SocketToConnIdMap;
   typedef std::map< DtWebSpyUtils::ConnectionIdentifier, DtTcpMsgSocket* > ConnIdToSocketMap;

   SocketToConnIdMap myIdsByConnection;
   ConnIdToSocketMap myConnectionsById;
   MAKRti::DtTime myTimeToTestConnections;
   std::auto_ptr<DtTcpMsgSocketMgr> mySocketMgr;
};

#endif //! DtTcpRtiConnectionMgr_H_