summaryrefslogtreecommitdiff
path: root/src/pipe.cpp
diff options
context:
space:
mode:
authorMartin Sustrik <sustrik@250bpm.com>2010-08-28 10:15:03 +0200
committerMartin Sustrik <sustrik@250bpm.com>2010-08-28 10:15:03 +0200
commit42000d2c4f988a164eaeb9b580a4f588d91e353e (patch)
tree1f148dbd4b4d78966a4554dbc215761d06623bb1 /src/pipe.cpp
parent92923cd40b645af844c5ed1055a0a45c6daa3c89 (diff)
terminology unified: revive->activate
Diffstat (limited to 'src/pipe.cpp')
-rw-r--r--src/pipe.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/pipe.cpp b/src/pipe.cpp
index 8785330..7fa7133 100644
--- a/src/pipe.cpp
+++ b/src/pipe.cpp
@@ -112,7 +112,7 @@ bool zmq::reader_t::read (zmq_msg_t *msg_)
msgs_read++;
if (lwm > 0 && msgs_read % lwm == 0)
- send_reader_info (writer, msgs_read);
+ send_activate_writer (writer, msgs_read);
return true;
}
@@ -127,7 +127,7 @@ void zmq::reader_t::terminate ()
send_pipe_term (writer);
}
-void zmq::reader_t::process_revive ()
+void zmq::reader_t::process_activate_reader ()
{
// Forward the event to the sink (either socket or session).
sink->activated (this);
@@ -258,7 +258,7 @@ void zmq::writer_t::rollback ()
void zmq::writer_t::flush ()
{
if (!pipe->flush ())
- send_revive (reader);
+ send_activate_reader (reader);
}
void zmq::writer_t::terminate ()
@@ -288,7 +288,7 @@ void zmq::writer_t::write_delimiter ()
flush ();
}
-void zmq::writer_t::process_reader_info (uint64_t msgs_read_)
+void zmq::writer_t::process_activate_writer (uint64_t msgs_read_)
{
zmq_msg_t msg;