kqueue.hpp

#pragma once
 
#include <sys/types.h>
#include <sys/event.h>
#include <sys/time.h>
 
#include <coroio/poller.hpp>
#include <coroio/socket.hpp>
 
namespace NNet {
 
class TKqueue: public TPollerBase {
public:
    using TSocket = NNet::TSocket;
    using TFileHandle = NNet::TFileHandle;
    TKqueue();
    ~TKqueue();
    void Poll();
 
private:
    int Fd_; 
    std::vector<THandlePair> InEvents_; 
    std::vector<struct kevent> ChangeList_; 
    std::vector<struct kevent> OutEvents_; 
};
 
} // namespace NNet