Commit 1d9b76c8 authored by Tim M's avatar Tim M

Added test for ZMQ_CONNECT_RID

parent 2f36f65f
...@@ -622,6 +622,7 @@ set(tests ...@@ -622,6 +622,7 @@ set(tests
test_timeo test_timeo
test_many_sockets test_many_sockets
test_diffserv test_diffserv
test_connect_rid
) )
if(NOT WIN32) if(NOT WIN32)
list(APPEND tests list(APPEND tests
......
...@@ -402,6 +402,7 @@ bool zmq::router_t::identify_peer (pipe_t *pipe_) ...@@ -402,6 +402,7 @@ bool zmq::router_t::identify_peer (pipe_t *pipe_)
put_uint32 (buf + 1, next_rid++); put_uint32 (buf + 1, next_rid++);
identity = blob_t (buf, sizeof buf); identity = blob_t (buf, sizeof buf);
} }
else
if (!options.raw_sock) { if (!options.raw_sock) {
// Pick up handshake cases and also case where next identity is set // Pick up handshake cases and also case where next identity is set
msg.init (); msg.init ();
...@@ -409,9 +410,6 @@ bool zmq::router_t::identify_peer (pipe_t *pipe_) ...@@ -409,9 +410,6 @@ bool zmq::router_t::identify_peer (pipe_t *pipe_)
if (!ok) if (!ok)
return false; return false;
if (connect_rid_used) // we read but do not use identity from peer
msg.close();
else
if (msg.size () == 0) { if (msg.size () == 0) {
// Fall back on the auto-generation // Fall back on the auto-generation
unsigned char buf [5]; unsigned char buf [5];
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment