mcs/SessionListener.cc

   1 #include "SessionListener.h"
   2
   3 namespace remote { namespace mcs {
   4
   5 SessionListener::SessionListener(unsigned int port)
   6         : FileDescriptor(openServerSocket(server, port, 5, 5)), sessions()
   7 {
   8         log("Listening for client connections on port %u.\n",port);
   9 }
  10
  11 SessionListener::~SessionListener()
  12 {
  13         sessionmapbyfd_t::iterator cI;
  14
  15         for (cI = sessions.begin(); cI != sessions.end(); cI++)
  16                 cI->second->destroy(true);
  17 }
  18
  19 void SessionListener::handleEvent(short events)
  20 {
  21         // for now, just try to accept a client connection
  22         struct sockaddr_in client;
  23
  24         if (events & POLLIN || events & POLLPRI) {
  25                 int clientsock = nextClient(fd, client);
  26
  27                 if (clientsock >= 0) {
  28                         log("Accepting new client connection\n");
  29                         new Session(clientsock, sessions);
  30                 }
  31         }
  32 }
  33
  34 }}