From 8b29c360d948b0a00b997e600a5b141ef293d3a1 Mon Sep 17 00:00:00 2001
From: Aleksandar Fabijanic <aleks-f@users.noreply.github.com>
Date: Tue, 16 Jan 2024 22:48:44 +0100
Subject: [PATCH] fix(SocketReactorTest): deadlock test intermittently hangs
 #4400

---
 Net/src/SocketReactor.cpp               |  4 ++--
 Net/testsuite/src/SocketReactorTest.cpp | 12 +++++++-----
 cppignore.win                           |  3 +--
 3 files changed, 10 insertions(+), 9 deletions(-)

diff --git a/Net/src/SocketReactor.cpp b/Net/src/SocketReactor.cpp
index 32700ee376..2815d07899 100644
--- a/Net/src/SocketReactor.cpp
+++ b/Net/src/SocketReactor.cpp
@@ -27,7 +27,7 @@ namespace Poco {
 namespace Net {
 
 
-SocketReactor::SocketReactor():
+SocketReactor::SocketReactor(): _threadAffinity(-1),
 	_stop(false),
 	_pReadableNotification(new ReadableNotification(this)),
 	_pWritableNotification(new WritableNotification(this)),
@@ -86,6 +86,7 @@ void SocketReactor::run()
 			if (hasSocketHandlers())
 			{
 				sm = _pollSet.poll(_params.pollTimeout);
+				if (_stop) break;
 				for (const auto& s : sm)
 				{
 					try
@@ -167,7 +168,6 @@ void SocketReactor::stop()
 
 void SocketReactor::wakeUp()
 {
-	if (_stop) return;
 	_pollSet.wakeUp();
 	_event.set();
 }
diff --git a/Net/testsuite/src/SocketReactorTest.cpp b/Net/testsuite/src/SocketReactorTest.cpp
index 2319c2618d..a07576c860 100644
--- a/Net/testsuite/src/SocketReactorTest.cpp
+++ b/Net/testsuite/src/SocketReactorTest.cpp
@@ -416,12 +416,14 @@ namespace
 		void onReadable(ReadableNotification* pNf)
 		{
 			pNf->release();
-			char buffer[64];
-			do
+			std::vector<char> buffer;
+			int n = 0;
+			while ((n = _socket.available()))
 			{
-				if (0 == _socket.receiveBytes(&buffer[0], sizeof(buffer)))
-					break;
-			} while (true);
+				if (n > buffer.size()) buffer.resize(n);
+				n = _socket.receiveBytes(&buffer[0], buffer.size());
+				if (0 == n) break;
+			}
 		}
 
 		void onShutdown(ShutdownNotification* pNf)
diff --git a/cppignore.win b/cppignore.win
index c762b60ac2..b72afc5d68 100644
--- a/cppignore.win
+++ b/cppignore.win
@@ -6,7 +6,7 @@ class CppUnit::TestCaller<class RawSocketTest>.testEchoIPv4Move
 class CppUnit::TestCaller<class ICMPClientTest>.testPing
 class CppUnit::TestCaller<class ICMPClientTest>.testBigPing
 class CppUnit::TestCaller<class HTTPSClientSessionTest>.testProxy
-class CppUnit::TestCaller<class HTTPSStreamFactoryTest>.testProxy  
+class CppUnit::TestCaller<class HTTPSStreamFactoryTest>.testProxy
 class CppUnit::TestCaller<class TCPServerTest>.testReuseSocket
 class CppUnit::TestCaller<class HTTPSClientSessionTest>.testInterop
 class CppUnit::TestCaller<class PathTest>.testFind
@@ -21,4 +21,3 @@ class CppUnit::TestCaller<class WinServiceTest>.testServiceReturnsTrueIfStopped
 class CppUnit::TestCaller<class ICMPSocketTest>.testSendToReceiveFrom
 class CppUnit::TestCaller<class ICMPSocketTest>.testMTU
 class CppUnit::TestCaller<class HTTPSClientSessionTest>.testCachedSession
-class CppUnit::TestCaller<class PollSetTest>.testPollClosedServer