From a756956781973d207413d675b998ae47de47b7c7 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sat, 5 Nov 2011 09:57:17 +0100 Subject: Use identities in inproc transport Previous patches have missed the case when the identity should be sent from an inproc endpoint. Fixed. Signed-off-by: Martin Sustrik --- src/socket_base.cpp | 11 +++++++++++ 1 file changed, 11 insertions(+) (limited to 'src') diff --git a/src/socket_base.cpp b/src/socket_base.cpp index a59ba69..ced28d4 100644 --- a/src/socket_base.cpp +++ b/src/socket_base.cpp @@ -415,6 +415,17 @@ int zmq::socket_base_t::connect (const char *addr_) // Attach local end of the pipe to this socket object. attach_pipe (pipes [0]); + // If required, send the identity of the local socket to the peer. + if (options.send_identity) { + msg_t id; + rc = id.init_size (options.identity_size); + zmq_assert (rc == 0); + memcpy (id.data (), options.identity, options.identity_size); + id.set_flags (msg_t::identity); + bool written = pipes [0]->write (&id); + zmq_assert (written); + } + // Attach remote end of the pipe to the peer socket. Note that peer's // seqnum was incremented in find_endpoint function. We don't need it // increased here. -- cgit v1.2.3