3party/libzmq
0
0
Fork 0
mirror of https://github.com/zeromq/libzmq.git synced 2025-03-21 19:23:51 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix issue #1257

Browse Source
This commit is contained in:
Martin Hurton 2014-11-24 15:07:24 +01:00 committed by KIU Shueng Chuan
parent 742e303c0d
commit e67f935f3a
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/socket_base.cpp
View File

@ -518,9 +518,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,
@ -569,6 +566,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_);