From f8bf3a4cef6b8e1688683ab8c5ed6dd1bc8e3a12 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Mon, 27 Jun 2011 18:16:53 +0200 Subject: Rename i_inout to i_engine_sink Signed-off-by: Martin Sustrik --- src/decoder.cpp | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) (limited to 'src/decoder.cpp') 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 #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 (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); -- cgit v1.2.3