Fix error in router socket introduced in the previous commit

9a60b3a2 · Martin Hurton · f037290d · 9a60b3a2
Commit 9a60b3a2 authored Apr 03, 2012 by Martin Hurton
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

router.cpp src/router.cpp +3 -1

No files found.
--- a/src/router.cpp
+++ b/src/router.cpp
@@ -108,8 +108,10 @@ void zmq::router_t::xread_activated (pipe_t *pipe_)
        fq.activated (pipe_);
    else {
        bool identity_ok = identify_peer (pipe_);
-        if (identity_ok)
+        if (identity_ok) {
            anonymous_pipes.erase (it);
+            fq.attach (pipe_);
+        }
    }
 }