Skip to content

Commit

Permalink
Flush identity message for inproc transport
Browse files Browse the repository at this point in the history
The scoket implementation for inproc transfer failed to flush
identity message. The result was that the identity message
was not delivered until after the user sent the first message.

The identity message was never delivered if the user
used the socket only to receive messages.
  • Loading branch information
hurtonm committed Apr 4, 2012
1 parent 5bc9fd6 commit b41036a
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions src/socket_base.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -434,6 +434,7 @@ int zmq::socket_base_t::connect (const char *addr_)
id.set_flags (msg_t::identity);
bool written = pipes [0]->write (&id);
zmq_assert (written);
pipes [0]->flush ();
}

// Attach remote end of the pipe to the peer socket. Note that peer's
Expand Down

0 comments on commit b41036a

Please sign in to comment.