summaryrefslogtreecommitdiff
path: root/src/pgm_socket.hpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/pgm_socket.hpp')
-rw-r--r--src/pgm_socket.hpp8
1 files changed, 7 insertions, 1 deletions
diff --git a/src/pgm_socket.hpp b/src/pgm_socket.hpp
index b9f55d1..10af0c2 100644
--- a/src/pgm_socket.hpp
+++ b/src/pgm_socket.hpp
@@ -28,6 +28,7 @@
#include "windows.hpp"
#endif
+#define __PGM_WININT_H__
#include <pgm/pgm.h>
#include "options.hpp"
@@ -67,6 +68,9 @@ namespace zmq
// Receive data from pgm socket.
ssize_t receive (void **data_, const pgm_tsi_t **tsi_);
+ long get_rx_timeout ();
+ long get_tx_timeout ();
+
// POLLIN on sender side should mean NAK or SPMR receiving.
// process_upstream function is used to handle such a situation.
void process_upstream ();
@@ -74,7 +78,9 @@ namespace zmq
private:
// OpenPGM transport
- pgm_transport_t* transport;
+ pgm_sock_t* sock;
+
+ int last_rx_status, last_tx_status;
// Associated socket options.
options_t options;