[2.4.4] fix #17 and cpp_redis#85 (select keep sleeping and does not p…

…rocess incoming read/write events).
Cylix · Jul 2, 2017 · ae0f2e9 · ae0f2e9
1 parent 4d4150a
commit ae0f2e9
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/sources/network/unix/io_service.cpp b/sources/network/unix/io_service.cpp
@@ -161,8 +161,9 @@ io_service::process_rd_event(const fd_t& fd, tracked_socket& socket) {
       __TACOPIE_LOG(debug, "untrack socket");
       m_tracked_sockets.erase(it);
       m_wait_for_removal_condvar.notify_all();
-      m_notifier.notify();
     }
+
+    m_notifier.notify();
   };
 }
 
@@ -190,8 +191,9 @@ io_service::process_wr_event(const fd_t& fd, tracked_socket& socket) {
       __TACOPIE_LOG(debug, "untrack socket");
       m_tracked_sockets.erase(it);
       m_wait_for_removal_condvar.notify_all();
-      m_notifier.notify();
     }
+
+    m_notifier.notify();
   };
 }
 

diff --git a/sources/network/windows/io_service.cpp b/sources/network/windows/io_service.cpp
@@ -162,8 +162,9 @@ io_service::process_rd_event(const fd_t& fd, tracked_socket& socket) {
       __TACOPIE_LOG(debug, "untrack socket");
       m_tracked_sockets.erase(it);
       m_wait_for_removal_condvar.notify_all();
-      m_notifier.notify();
     }
+
+    m_notifier.notify();
   };
 }
 
@@ -191,8 +192,9 @@ io_service::process_wr_event(const fd_t& fd, tracked_socket& socket) {
       __TACOPIE_LOG(debug, "untrack socket");
       m_tracked_sockets.erase(it);
       m_wait_for_removal_condvar.notify_all();
-      m_notifier.notify();
     }
+
+    m_notifier.notify();
   };
 }