summaryrefslogtreecommitdiff
path: root/src/pgm_sender.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/pgm_sender.cpp')
-rw-r--r--src/pgm_sender.cpp18
1 files changed, 0 insertions, 18 deletions
diff --git a/src/pgm_sender.cpp b/src/pgm_sender.cpp
index 964e00b..7686286 100644
--- a/src/pgm_sender.cpp
+++ b/src/pgm_sender.cpp
@@ -74,19 +74,13 @@ 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;
-#ifdef ZMQ_HAVE_OPENPGM2
int rdata_notify_fd = 0;
-#endif
encoder.set_inout (inout_);
// Fill fds from PGM transport.
-#ifdef ZMQ_HAVE_OPENPGM1
- pgm_socket.get_sender_fds (&downlink_socket_fd, &uplink_socket_fd);
-#elif ZMQ_HAVE_OPENPGM2
pgm_socket.get_sender_fds
(&downlink_socket_fd, &uplink_socket_fd, &rdata_notify_fd);
-#endif
// Add downlink_socket_fd into poller.
handle = add_fd (downlink_socket_fd);
@@ -95,16 +89,12 @@ void zmq::pgm_sender_t::plug (i_inout *inout_)
uplink_handle = add_fd (uplink_socket_fd);
// Add rdata_notify_fd into the poller.
-#ifdef ZMQ_HAVE_OPENPGM2
rdata_notify_handle = add_fd (rdata_notify_fd);
-#endif
// Set POLLIN. We wont never want to stop polling for uplink = we never
// want to stop porocess NAKs.
set_pollin (uplink_handle);
-#ifdef ZMQ_HAVE_OPENPGM2
set_pollin (rdata_notify_handle);
-#endif
// Set POLLOUT for downlink_socket_handle.
set_pollout (handle);
@@ -116,9 +106,7 @@ void zmq::pgm_sender_t::unplug ()
{
rm_fd (handle);
rm_fd (uplink_handle);
-#ifdef ZMQ_HAVE_OPENPGM2
rm_fd (rdata_notify_handle);
-#endif
encoder.set_inout (NULL);
inout = NULL;
}
@@ -195,12 +183,6 @@ void zmq::pgm_sender_t::out_event ()
zmq_log (1, "pgm rate limit reached, %s(%i)\n", __FILE__, __LINE__);
}
-#ifdef ZMQ_HAVE_OPENPGM1
- // After sending data slice is owned by tx window.
- if (nbytes) {
- out_buffer = NULL;
- }
-#endif
write_pos += nbytes;
}