more fixes to (e)pgm transport

1 files changed, 5 insertions, 0 deletions

diff --git a/src/pgm_socket.hpp b/src/pgm_socket.hpp
index 334e42f..142fdcc 100644
--- a/src/pgm_socket.hpp
+++ b/src/pgm_socket.hpp
@@ -67,6 +67,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 ();
@@ -76,6 +79,8 @@ namespace zmq
         //  OpenPGM transport
         pgm_sock_t* sock;
 
+        int last_rx_status, last_tx_status;
+
         //  Associated socket options.
         options_t options;