summaryrefslogtreecommitdiff
path: root/src/pgm_socket.hpp
diff options
context:
space:
mode:
authormalosek <malosek@fastmq.com>2009-09-28 18:06:06 +0200
committermalosek <malosek@fastmq.com>2009-09-28 18:06:06 +0200
commit39d915ded8ccb612ae1f9aaefcd93f349f4c8f4c (patch)
tree1da94b99d5072345e53d58ba5e304887ee7f1c1f /src/pgm_socket.hpp
parentcf6cc0128ff4d26e0059f399bbb8342ce259b996 (diff)
PGM2 sender
Diffstat (limited to 'src/pgm_socket.hpp')
-rw-r--r--src/pgm_socket.hpp8
1 files changed, 6 insertions, 2 deletions
diff --git a/src/pgm_socket.hpp b/src/pgm_socket.hpp
index 5225e50..473e58c 100644
--- a/src/pgm_socket.hpp
+++ b/src/pgm_socket.hpp
@@ -65,7 +65,7 @@ namespace zmq
// Get sender and receiver fds and store it to user allocated
// memory. Receive fd is used to process NAKs from peers.
- int get_sender_fds (int *send_fd_, int *receive_fd_);
+ int get_sender_fds (int *send_fd_, int *receive_fd_, int *rdata_notify_fd_ = NULL);
// Send data as one APDU, transmit window owned memory.
size_t send (unsigned char *data_, size_t data_len_);
@@ -143,8 +143,12 @@ namespace zmq
size_t pgm_msgv_len;
// Sender transport uses 2 fd.
+#ifdef ZMQ_HAVE_OPENPGM1
enum {pgm_sender_fd_count = 2};
-
+#elif ZMQ_HAVE_OPENPGM2
+ enum {pgm_sender_fd_count = 3};
+#endif
+
// Receiver transport uses 2 fd.
enum {pgm_receiver_fd_count = 2};
#endif