Polling on SURVEYOR socket implemented

Signed-off-by: Martin Sustrik <sustrik@250bpm.com>

1 files changed, 5 insertions, 1 deletions

diff --git a/src/surveyor.hpp b/src/surveyor.hpp
index e79dab0..1661d9c 100644
--- a/src/surveyor.hpp
+++ b/src/surveyor.hpp
@@ -23,12 +23,12 @@
 
 #include "xsurveyor.hpp"
 #include "stdint.hpp"
+#include "msg.hpp"
 
 namespace xs
 {
 
     class ctx_t;
-    class msg_t;
     class io_thread_t;
     class socket_base_t;
 
@@ -57,6 +57,10 @@ namespace xs
         //  The time instant when the current survey expires.
         uint64_t timeout;
 
+        //  Inbound message prefetched during polling.
+        bool has_prefetched;
+        msg_t prefetched;
+
         surveyor_t (const surveyor_t&);
         const surveyor_t &operator = (const surveyor_t&);
     };