socketeventshandler.h

#ifndef N2NC_NETSOCKETEVENTSHANDLER_H
#define N2NC_NETSOCKETEVENTSHANDLER_H

#include "nixsys.h"
#include "thread.h"
#include "socket.h"
#include "mutex.h"
#include "condition.h"
// #include "socketevents.h"


namespace n2nc {
namespace net {
    
class SocketEvents;

class SocketEventsHandler : n2nc::sync::Thread{
  public:
    SocketEventsHandler();
    ~SocketEventsHandler();
    
    enum check_for_t{
      READ    = 1,  
      WRITE   = 2,  
      EXCEPT  = 4,  
      NOTHING = 8   
    };
    int add(Socket &sock,check_for_t checkfor, SocketEvents& se);
    int del(Socket &sock);
    
    bool enableSocket(const Socket& sock);
    bool disableSocket(const Socket& sock);
    
    int waitForEvents();

    struct socket_extra_t{
      check_for_t               check;
      SocketEvents*             se ;
      Socket*                   sock ;
      n2nc::sync::Condition*    wait ;
      int                       last_errno ;
    };
    
    virtual void* entry_point();

  private:
    
    int _main_loop();
    
    int computeMaxFD();
    int tryAddMaxFD(Socket::fd_t fd);
    int tryAddMaxFD(const std::pair<Socket::fd_t,socket_extra_t*>& mypair);
    
    std::map<Socket::fd_t,socket_extra_t*> m_map_new ;
    int m_max_fd;
    
    std::vector<Socket*> m_dispatched ;
    n2nc::sync::Mutex m_lock ;
    int m_wakeup[2];
    pthread_t m_this_thread ;


};




}
}

#endif

---