[2.4.3] hotfix - still need to notify in worker thread on socket remo…

…val.
Cylix · Jun 20, 2017 · cc98f8d · cc98f8d
1 parent 3851908
commit cc98f8d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/sources/network/unix/io_service.cpp b/sources/network/unix/io_service.cpp
@@ -161,6 +161,7 @@ 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();
     }
   };
 }
@@ -189,6 +190,7 @@ 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();
     }
   };
 }

diff --git a/sources/network/windows/io_service.cpp b/sources/network/windows/io_service.cpp
@@ -134,6 +134,7 @@ io_service::process_events(void) {
       __TACOPIE_LOG(debug, "untrack socket");
       m_tracked_sockets.erase(it);
       m_wait_for_removal_condvar.notify_all();
+      m_notifier.notify();
     }
   }
 }
@@ -162,6 +163,7 @@ 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();
     }
   };
 }