From fa6bf24d8030b0e54fd25b167064482e4cf08a36 Mon Sep 17 00:00:00 2001 From: Martin Sustrik Date: Sun, 13 Dec 2009 14:45:23 +0100 Subject: XREP & XREQ socket types added; zmq_queue device added --- src/pgm_sender.cpp | 4 ---- 1 file changed, 4 deletions(-) (limited to 'src/pgm_sender.cpp') diff --git a/src/pgm_sender.cpp b/src/pgm_sender.cpp index 19fc0e2..69cb586 100644 --- a/src/pgm_sender.cpp +++ b/src/pgm_sender.cpp @@ -46,7 +46,6 @@ zmq::pgm_sender_t::pgm_sender_t (io_thread_t *parent_, write_pos (0), first_message_offset (-1) { - } int zmq::pgm_sender_t::init (bool udp_encapsulation_, const char *network_) @@ -56,7 +55,6 @@ int zmq::pgm_sender_t::init (bool udp_encapsulation_, const char *network_) void zmq::pgm_sender_t::plug (i_inout *inout_) { - // Alocate 2 fds for PGM socket. int downlink_socket_fd = 0; int uplink_socket_fd = 0; @@ -119,7 +117,6 @@ void zmq::pgm_sender_t::in_event () void zmq::pgm_sender_t::out_event () { - // POLLOUT event from send socket. If write buffer is empty, // try to read new data from the encoder. if (write_pos == write_size) { @@ -159,7 +156,6 @@ void zmq::pgm_sender_t::out_event () write_pos += nbytes; } - } size_t zmq::pgm_sender_t::write_one_pkt_with_offset (unsigned char *data_, -- cgit v1.2.3