kill process thread when socket read thread exits

goatpig · Nov 6, 2018 · 2f82560 · 2f82560
1 parent e62b347
commit 2f82560
Show file tree

Hide file tree

Showing 2 changed files with 9 additions and 1 deletion.
diff --git a/cppForSwig/BitcoinP2P.cpp b/cppForSwig/BitcoinP2P.cpp
@@ -1407,9 +1407,13 @@ void BitcoinP2P::updateNodeStatus(bool connected)
 ////////////////////////////////////////////////////////////////////////////////
 void  BitcoinP2PSocket::respond(vector<uint8_t>& packet)
 {
-   readDataStack_->push_back(move(packet));
+   if (packet.size() >= 0)
+      readDataStack_->push_back(move(packet));
+   else
+      readDataStack_->terminate();
 }
 
+
 ////////////////////////////////////////////////////////////////////////////////
 void BitcoinP2PSocket::pushPayload(
    unique_ptr<Socket_WritePayload> write_payload,

diff --git a/cppForSwig/SocketObject.cpp b/cppForSwig/SocketObject.cpp
@@ -549,6 +549,7 @@ void PersistentSocket::socketService_win()
    }
 
    run_.store(false, memory_order_relaxed);
+   readQueue_.terminate();
 }
 #endif
 
@@ -587,6 +588,9 @@ void PersistentSocket::readService()
 
       respond(payload);
    }
+
+   vector<uint8_t> emptyPacket;
+   respond(emptyPacket);
 }
 
 ///////////////////////////////////////////////////////////////////////////////