diff options
Diffstat (limited to 'src/pgm_socket.hpp')
-rw-r--r-- | src/pgm_socket.hpp | 8 |
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; |