From da49e5a4dd4602bf893193a5e6e64af54695b51c Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Tue, 13 Jul 2010 07:57:29 +0200 Subject: devices exit in case of context termination --- src/forwarder.cpp | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) (limited to 'src/forwarder.cpp') diff --git a/src/forwarder.cpp b/src/forwarder.cpp index 5aab8f2..503868b 100644 --- a/src/forwarder.cpp +++ b/src/forwarder.cpp @@ -30,8 +30,19 @@ int zmq::forwarder (socket_base_t *insocket_, socket_base_t *outsocket_) errno_assert (rc == 0); while (true) { - insocket_->recv (&msg, 0); - outsocket_->send (&msg, 0); + rc = insocket_->recv (&msg, 0); + if (rc < 0) { + if (errno == ETERM) + return -1; + errno_assert (false); + } + + rc = outsocket_->send (&msg, 0); + if (rc < 0) { + if (errno == ETERM) + return -1; + errno_assert (false); + } } return 0; -- cgit v1.2.3