mirror of
https://github.com/pocoproject/poco.git
synced 2026-01-11 08:34:20 +01:00
6d602ea6b3
* fix(NotificationCenter): use RWLock to prevent lock-order-inversion #5150 Change NotificationCenter from Mutex to RWLock to fix TSAN lock-order-inversion warnings when notification handlers call back into the notification center (e.g., hasEventHandler() from within a SocketReactor handler). Key changes: - Replace Mutex with RWLock for better read concurrency - Use read locks for hasObserver(), observersToNotify(), hasObservers(), countObservers(), backlog() - Use write locks for addObserver(), removeObserver(), clear() - observersToNotify() now copies observer list and releases lock before calling accepts() to avoid lock cycle with NObserver's internal mutex - Add clear() method to atomically disable and remove all observers - Update AsyncNotificationCenter to use RWLock::ScopedLock Also fixes AsyncNotificationCenter shutdown to properly signal the dequeue thread via ShutdownNotification instead of relying only on wakeUpAll() #5058 * fix(Net): add SocketReactor::remove() for safe socket cleanup #5150 Add SocketReactor::remove() method that atomically removes a socket from the poll set and disables all its event handlers. This prevents race conditions when removing handlers in destructors, where events could still be dispatched to handlers while other handlers for the same socket are being removed. Changes: - Add SocketReactor::remove(socket) for atomic socket removal - Add SocketNotifier::disableObservers() to disable all handlers - Add SocketNotifier::socket() getter - Skip dispatch for removed sockets in dispatch() methods - Update tests to use remove() before removeEventHandler() - Add testSocketReactorRemove() test * fix(Foundation): improve ProcessRunner robustness #5054 - Fix race condition: set _pPH after _pid to ensure pid() returns valid value when running() returns true - Add upfront invalid PID validation before termination attempt - Escalate to Process::kill() if requestTermination times out, with its own timeout before throwing - Try to remove stale PID file on timeout instead of throwing - Wrap start() wait logic in try/catch to kill orphan process and reset state if startup fails - Clear _error under lock after successful stop to prevent stale error from affecting next start() * Update Net/include/Poco/Net/SocketReactor.h Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * Update Foundation/src/AsyncNotificationCenter.cpp Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * Update Foundation/include/Poco/AsyncNotificationCenter.h Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * Update Foundation/src/AsyncNotificationCenter.cpp Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * chore: add TaskManager::testCancel to win ignore list * chore: few improvements in NotificationCenter and ODBC cmake. --------- Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> Co-authored-by: Matej Kenda <matejken@gmail.com>
30 lines
1.8 KiB
Plaintext
30 lines
1.8 KiB
Plaintext
class CppUnit::TestCaller<class NTPClientTest>.testTimeSync
|
|
class CppUnit::TestCaller<class GlobTest>.testGlob
|
|
class CppUnit::TestCaller<class RawSocketTest>.testEchoIPv4
|
|
class CppUnit::TestCaller<class RawSocketTest>.testSendToReceiveFromIPv4
|
|
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 TCPServerTest>.testReuseSocket
|
|
class CppUnit::TestCaller<class HTTPSClientSessionTest>.testInterop
|
|
class CppUnit::TestCaller<class PathTest>.testFind
|
|
class CppUnit::TestCaller<class ThreadTest>.testSleep
|
|
class CppUnit::TestCaller<class TimerTest>.testTimer
|
|
class CppUnit::TestCaller<class TimerTest>.testScheduleInterval
|
|
class CppUnit::TestCaller<class TimerTest>.testScheduleIntervalTimestamp
|
|
class CppUnit::TestCaller<class TimerTest>.testScheduleIntervalClock
|
|
class CppUnit::TestCaller<class TimerTest>.testScheduleAtFixedRate
|
|
class CppUnit::TestCaller<class SystemConfigurationTest>.testProperties
|
|
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 SyslogTest>.testListener
|
|
class CppUnit::TestCaller<class SyslogTest>.testChannelFacility
|
|
class CppUnit::TestCaller<class SyslogTest>.testChannelOpenClose
|
|
class CppUnit::TestCaller<class SyslogTest>.testOldBSD
|
|
class CppUnit::TestCaller<class SyslogTest>.testStructuredData
|
|
class CppUnit::TestCaller<class TaskManagerTest>.testCancel
|