From 9a60b3a2a197f1f1f48cf0bf6fa3e5e61e7efb6a Mon Sep 17 00:00:00 2001 From: Martin Hurton Date: Tue, 3 Apr 2012 09:28:38 +0200 Subject: [PATCH] Fix error in router socket introduced in the previous commit --- src/router.cpp | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/router.cpp b/src/router.cpp index f87242a5..8821dc45 100644 --- 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_); + } } }