atoms/io_poller.hh

Go to the documentation of this file.

#ifndef ATOMS_IO_POLLER_HH
#define ATOMS_IO_POLLER_HH

#include <atoms/gen.hh>
#include <map>
#include <boost/utility.hpp>
#include <boost/function.hpp>
#include <atoms/mutex.hh>
#include <atoms/time.hh>

namespace atoms {

class IOPoller : public IOHandle {
public:
    enum Event {
        eNone           = 0, 

        eInput          = 1, 
        eOutput         = 2, 
        ePriorityInput  = 4, 

        eAddable        = eInput|eOutput|ePriorityInput,
        eError          = 8, 
        eHangup         = 16,
        eEdgeTriggered  = 32 

    };

    static boost::shared_ptr<IOPoller> create();

    virtual bool supportsEdgeTriggering() const = 0;

    typedef boost::function<void (Event)> EventHandler;

    virtual void add(int fd, Event eventMask, const EventHandler &onEvent) = 0;

    virtual void remove(int fd, Event eventMask) = 0;

    virtual void remove(int fd, bool isClosing = false) = 0;

    virtual void poll(const Timespan &interval = Timespan::tINFINITY) = 0;

protected:
    struct DescriptorInfo {
        bool stale;
        bool edgeTriggered;
        std::map<Event, EventHandler> eventHandlerMap;
    };

    std::map<int, boost::shared_ptr<DescriptorInfo> > descriptorMap;
};

} // namespace atoms
#endif // !ATOMS_IO_POLLER_HH

---