DtTcpServer.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2015 MAK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: DtTcpServer.h,v $ $Revision: 1.25 $ $State: Exp $
*******************************************************************************/


#ifndef DtIGITCPServer_H_
#define DtIGITCPServer_H_

#include <vrvCore/vrvCore.h>

#include <list>
#include <string>

#ifdef _WIN32
struct fd_set;
#else
#include <sys/types.h>
#endif


namespace makVrv
{
   class DtDe;
   class DtMessageDispatcher;
   class DtTcpMessageClient;

   class DT_DLL_VRVCORE DtTcpServer
   {
   public:

      typedef std::list<DtTcpMessageClient*> ClientList;

      static const std::string theServerHandshake;
      static const std::string theClientHandshake;

      DtTcpServer(DtDe& de,int port);

      ~DtTcpServer();

      bool isListening() const;

      void startListening();

      void stopListening();

      int numberOfConnections();

      void cleanupDisconnectedClients();

      void checkForMessages();

      void addClient(DtTcpMessageClient*);

      const ClientList& clients() const;

      void deleteClient(DtTcpMessageClient*);

      DtTcpMessageClient* findClient(const std::string& name);

      void deleteClients();     

      static void setBlocking(int fd, bool blocking);

   protected:

      void handleNewConnections();

      void buildSocketList();
      
      void processReads();      
      

      DtDe& myDe;
      int mySocket;
      int myHighSocket;
      int myPort;
      fd_set* myReceiveSet;
      
      ClientList myClients;
      DtMessageDispatcher& myDispatcher;
   };
}

#endif