Commit cefce68a authored by Constantin Rack's avatar Constantin Rack

Merge pull request #1262 from hurtonm/master

Fix issue #1257
parents 1680a3ce 905b1683
...@@ -506,9 +506,6 @@ int zmq::socket_base_t::connect (const char *addr_) ...@@ -506,9 +506,6 @@ int zmq::socket_base_t::connect (const char *addr_)
int rc = pipepair (parents, new_pipes, hwms, conflates); int rc = pipepair (parents, new_pipes, hwms, conflates);
errno_assert (rc == 0); errno_assert (rc == 0);
// Attach local end of the pipe to this socket object.
attach_pipe (new_pipes [0]);
if (!peer.socket) { if (!peer.socket) {
// The peer doesn't exist yet so we don't know whether // The peer doesn't exist yet so we don't know whether
// to send the identity message or not. To resolve this, // to send the identity message or not. To resolve this,
...@@ -557,6 +554,9 @@ int zmq::socket_base_t::connect (const char *addr_) ...@@ -557,6 +554,9 @@ int zmq::socket_base_t::connect (const char *addr_)
send_bind (peer.socket, new_pipes [1], false); send_bind (peer.socket, new_pipes [1], false);
} }
// Attach local end of the pipe to this socket object.
attach_pipe (new_pipes [0]);
// Save last endpoint URI // Save last endpoint URI
last_endpoint.assign (addr_); last_endpoint.assign (addr_);
......
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