vlTcpSocketMgr.h

Go to the documentation of this file.

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


#include <vlutil/vlMachineTypes.h>    
#include <vlutil/vlNetTypes.h>
#include <vlutil/vlUtil.h>
#include "vlTcpSocket.h"

#ifdef DtUSE_UTILITIES_NAMESPACE
namespace DtUSE_UTILITIES_NAMESPACE
{
#endif


typedef void (*DtSocketAdditionCallback)(DtTcpSocket* sock, void* usr);
typedef DtSocketAdditionCallback DtSocketRemovalCallback;
class DtTcpSocketMgr;
typedef DtSocket* (*DtSocketCreationCallback)(void* creator, DtTcpSocketMgr * mgr);


class DT_DLL_NETCOMPAT DtTcpSocketMgr
{
public:
   
   DtTcpSocketMgr(int port=DtDEFAULT_PORT);
   DtTcpSocketMgr(DtSocketCreationCallback cb, void *socketCreator, int port=DtDEFAULT_PORT);

   virtual ~DtTcpSocketMgr();

   virtual void processConnections();

   virtual int isOk() const;

   virtual int addrInUse() const;

   virtual DtIpv4Addr currentClientAddr() const;

   virtual int currentClientPort() const;

   virtual int currentSockFd() const;

   virtual const DtList* socketList();

   void removeAndDelete(DtTcpSocket* sock);

   void setNoDelay(bool onOff);

   virtual void addSocketAdditionCallback(
      DtSocketAdditionCallback cb, void* usr);
   virtual void removeSocketAdditionCallback(
      DtSocketAdditionCallback cb, void* usr);
   
   virtual void addSocketRemovalCallback(
      DtSocketRemovalCallback cb, void* usr);
   virtual void removeSocketRemovalCallback(
      DtSocketRemovalCallback cb, void* usr);

   virtual int sizeOffset();
   virtual int sizeLength();
   virtual void setSizeOffset(int offset);
   virtual void setSizeLength(int length);

   virtual void setPacketBundling( unsigned int maxBundleSize );

protected:
   
   virtual void emptyCallbackLists();

   DtTcpSocketMgr(const DtTcpSocketMgr&);

   DtTcpSocketMgr& operator=(const DtTcpSocketMgr &);

protected:

   int serverSockfd;
   int mySizeOffset;
   int mySizeLength;

   int myCurrentSockFd;
   DtIpv4Addr myServAddr;
   DtIpv4Addr myCliAddr;
   int myCliPort;
   DtList* mySockList;
   int myOk;
   int myAddrInUse;
   bool myNoDelay;
   unsigned int myMaxBundleSize;

   DtSocketCreationCallback mySocketCreationCb;
   void * mySocketCreator;

   
   DtList myAdditionCallbacks;
   DtList myRemovalCallbacks;
};

inline int DtTcpSocketMgr::isOk() const
{
   return myOk; 
}

inline int DtTcpSocketMgr::sizeLength()
{
   return mySizeLength;
}

inline int DtTcpSocketMgr::sizeOffset()
{
   return mySizeOffset;
}

#ifdef DtUSE_UTILITIES_NAMESPACE
} 
#endif


#endif