diff options
| author | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-13 14:45:23 +0100 |
|---|---|---|
| committer | Martin Sustrik <sustrik@fastmq.commkdir> | 2009-12-13 14:45:23 +0100 |
| commit | fa6bf24d8030b0e54fd25b167064482e4cf08a36 (patch) | |
| tree | 9f8f833da9607c9ba3376b45aa5cfafa4305e59c /src/pgm_sender.cpp | |
| parent | c43aded531014895973c283fdd82bb2e5e85c789 (diff) | |
XREP & XREQ socket types added; zmq_queue device added
Diffstat (limited to 'src/pgm_sender.cpp')
| -rw-r--r-- | src/pgm_sender.cpp | 4 |
1 files changed, 0 insertions, 4 deletions
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_, |