summaryrefslogtreecommitdiff
path: root/src/session.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-02-16 18:30:38 +0100
committerMartin Sustrik <sustrik@250bpm.com>2010-02-16 18:30:38 +0100
commitb9caa319e279cd8cd367e0a64308b9e80c4ead3d (patch)
tree751d1eb31b0e41bf82f51ad3be69e13a2af70472 /src/session.cpp
parent2ddce205350f11dacd8d8550f7d4e6e088c7fbcd (diff)
Multi-hop REQ/REP, part XI., finalise the XREQ/XREP functionality
Diffstat (limited to 'src/session.cpp')
-rw-r--r--src/session.cpp7
1 files changed, 6 insertions, 1 deletions
diff --git a/src/session.cpp b/src/session.cpp
index f86327e..74bd8ae 100644
--- a/src/session.cpp
+++ b/src/session.cpp
@@ -124,7 +124,7 @@ uint64_t zmq::session_t::get_ordinal ()
}
void zmq::session_t::attach_pipes (class reader_t *inpipe_,
- class writer_t *outpipe_)
+ class writer_t *outpipe_, const blob_t &peer_identity_)
{
if (inpipe_) {
zmq_assert (!in_pipe);
@@ -251,4 +251,9 @@ void zmq::session_t::process_attach (i_engine *engine_,
zmq_assert (engine_);
engine = engine_;
engine->plug (this);
+
+ // Once the initial handshaking is over tracerouting should trim prefixes
+ // from outbound messages.
+ if (options.traceroute)
+ engine->trim_prefix ();
}