EPoll.h

#ifndef __EPoll_h__
#define __EPoll_h__
 
#include "Log.h"
#include "Socket.h"
#include "Thread.h"
#include "TCPSession.h"
#include "Command.h"
 
namespace core {
   
 
   class EPoll : public Command {
 
    public:
 
 
      EPoll();
 
      
      ~EPoll();
      
      
      bool start(int numberOfThreads, int maxSockets); 
      
      
      bool stop(); 
      
      
      bool isStopping(); 
      
      
      bool registerSocket(Socket *socket); 
      
      
      bool unregisterSocket(Socket *socket); 
      
      
      int getDescriptor(); 
      
      
      int maxSockets; 
      
      
      void eventReceived(struct epoll_event event); 
      
      
      int processCommand(coreutils::ZString &request, TCPSession &session) override; 
 
      void resetSocket(Socket *socket);
 
    private:
      
      int epfd;
      int numberOfThreads; 
      std::vector<Thread> threads; 
      volatile bool terminateThreads; 
      void enableSocket(Socket *socket);
      void disableSocket(Socket *socket);
            
   };
   
}
 
#endif