Update router.cpp

zeromq · Mar 11, 2024 · 93827b0 · 93827b0
1 parent 5db878e
commit 93827b0
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/router.cpp b/src/router.cpp
@@ -185,12 +185,13 @@ int zmq::router_t::xsend (msg_t *msg_)
                 if (!_current_out->check_write ()) {
                     // Check whether pipe is full or not
                     const bool pipe_full = !_current_out->check_hwm ();
+                    const bool pipe_active = _current_out->is_active();
                     out_pipe->active = false;
                     _current_out = NULL;
 
                     if (_mandatory) {
                         _more_out = false;
-                        if (pipe_full)
+                        if (pipe_full && pipe_active)
                             errno = EAGAIN;
                         else
                             errno = EHOSTUNREACH;