From 7730ef29cd5c2abe6970003cdb0f9a17387cf4e2 Mon Sep 17 00:00:00 2001
From: Takuya ASADA <syuu@cloudius-systems.com>
Date: Thu, 8 Jan 2015 01:03:32 +0900
Subject: [PATCH] Add readable()/writeable() method on pollable_fd

---
 core/reactor.hh | 12 ++++++++++++
 1 file changed, 12 insertions(+)

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<size_t> write_some(net::packet& p);
     future<> write_all(net::packet& p);
+    future<> readable();
+    future<> writeable();
     future<pollable_fd, socket_address> accept();
     future<size_t> sendmsg(struct msghdr *msg);
     future<size_t> 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, socket_address> pollable_fd::accept() {
     return engine.accept(*_s);