oss/luanti
oss/luanti
1
0
Fork 0
mirror of https://github.com/luanti-org/luanti.git synced 2025-06-27 16:36:03 +00:00
Code Wiki Activity

Connection: Fix deadlock in debug mode (#9550)

Browse source
This commit is contained in:
SmallJoker 2020-03-26 19:13:50 +01:00 • committed by GitHub
parent f7c7353a9a
commit a0998754a7
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 21 additions and 11 deletions
Download patch file Download diff file Expand all files Collapse all files

12
src/network/connection.cpp
View file

@ -44,6 +44,7 @@ namespace con
#define LOG(a) a #define LOG(a) a
#define PROFILE(a) #define PROFILE(a)
#else #else
#if 0
/* this mutex is used to achieve log message consistency */ /* this mutex is used to achieve log message consistency */
std::mutex log_message_mutex; std::mutex log_message_mutex;
#define LOG(a) \ #define LOG(a) \
@ -51,6 +52,11 @@ std::mutex log_message_mutex;
MutexAutoLock loglock(log_message_mutex); \ MutexAutoLock loglock(log_message_mutex); \
a; \ a; \
} }
#else
// Prevent deadlocks until a solution is found after 5.2.0 (TODO)
#define LOG(a) a
#endif
#define PROFILE(a) a #define PROFILE(a) a
#endif #endif
@ -1073,6 +1079,10 @@ bool UDPPeer::processReliableSendCommand(
FATAL_ERROR_IF(!successfully_put_back_sequence_number, "error"); FATAL_ERROR_IF(!successfully_put_back_sequence_number, "error");
} }
// DO NOT REMOVE n_queued! It avoids a deadlock of async locked
// 'log_message_mutex' and 'm_list_mutex'.
u32 n_queued = channels[c.channelnum].outgoing_reliables_sent.size();
LOG(dout_con<<m_connection->getDesc() LOG(dout_con<<m_connection->getDesc()
<< " Windowsize exceeded on reliable sending " << " Windowsize exceeded on reliable sending "
<< c.data.getSize() << " bytes" << c.data.getSize() << " bytes"
@ -1081,7 +1091,7 @@ bool UDPPeer::processReliableSendCommand(
<< std::endl << "\t\tgot at most : " << std::endl << "\t\tgot at most : "
<< packets_available << " packets" << packets_available << " packets"
<< std::endl << "\t\tpackets queued : " << std::endl << "\t\tpackets queued : "
<< channels[c.channelnum].outgoing_reliables_sent.size() << n_queued
<< std::endl); << std::endl);
return false; return false;