atoms/select_poller.hh

Go to the documentation of this file.

#ifndef ATOMS_SELECT_POLLER_HH
#define ATOMS_SELECT_POLLER_HH

#include <atoms/gen.hh>
#include <sys/time.h>
#include <sys/types.h>
#include <unistd.h>
#include <boost/utility.hpp>
#include <boost/shared_ptr.hpp>
#include <atoms/io_poller.hh>
#include <atoms/debug.hh>

namespace atoms {

class SelectPoller : public IOPoller {
public:
    ~SelectPoller() {}
    void add(int fd, Event eventMask, const EventHandler &onEvent);
    void remove(int fd, Event eventMask);
    void remove(int fd, bool isClosing = false);
    void poll(const Timespan &interval = Timespan::tINFINITY);
    bool supportsEdgeTriggering() const { return false; }

    static boost::shared_ptr<IOPoller> create() {
        return boost::shared_ptr<IOPoller>(new SelectPoller());
    }

private:
    SelectPoller();

    fd_set readset,         
           writeset,        
           exceptset;       


    static DebugLogger LOGGER;
};

}
#endif

---