diff options
Diffstat (limited to 'src/zmq_engine.cpp')
-rw-r--r-- | src/zmq_engine.cpp | 11 |
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); |