summaryrefslogtreecommitdiff
path: root/src/io_object.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/io_object.cpp')
-rw-r--r--src/io_object.cpp45
1 files changed, 44 insertions, 1 deletions
diff --git a/src/io_object.cpp b/src/io_object.cpp
index 41e4717..a4badd7 100644
--- a/src/io_object.cpp
+++ b/src/io_object.cpp
@@ -18,17 +18,60 @@
*/
#include "io_object.hpp"
+#include "io_thread.hpp"
-zmq::io_object_t::io_object_t (object_t *parent_, object_t *owner_) :
+zmq::io_object_t::io_object_t (io_thread_t *parent_, object_t *owner_) :
object_t (parent_),
owner (owner_)
{
+ // Retrieve the poller from the thread we are running in.
+ poller = parent_->get_poller ();
}
zmq::io_object_t::~io_object_t ()
{
}
+zmq::handle_t zmq::io_object_t::add_fd (fd_t fd_, i_poll_events *events_)
+{
+ return poller->add_fd (fd_, events_);
+}
+
+void zmq::io_object_t::rm_fd (handle_t handle_)
+{
+ poller->rm_fd (handle_);
+}
+
+void zmq::io_object_t::set_pollin (handle_t handle_)
+{
+ poller->set_pollin (handle_);
+}
+
+void zmq::io_object_t::reset_pollin (handle_t handle_)
+{
+ poller->reset_pollin (handle_);
+}
+
+void zmq::io_object_t::set_pollout (handle_t handle_)
+{
+ poller->set_pollout (handle_);
+}
+
+void zmq::io_object_t::reset_pollout (handle_t handle_)
+{
+ poller->reset_pollout (handle_);
+}
+
+void zmq::io_object_t::add_timer (i_poll_events *events_)
+{
+ poller->add_timer (events_);
+}
+
+void zmq::io_object_t::cancel_timer (i_poll_events *events_)
+{
+ poller->cancel_timer (events_);
+}
+
void zmq::io_object_t::term ()
{
send_term_req (owner, this);