diff options
author | Martin Sustrik <sustrik@250bpm.com> | 2011-06-27 18:16:53 +0200 |
---|---|---|
committer | Martin Sustrik <sustrik@250bpm.com> | 2011-06-27 18:16:53 +0200 |
commit | f8bf3a4cef6b8e1688683ab8c5ed6dd1bc8e3a12 (patch) | |
tree | c73fa27cb241d8b4639b0cc535fbd3c6f39c3821 /src/decoder.cpp | |
parent | 3ae73ee11f13bbc9c91b235de18fde763c359009 (diff) |
Rename i_inout to i_engine_sink
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/decoder.cpp')
-rw-r--r-- | src/decoder.cpp | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/decoder.cpp b/src/decoder.cpp index bcf5974..8fc1d5e 100644 --- a/src/decoder.cpp +++ b/src/decoder.cpp @@ -22,13 +22,13 @@ #include <string.h> #include "decoder.hpp" -#include "i_inout.hpp" +#include "i_engine.hpp" #include "wire.hpp" #include "err.hpp" zmq::decoder_t::decoder_t (size_t bufsize_, int64_t maxmsgsize_) : decoder_base_t <decoder_t> (bufsize_), - destination (NULL), + sink (NULL), maxmsgsize (maxmsgsize_) { int rc = in_progress.init (); @@ -44,9 +44,9 @@ zmq::decoder_t::~decoder_t () errno_assert (rc == 0); } -void zmq::decoder_t::set_inout (i_inout *destination_) +void zmq::decoder_t::set_sink (i_engine_sink *sink_) { - destination = destination_; + sink = sink_; } bool zmq::decoder_t::one_byte_size_ready () @@ -136,7 +136,7 @@ bool zmq::decoder_t::message_ready () { // Message is completely read. Push it further and start reading // new message. (in_progress is a 0-byte message after this point.) - if (!destination || !destination->write (&in_progress)) + if (!sink || !sink->write (&in_progress)) return false; next_step (tmpbuf, 1, &decoder_t::one_byte_size_ready); |