summaryrefslogtreecommitdiff
path: root/src/io_object.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@fastmq.commkdir>2009-08-09 16:12:09 +0200
committerMartin Sustrik <sustrik@fastmq.commkdir>2009-08-09 16:12:09 +0200
commit9f1f823b7b69ced56bdb0416feef71230cc7fd55 (patch)
treee5aa6ca2b943c62afcc4ca427102693d8f88a14e /src/io_object.cpp
parent3147ff8523d9736039c4582f5f62c323b23940d1 (diff)
zmq_listener/zmq_connecter implemented
Diffstat (limited to 'src/io_object.cpp')
-rw-r--r--src/io_object.cpp13
1 files changed, 7 insertions, 6 deletions
diff --git a/src/io_object.cpp b/src/io_object.cpp
index b7c70d4..d8cc1c0 100644
--- a/src/io_object.cpp
+++ b/src/io_object.cpp
@@ -52,9 +52,9 @@ void zmq::io_object_t::process_plug ()
plugged_in = true;
}
-zmq::handle_t zmq::io_object_t::add_fd (fd_t fd_, i_poll_events *events_)
+zmq::handle_t zmq::io_object_t::add_fd (fd_t fd_)
{
- return poller->add_fd (fd_, events_);
+ return poller->add_fd (fd_, this);
}
void zmq::io_object_t::rm_fd (handle_t handle_)
@@ -82,14 +82,14 @@ 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_)
+void zmq::io_object_t::add_timer ()
{
- poller->add_timer (events_);
+ poller->add_timer (this);
}
-void zmq::io_object_t::cancel_timer (i_poll_events *events_)
+void zmq::io_object_t::cancel_timer ()
{
- poller->cancel_timer (events_);
+ poller->cancel_timer (this);
}
void zmq::io_object_t::in_event ()
@@ -126,5 +126,6 @@ void zmq::io_object_t::process_term ()
// Otherwise, destroy the object and acknowledge the termination
// straight away.
send_term_ack (owner);
+ process_unplug ();
delete this;
}