From f44b215a60f50e8730a50522d7b9f2d5b4381d19 Mon Sep 17 00:00:00 2001 From: malosek Date: Tue, 15 Sep 2009 09:47:25 +0200 Subject: added out_event call into pgm_sender_t revive --- src/pgm_sender.cpp | 23 +---------------------- 1 file changed, 1 insertion(+), 22 deletions(-) (limited to 'src/pgm_sender.cpp') 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 ::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_) { -- cgit v1.2.3