tcpMsgSocketMgr.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2010 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: $ $Revision: $ $State: Exp $
*********************************************************************/


#ifndef tcpMsgSocketMgr_H_
#define tcpMsgSocketMgr_H_

#include <set>
#include <vlutil/vlInetSocketMgr.h>
#include "tcpMsgSocket.h"

using namespace MAKRti;

typedef void (*DtTcpSocketAdditionCallback)(DtTcpMsgSocket* sock, void* usr);
typedef DtTcpSocketAdditionCallback DtTcpSocketRemovalCallback;

class DtTcpSocketMgrCbInfo
{
public:

   DtTcpSocketMgrCbInfo(DtTcpSocketAdditionCallback cb, void* usr)
   {
      myCb = cb;
      myUsr = usr;
   }

   bool operator==(const DtTcpSocketMgrCbInfo& rhs)
   {
      return (myCb == rhs.myCb && myUsr == rhs.myUsr);
   }

   DtTcpSocketAdditionCallback myCb;
   void* myUsr;
};

typedef std::map<DtInetTcpSocket*, DtTcpMsgSocket*> DtTcpMsgSocketMap;

class DT_DLL_RTIUTIL DtTcpMsgSocketMgr
{
public:

   DtTcpMsgSocketMgr(DtBoost::shared_ptr<DtMsgHeaderReader> hdrReader,
      size_t recvBufferSize = 20000, int maxQueuedMsgs = -1);

   virtual ~DtTcpMsgSocketMgr();

   virtual bool openServerSocket( DtU16 localPort, DtInetDevice* hostIf = NULL, 
      DtInetUtils::DtInetAddrFamily family = DtInetUtils::DtInetAddrFamily_IPv4,
      DtU32 flags = (DtDefaultSockOpts | DtSockOptNonBlocking) );

   virtual void processConnections();

   virtual void addSocket(DtTcpMsgSocket* sock);

   static bool socketAdded(DtInetSocket* sock, void* usr);
   bool socketAdded(DtInetSocket* sock);

   virtual void addSocketAdditionCallback(DtTcpSocketAdditionCallback cb,
      void* usr);
   virtual void removeSocketAdditionCallback(DtTcpSocketAdditionCallback cb, 
      void* usr);

   static bool socketRemoved(DtInetSocket* sock, void* usr);
   bool socketRemoved(DtInetSocket* sock);

   virtual void addSocketRemovalCallback(DtTcpSocketRemovalCallback cb, 
      void* usr);
   virtual void removeSocketRemovalCallback(DtTcpSocketRemovalCallback cb, 
      void* usr);

   virtual void removeAndDelete(DtTcpMsgSocket* sock);

   virtual void enableBundling(size_t maxBundleSize);

   virtual void disableBundling();

   virtual void enableCompression(DtU8 compressionLevel);

   virtual void disableCompression();

   virtual void setTcpNoDelay(bool enable);

   virtual void setSendBufferSize(DtU32 size);

   virtual void setRecvBufferSize(DtU32 size);

   virtual DtInetSockState serverSocketState() const;

   virtual DtU32 maxMsgSize() const;

   DtTcpMsgSocketMap& socketSet();

   DtTcpMsgSocketMap::iterator socketIter(DtTcpMsgSocket* sock);

   DtString getLastError() const;

   bool isListening() const { return serverSocketState() == DtInetSockState_LISTENING; }

private:

   DtTcpMsgSocketMgr(const DtTcpMsgSocketMgr&);
   DtTcpMsgSocketMgr& operator=(const DtTcpMsgSocketMgr&);

protected:

   std::auto_ptr<DtInetSocketMgr> mySocketMgr;

   DtTcpMsgSocketMap mySockets;

   DtBoost::shared_ptr<DtMsgHeaderReader> myHeaderReader;

   int myMaxQueuedMessages;

   size_t myRecvBufferSize;

   bool myTcpNoDelay;

   size_t myMaxBundleSize;

   MAKRti::DtU8 myCompressionLevel;

   MAKRti::DtU32 mySockRecvBufferSize;

   MAKRti::DtU32 mySockSendBufferSize;

   std::list<DtTcpSocketMgrCbInfo> myAdditionCallbacks;

   std::list<DtTcpSocketMgrCbInfo> myRemovalCallbacks;

   DtString myLastError;
};

inline DtTcpMsgSocketMap& DtTcpMsgSocketMgr::socketSet()
{
   return mySockets;
}

inline DtTcpMsgSocketMap::iterator DtTcpMsgSocketMgr::socketIter(DtTcpMsgSocket* sock)
{
   DtTcpMsgSocketMap::iterator iter = mySockets.end();
   if(sock)
   {
      DtInetTcpSocket* inetSock = sock->inetTcpSocket();
      if(inetSock)
      {
         iter = mySockets.find(inetSock);
      }
   }
   return iter;
}

inline DtString DtTcpMsgSocketMgr::getLastError() const
{
   return myLastError;
}

#endif