summaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
Diffstat (limited to 'src')
-rw-r--r--src/pgm_sender.cpp23
1 files changed, 1 insertions, 22 deletions
diff --git a/src/pgm_sender.cpp b/src/pgm_sender.cpp
index 60b4c3a..8e7a66b 100644
--- a/src/pgm_sender.cpp
+++ b/src/pgm_sender.cpp
@@ -108,6 +108,7 @@ void zmq::pgm_sender_t::unplug ()
void zmq::pgm_sender_t::revive ()
{
set_pollout (handle);
+ out_event ();
}
zmq::pgm_sender_t::~pgm_sender_t ()
@@ -181,28 +182,6 @@ void zmq::pgm_sender_t::out_event ()
}
-/*
-void zmq::bp_pgm_sender_t::revive (pipe_t *pipe_)
-{
- // We have some messages in encoder.
- if (!shutting_down) {
-
- // Forward the revive command to the pipe.
- engine_base_t <false, true>::revive (pipe_);
-
- // There is at least one engine (that one which sent revive) that
- // has messages ready. Try to write data to the socket, thus
- // eliminating one polling for POLLOUT event.
- // Note that if write_size is zero it means that buffer is empty and
- // we can read data from encoder.
- if (!write_size) {
- poller->set_pollout (handle);
- out_event (handle);
- }
- }
-}
-
-*/
size_t zmq::pgm_sender_t::write_one_pkt_with_offset (unsigned char *data_,
size_t size_, uint16_t offset_)
{