poll.hpp

#pragma once
 
#ifdef _WIN32
#include <winsock2.h>
#else
#include <poll.h>
#endif
 
#include <assert.h>
 
#include <iostream>
 
#include <coroio/base.hpp>
#include <coroio/poller.hpp>
#include <coroio/socket.hpp>
 
namespace NNet {
 
class TPoll: public TPollerBase {
public:
    using TSocket = NNet::TSocket;
    using TFileHandle = NNet::TFileHandle;
 
#ifdef _WIN32
    TPoll();
#endif
 
    void Poll();
 
private:
    std::vector<std::tuple<THandlePair,int>> InEvents_;
    std::vector<pollfd> Fds_;
#ifdef _WIN32
    TSocket DummySocket_;
#endif
};
 
} // namespace NNet