From 597fb9ff6dd8ab4500141186f0ebebd2aaea92f0 Mon Sep 17 00:00:00 2001 From: Sepalani Date: Mon, 22 Aug 2022 12:39:02 +0400 Subject: [PATCH] Move SocketManager's DecodeError to Common Fix thread safety issue --- Source/Core/Common/Network.cpp | 21 +++++++++++++++++++ Source/Core/Common/Network.h | 1 + Source/Core/Core/IOS/Network/Socket.cpp | 28 +++++-------------------- 3 files changed, 27 insertions(+), 23 deletions(-) diff --git a/Source/Core/Common/Network.cpp b/Source/Core/Common/Network.cpp index 2d532690c1..a112fb9a99 100644 --- a/Source/Core/Common/Network.cpp +++ b/Source/Core/Common/Network.cpp @@ -9,6 +9,7 @@ #ifndef _WIN32 #include +#include #include #include #else @@ -545,4 +546,24 @@ void RestoreNetworkErrorState(const NetworkErrorState& state) WSASetLastError(state.wsa_error); #endif } + +const char* DecodeNetworkError(s32 error_code) +{ + thread_local char buffer[1024]; +#define IS_BSD_STRERROR \ + defined(__FreeBSD__) || defined(__OpenBSD__) || defined(__NetBSD__) || defined(ANDROID) || \ + defined(__APPLE__) +#ifdef _WIN32 + FormatMessageA(FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS | + FORMAT_MESSAGE_MAX_WIDTH_MASK, + nullptr, error_code, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), buffer, + sizeof(buffer), nullptr); + return buffer; +#elif (IS_BSD_STRERROR) || ((_POSIX_C_SOURCE >= 200112L || _XOPEN_SOURCE >= 600) && !_GNU_SOURCE) + strerror_r(error_code, buffer, sizeof(buffer)); + return buffer; +#else + return strerror_r(error_code, buffer, sizeof(buffer)); +#endif +} } // namespace Common diff --git a/Source/Core/Common/Network.h b/Source/Core/Common/Network.h index 27eaad7c42..c615d31451 100644 --- a/Source/Core/Common/Network.h +++ b/Source/Core/Common/Network.h @@ -265,4 +265,5 @@ u16 ComputeTCPNetworkChecksum(const IPAddress& from, const IPAddress& to, const u16 length, u8 protocol); NetworkErrorState SaveNetworkErrorState(); void RestoreNetworkErrorState(const NetworkErrorState& state); +const char* DecodeNetworkError(s32 error_code); } // namespace Common diff --git a/Source/Core/Core/IOS/Network/Socket.cpp b/Source/Core/Core/IOS/Network/Socket.cpp index dcccf5977f..11e285d2f7 100644 --- a/Source/Core/Core/IOS/Network/Socket.cpp +++ b/Source/Core/Core/IOS/Network/Socket.cpp @@ -38,23 +38,6 @@ namespace IOS::HLE { -char* WiiSockMan::DecodeError(s32 ErrorCode) -{ -#ifdef _WIN32 - // NOT THREAD SAFE - static char Message[1024]; - - FormatMessageA(FORMAT_MESSAGE_FROM_SYSTEM | FORMAT_MESSAGE_IGNORE_INSERTS | - FORMAT_MESSAGE_MAX_WIDTH_MASK, - nullptr, ErrorCode, MAKELANGID(LANG_NEUTRAL, SUBLANG_DEFAULT), Message, - sizeof(Message), nullptr); - - return Message; -#else - return strerror(ErrorCode); -#endif -} - // The following functions can return // - EAGAIN / EWOULDBLOCK: send(to), recv(from), accept // - EINPROGRESS: connect, bind @@ -117,7 +100,7 @@ s32 WiiSockMan::GetNetErrorCode(s32 ret, std::string_view caller, bool is_rw) } ERROR_LOG_FMT(IOS_NET, "{} failed with error {}: {}, ret= {}", caller, error_code, - DecodeError(error_code), ret); + Common::DecodeNetworkError(error_code), ret); const s32 return_value = TranslateErrorCode(error_code, is_rw); WiiSockMan::GetInstance().SetLastNetError(return_value); @@ -763,12 +746,11 @@ WiiSocket::ConnectingState WiiSocket::GetConnectingState() const FD_SET(fd, &write_fds); FD_SET(fd, &except_fds); - auto& sm = WiiSockMan::GetInstance(); if (select(nfds, &read_fds, &write_fds, &except_fds, &t) < 0) { const s32 error = get_errno(); ERROR_LOG_FMT(IOS_SSL, "Failed to get socket (fd={}) connection state (err={}): {}", wii_fd, - error, sm.DecodeError(error)); + error, Common::DecodeNetworkError(error)); return ConnectingState::Error; } @@ -781,14 +763,14 @@ WiiSocket::ConnectingState WiiSocket::GetConnectingState() const { error = get_errno(); ERROR_LOG_FMT(IOS_SSL, "Failed to get socket (fd={}) error state (err={}): {}", wii_fd, error, - sm.DecodeError(error)); + Common::DecodeNetworkError(error)); return ConnectingState::Error; } if (error != 0) { ERROR_LOG_FMT(IOS_SSL, "Non-blocking connect (fd={}) failed (err={}): {}", wii_fd, error, - sm.DecodeError(error)); + Common::DecodeNetworkError(error)); return ConnectingState::Error; } @@ -799,7 +781,7 @@ WiiSocket::ConnectingState WiiSocket::GetConnectingState() const { error = get_errno(); ERROR_LOG_FMT(IOS_SSL, "Non-blocking connect (fd={}) failed to get peername (err={}): {}", - wii_fd, error, sm.DecodeError(error)); + wii_fd, error, Common::DecodeNetworkError(error)); return ConnectingState::Error; }