diff options
| author | Martin Hurton <hurtonm@gmail.com> | 2012-04-05 01:01:50 +0200 |
|---|---|---|
| committer | Martin Sustrik <sustrik@250bpm.com> | 2012-04-06 13:03:00 +0200 |
| commit | 79f9c65133801d3a4a634dc59d418af68cf39508 (patch) | |
| tree | 769b0491a36fec9e1d9c06db14e3f0d727e7dd3c | |
| parent | 6c733a38308cc03f82ffb1e0d58f72d71460784f (diff) | |
Flush identity message for inproc transport
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.
| -rw-r--r-- | src/socket_base.cpp | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/src/socket_base.cpp b/src/socket_base.cpp index 5b1752e..26aa209 100644 --- a/src/socket_base.cpp +++ b/src/socket_base.cpp @@ -422,6 +422,7 @@ int xs::socket_base_t::connect (const char *addr_) id.set_flags (msg_t::identity); bool written = ppair [0]->write (&id); xs_assert (written); + pipes [0]->flush (); } // Attach remote end of the pipe to the peer socket. Note that peer's |