Multi-hop REQ/REP, part I., tracerouting switched on on XREP socket

1 files changed, 9 insertions, 2 deletions

diff --git a/src/zmq_engine.cpp b/src/zmq_engine.cpp
index 01fe98c..bda098c 100644
--- a/src/zmq_engine.cpp
+++ b/src/zmq_engine.cpp
@@ -32,10 +32,10 @@ zmq::zmq_engine_t::zmq_engine_t (io_thread_t *parent_, fd_t fd_,
     io_object_t (parent_),
     inpos (NULL),
     insize (0),
-    decoder (in_batch_size, NULL, 0),
+    decoder (in_batch_size),
     outpos (NULL),
     outsize (0),
-    encoder (out_batch_size, false),
+    encoder (out_batch_size),
     inout (NULL),
     options (options_),
     reconnect (reconnect_)
@@ -160,6 +160,13 @@ void zmq::zmq_engine_t::revive ()
     out_event ();
 }
 
+void zmq::zmq_engine_t::traceroute (unsigned char *identity_,
+    size_t identity_size_)
+{
+    encoder.trim_prefix ();
+    decoder.add_prefix (identity_, identity_size_);
+}
+
 void zmq::zmq_engine_t::error ()
 {
     zmq_assert (inout);