io_thread_t merged with poller_base_t

The relationship of these two classes was 1:1.
Thus one of them was obsolete.

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

1 files changed, 3 insertions, 3 deletions

diff --git a/src/socket_base.cpp b/src/socket_base.cpp
index 97ac4b4..492d027 100644
--- a/src/socket_base.cpp
+++ b/src/socket_base.cpp
@@ -39,7 +39,7 @@
 #include "tcp_listener.hpp"
 #include "ipc_listener.hpp"
 #include "tcp_connecter.hpp"
-#include "io_thread.hpp"
+#include "poller_base.hpp"
 #include "session_base.hpp"
 #include "config.hpp"
 #include "clock.hpp"
@@ -338,7 +338,7 @@ int xs::socket_base_t::bind (const char *addr_)
 
     //  Remaining trasnports require to be run in an I/O thread, so at this
     //  point we'll choose one.
-    io_thread_t *io_thread = choose_io_thread (options.affinity);
+    poller_base_t *io_thread = choose_io_thread (options.affinity);
     if (!io_thread) {
         errno = EMTHREAD;
         return -1;
@@ -449,7 +449,7 @@ int xs::socket_base_t::connect (const char *addr_)
     }
 
     //  Choose the I/O thread to run the session in.
-    io_thread_t *io_thread = choose_io_thread (options.affinity);
+    poller_base_t *io_thread = choose_io_thread (options.affinity);
     if (!io_thread) {
         errno = EMTHREAD;
         return -1;