From 11fec367d1a13c3f0248f8542eb805b8d9571685 Mon Sep 17 00:00:00 2001 From: malosek Date: Tue, 5 Jan 2010 11:22:14 +0100 Subject: added pending event fd handling by the pgm_sender --- src/pgm_socket.cpp | 10 +++++++--- 1 file changed, 7 insertions(+), 3 deletions(-) (limited to 'src/pgm_socket.cpp') diff --git a/src/pgm_socket.cpp b/src/pgm_socket.cpp index 0fbe58a..11084ff 100644 --- a/src/pgm_socket.cpp +++ b/src/pgm_socket.cpp @@ -375,13 +375,15 @@ void zmq::pgm_socket_t::get_receiver_fds (int *receive_fd_, // sender_fd is from pgm_transport->send_sock. // receive_fd_ is from transport->recv_sock. // rdata_notify_fd_ is from transport->rdata_notify. +// pending_notify_fd_ is from transport->pending_notify. void zmq::pgm_socket_t::get_sender_fds (int *send_fd_, int *receive_fd_, - int *rdata_notify_fd_) + int *rdata_notify_fd_, int *pending_notify_fd_) { zmq_assert (send_fd_); zmq_assert (receive_fd_); zmq_assert (rdata_notify_fd_); + zmq_assert (pending_notify_fd_); // recv_sock2 should not be used - check it. zmq_assert (transport->recv_sock2 == -1); @@ -390,10 +392,12 @@ void zmq::pgm_socket_t::get_sender_fds (int *send_fd_, int *receive_fd_, zmq_assert (transport->can_send_data); zmq_assert (!transport->can_recv_data); - // Take FDs directly from transport. + // Take FDs from transport. + *send_fd_ = pgm_transport_get_send_fd (transport); *receive_fd_ = pgm_transport_get_recv_fd (transport); + *rdata_notify_fd_ = pgm_transport_get_repair_fd (transport); - *send_fd_ = pgm_transport_get_send_fd (transport); + *pending_notify_fd_ = pgm_transport_get_pending_fd (transport); } // Send one APDU, transmit window owned memory. -- cgit v1.2.3