mirror of
https://github.com/zeromq/libzmq.git
synced 2025-03-10 07:56:09 +00:00
Fix issue #1257
This commit is contained in:
parent
1680a3cea1
commit
905b1683c7
@ -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_)
|
|||||||
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_);
|
||||||
|
|
||||||
|
Loading…
x
Reference in New Issue
Block a user