From 5b82b1ba30d136655c72f116ee2e372ded453952 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Wed, 9 Feb 2011 22:23:21 +0100 Subject: Reaper thread waits for commands rather them retrieving them periodically Signed-off-by: Martin Sustrik --- src/object.cpp | 20 ++++++++++++++++++++ 1 file changed, 20 insertions(+) (limited to 'src/object.cpp') diff --git a/src/object.cpp b/src/object.cpp index 823d4b6..9ec73f7 100644 --- a/src/object.cpp +++ b/src/object.cpp @@ -118,6 +118,10 @@ void zmq::object_t::process_command (command_t &cmd_) process_reap (cmd_.args.reap.socket); break; + case command_t::reaped: + process_reaped (); + break; + default: zmq_assert (false); } @@ -352,6 +356,17 @@ void zmq::object_t::send_reap (class socket_base_t *socket_) send_command (cmd); } +void zmq::object_t::send_reaped () +{ + command_t cmd; +#if defined ZMQ_MAKE_VALGRIND_HAPPY + memset (&cmd, 0, sizeof (cmd)); +#endif + cmd.destination = ctx->get_reaper (); + cmd.type = command_t::reaped; + send_command (cmd); +} + void zmq::object_t::send_done () { command_t cmd; @@ -430,6 +445,11 @@ void zmq::object_t::process_reap (class socket_base_t *socket_) zmq_assert (false); } +void zmq::object_t::process_reaped () +{ + zmq_assert (false); +} + void zmq::object_t::process_seqnum () { zmq_assert (false); -- cgit v1.2.3