Merge pull request #290 from pieterh/master

Fixed issue #325

doc/zmq_setsockopt.txt

@@ -133,6 +133,9 @@ identity.
 Identity should be at least one byte and at most 255 bytes long. Identities
 starting with binary zero are reserved for use by 0MQ infrastructure.
 
+If two peers use the same identity when connecting to a third peer, the
+results shall be undefined.
+
 [horizontal]
 Option value type:: binary data
 Option value unit:: N/A

src/router.cpp

 /*
+    Copyright (c) 2012 iMatix Corporation
     Copyright (c) 2009-2011 250bpm s.r.o.
-    Copyright (c) 2011 iMatix Corporation
     Copyright (c) 2011 VMware, Inc.
     Copyright (c) 2007-2011 Other contributors as noted in the AUTHORS file
 
@@ -106,6 +106,7 @@ void zmq::router_t::xterminated (pipe_t *pipe_)
             return;
         }
     }
+    //  We should never get here
     zmq_assert (false);
 }
 
@@ -236,25 +237,29 @@ int zmq::router_t::xrecv (msg_t *msg_, int flags_)
 
         zmq_assert (!more_in);
 
-        //  Empty identity means we can preserve the auto-generated identity.
-        if (msg_->size () != 0) {
-
-            //  Actual change of the identity.
-            outpipes_t::iterator it = outpipes.begin ();
+        //  Empty identity means we can preserve the auto-generated identity
+        if (msg_->size ()) {
+            blob_t identity ((unsigned char*) msg_->data (), msg_->size ());
+            outpipes_t::iterator it = outpipes.find (identity);
+            if (it == outpipes.end ()) {
+                //  Find the pipe and change its identity
+                bool changed = false;
+                it = outpipes.begin ();
                 while (it != outpipes.end ()) {
                     if (it->second.pipe == pipe) {
-                    blob_t identity ((unsigned char*) msg_->data (),
-                        msg_->size ());
                         pipe->set_identity (identity);
                         outpipes.erase (it);
                         outpipe_t outpipe = {pipe, true};
-                    outpipes.insert (outpipes_t::value_type (identity,
-                        outpipe));
+                        if (!outpipes.insert (
+                            outpipes_t::value_type (identity, outpipe)).second)
+                            zmq_assert (false);
+                        changed = true;
                         break;
                     }
                     ++it;
                 }
-            zmq_assert (it != outpipes.end ());
+                zmq_assert (changed);
+            }
         }
     }