summaryrefslogtreecommitdiff
path: root/src/encoder.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2011-06-27 18:16:53 +0200
committerMartin Sustrik <sustrik@250bpm.com>2011-06-27 18:16:53 +0200
commitf8bf3a4cef6b8e1688683ab8c5ed6dd1bc8e3a12 (patch)
treec73fa27cb241d8b4639b0cc535fbd3c6f39c3821 /src/encoder.cpp
parent3ae73ee11f13bbc9c91b235de18fde763c359009 (diff)
Rename i_inout to i_engine_sink
Signed-off-by: Martin Sustrik <sustrik@250bpm.com>
Diffstat (limited to 'src/encoder.cpp')
-rw-r--r--src/encoder.cpp10
1 files changed, 5 insertions, 5 deletions
diff --git a/src/encoder.cpp b/src/encoder.cpp
index f579deb..a9be68c 100644
--- a/src/encoder.cpp
+++ b/src/encoder.cpp
@@ -19,12 +19,12 @@
*/
#include "encoder.hpp"
-#include "i_inout.hpp"
+#include "i_engine.hpp"
#include "wire.hpp"
zmq::encoder_t::encoder_t (size_t bufsize_) :
encoder_base_t <encoder_t> (bufsize_),
- source (NULL)
+ sink (NULL)
{
int rc = in_progress.init ();
errno_assert (rc == 0);
@@ -39,9 +39,9 @@ zmq::encoder_t::~encoder_t ()
errno_assert (rc == 0);
}
-void zmq::encoder_t::set_inout (i_inout *source_)
+void zmq::encoder_t::set_sink (i_engine_sink *sink_)
{
- source = source_;
+ sink = sink_;
}
bool zmq::encoder_t::size_ready ()
@@ -62,7 +62,7 @@ bool zmq::encoder_t::message_ready ()
// Note that new state is set only if write is successful. That way
// unsuccessful write will cause retry on the next state machine
// invocation.
- if (!source || !source->read (&in_progress)) {
+ if (!sink || !sink->read (&in_progress)) {
rc = in_progress.init ();
errno_assert (rc == 0);
return false;