diff --git a/core/reactor.hh b/core/reactor.hh index edc495ce27..ad478e49b7 100644 --- a/core/reactor.hh +++ b/core/reactor.hh @@ -178,6 +178,8 @@ public: future<> write_all(const uint8_t* buffer, size_t size); future write_some(net::packet& p); future<> write_all(net::packet& p); + future<> readable(); + future<> writeable(); future accept(); future sendmsg(struct msghdr *msg); future recvmsg(struct msghdr *msg); @@ -1347,6 +1349,16 @@ future<> pollable_fd::write_all(net::packet& p) { }); } +inline +future<> pollable_fd::readable() { + return engine.readable(*_s); +} + +inline +future<> pollable_fd::writeable() { + return engine.writeable(*_s); +} + inline future pollable_fd::accept() { return engine.accept(*_s);