RPCS3/rpcs3
1
0
Fork 0
mirror of https://github.com/RPCS3/rpcs3.git synced 2025-01-31 20:41:45 +01:00
Code Issues Releases Wiki Activity

Fix tcp_timeout_monitor abort

Browse Source
This commit is contained in:
Eladash 2023-12-17 23:45:15 +02:00 committed by Elad Ashkenazi
parent 9f0cb9148f
commit 7e853abc4b
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
rpcs3/Emu/Cell/lv2/sys_net/lv2_socket_p2ps.cpp
View File

@ -74,6 +74,12 @@ public:
while (thread_ctrl::state() != thread_state::aborting) while (thread_ctrl::state() != thread_state::aborting)
{ {
std::unique_lock<std::mutex> lock(data_mutex); std::unique_lock<std::mutex> lock(data_mutex);
if (thread_ctrl::state() == thread_state::aborting)
{
break;
}
if (msgs.size()) if (msgs.size())
wakey.wait_until(lock, msgs.begin()->first); wakey.wait_until(lock, msgs.begin()->first);
else else
@ -150,6 +156,8 @@ public:
tcp_timeout_monitor& operator=(thread_state) tcp_timeout_monitor& operator=(thread_state)
{ {
data_mutex.lock();
data_mutex.unlock();
wakey.notify_one(); wakey.notify_one();
return *this; return *this;
} }