diff options
| -rw-r--r-- | src/pgm_sender.cpp | 23 |
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_) { |