diff options
author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-08-09 09:24:48 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-08-09 09:24:48 +0200 |
commit | 5b5b513330e96e3e08d0c2c60d03044091976420 (patch) | |
tree | 1eb97606ff6827760c0b063aca95470df6ae20a1 /src/io_object.cpp | |
parent | a8b410e66c3c75809c8e9c01dd3e35c579f02347 (diff) |
socket options interface modeled as in BSD sockets
Diffstat (limited to 'src/io_object.cpp')
-rw-r--r-- | src/io_object.cpp | 45 |
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); |