diff options
| author | 2022-08-01 22:47:39 +0200 | |
|---|---|---|
| committer | 2022-08-15 20:25:42 +0200 | |
| commit | 6d41088153b4b932b4f2524d4252993a5642f998 (patch) | |
| tree | 39ea8d5749f2a5bf9216b885780617e7f41c2a7e /src/core | |
| parent | core/socket_proxy: Fix compilation (diff) | |
| download | yuzu-6d41088153b4b932b4f2524d4252993a5642f998.tar.gz yuzu-6d41088153b4b932b4f2524d4252993a5642f998.tar.xz yuzu-6d41088153b4b932b4f2524d4252993a5642f998.zip | |
core, yuzu: Address first part of review comments
Diffstat (limited to 'src/core')
| -rw-r--r-- | src/core/announce_multiplayer_session.cpp | 6 | ||||
| -rw-r--r-- | src/core/hle/service/nifm/nifm.cpp | 1 | ||||
| -rw-r--r-- | src/core/internal_network/network.cpp | 8 | ||||
| -rw-r--r-- | src/core/internal_network/socket_proxy.cpp | 10 | ||||
| -rw-r--r-- | src/core/internal_network/socket_proxy.h | 3 | ||||
| -rw-r--r-- | src/core/internal_network/sockets.h | 6 |
6 files changed, 16 insertions, 18 deletions
diff --git a/src/core/announce_multiplayer_session.cpp b/src/core/announce_multiplayer_session.cpp index d73a488cf..6737ce85a 100644 --- a/src/core/announce_multiplayer_session.cpp +++ b/src/core/announce_multiplayer_session.cpp | |||
| @@ -31,7 +31,7 @@ AnnounceMultiplayerSession::AnnounceMultiplayerSession(Network::RoomNetwork& roo | |||
| 31 | } | 31 | } |
| 32 | 32 | ||
| 33 | WebService::WebResult AnnounceMultiplayerSession::Register() { | 33 | WebService::WebResult AnnounceMultiplayerSession::Register() { |
| 34 | std::shared_ptr<Network::Room> room = room_network.GetRoom().lock(); | 34 | auto room = room_network.GetRoom().lock(); |
| 35 | if (!room) { | 35 | if (!room) { |
| 36 | return WebService::WebResult{WebService::WebResult::Code::LibError, | 36 | return WebService::WebResult{WebService::WebResult::Code::LibError, |
| 37 | "Network is not initialized", ""}; | 37 | "Network is not initialized", ""}; |
| @@ -102,7 +102,7 @@ void AnnounceMultiplayerSession::UpdateBackendData(std::shared_ptr<Network::Room | |||
| 102 | void AnnounceMultiplayerSession::AnnounceMultiplayerLoop() { | 102 | void AnnounceMultiplayerSession::AnnounceMultiplayerLoop() { |
| 103 | // Invokes all current bound error callbacks. | 103 | // Invokes all current bound error callbacks. |
| 104 | const auto ErrorCallback = [this](WebService::WebResult result) { | 104 | const auto ErrorCallback = [this](WebService::WebResult result) { |
| 105 | std::lock_guard<std::mutex> lock(callback_mutex); | 105 | std::lock_guard lock(callback_mutex); |
| 106 | for (auto callback : error_callbacks) { | 106 | for (auto callback : error_callbacks) { |
| 107 | (*callback)(result); | 107 | (*callback)(result); |
| 108 | } | 108 | } |
| @@ -120,7 +120,7 @@ void AnnounceMultiplayerSession::AnnounceMultiplayerLoop() { | |||
| 120 | std::future<WebService::WebResult> future; | 120 | std::future<WebService::WebResult> future; |
| 121 | while (!shutdown_event.WaitUntil(update_time)) { | 121 | while (!shutdown_event.WaitUntil(update_time)) { |
| 122 | update_time += announce_time_interval; | 122 | update_time += announce_time_interval; |
| 123 | std::shared_ptr<Network::Room> room = room_network.GetRoom().lock(); | 123 | auto room = room_network.GetRoom().lock(); |
| 124 | if (!room) { | 124 | if (!room) { |
| 125 | break; | 125 | break; |
| 126 | } | 126 | } |
diff --git a/src/core/hle/service/nifm/nifm.cpp b/src/core/hle/service/nifm/nifm.cpp index 42ed17187..e3ef06481 100644 --- a/src/core/hle/service/nifm/nifm.cpp +++ b/src/core/hle/service/nifm/nifm.cpp | |||
| @@ -381,6 +381,7 @@ void IGeneralService::GetCurrentIpAddress(Kernel::HLERequestContext& ctx) { | |||
| 381 | rb.Push(ResultSuccess); | 381 | rb.Push(ResultSuccess); |
| 382 | rb.PushRaw(*ipv4); | 382 | rb.PushRaw(*ipv4); |
| 383 | } | 383 | } |
| 384 | |||
| 384 | void IGeneralService::CreateTemporaryNetworkProfile(Kernel::HLERequestContext& ctx) { | 385 | void IGeneralService::CreateTemporaryNetworkProfile(Kernel::HLERequestContext& ctx) { |
| 385 | LOG_DEBUG(Service_NIFM, "called"); | 386 | LOG_DEBUG(Service_NIFM, "called"); |
| 386 | 387 | ||
diff --git a/src/core/internal_network/network.cpp b/src/core/internal_network/network.cpp index 160cc83e4..3b6906f7d 100644 --- a/src/core/internal_network/network.cpp +++ b/src/core/internal_network/network.cpp | |||
| @@ -352,8 +352,8 @@ std::optional<IPv4Address> GetHostIPv4Address() { | |||
| 352 | return {}; | 352 | return {}; |
| 353 | } | 353 | } |
| 354 | 354 | ||
| 355 | char ip_addr[16] = {}; | 355 | std::array<char, 16> ip_addr = {}; |
| 356 | ASSERT(inet_ntop(AF_INET, &interface->ip_address, ip_addr, sizeof(ip_addr)) != nullptr); | 356 | ASSERT(inet_ntop(AF_INET, &interface->ip_address, ip_addr.data(), sizeof(ip_addr)) != nullptr); |
| 357 | return TranslateIPv4(interface->ip_address); | 357 | return TranslateIPv4(interface->ip_address); |
| 358 | } | 358 | } |
| 359 | 359 | ||
| @@ -402,9 +402,9 @@ Socket::Socket(Socket&& rhs) noexcept { | |||
| 402 | } | 402 | } |
| 403 | 403 | ||
| 404 | template <typename T> | 404 | template <typename T> |
| 405 | Errno Socket::SetSockOpt(SOCKET _fd, int option, T value) { | 405 | Errno Socket::SetSockOpt(SOCKET fd_, int option, T value) { |
| 406 | const int result = | 406 | const int result = |
| 407 | setsockopt(_fd, SOL_SOCKET, option, reinterpret_cast<const char*>(&value), sizeof(value)); | 407 | setsockopt(fd_, SOL_SOCKET, option, reinterpret_cast<const char*>(&value), sizeof(value)); |
| 408 | if (result != SOCKET_ERROR) { | 408 | if (result != SOCKET_ERROR) { |
| 409 | return Errno::SUCCESS; | 409 | return Errno::SUCCESS; |
| 410 | } | 410 | } |
diff --git a/src/core/internal_network/socket_proxy.cpp b/src/core/internal_network/socket_proxy.cpp index b9c50430e..216893ba1 100644 --- a/src/core/internal_network/socket_proxy.cpp +++ b/src/core/internal_network/socket_proxy.cpp | |||
| @@ -30,19 +30,19 @@ void ProxySocket::HandleProxyPacket(const ProxyPacket& packet) { | |||
| 30 | closed) { | 30 | closed) { |
| 31 | return; | 31 | return; |
| 32 | } | 32 | } |
| 33 | std::lock_guard<std::mutex> guard(packets_mutex); | 33 | std::lock_guard guard(packets_mutex); |
| 34 | received_packets.push(packet); | 34 | received_packets.push(packet); |
| 35 | } | 35 | } |
| 36 | 36 | ||
| 37 | template <typename T> | 37 | template <typename T> |
| 38 | Errno ProxySocket::SetSockOpt(SOCKET _fd, int option, T value) { | 38 | Errno ProxySocket::SetSockOpt(SOCKET fd_, int option, T value) { |
| 39 | socket_options[option] = reinterpret_cast<const char*>(&value); | 39 | socket_options[option] = reinterpret_cast<const char*>(&value); |
| 40 | return Errno::SUCCESS; | 40 | return Errno::SUCCESS; |
| 41 | } | 41 | } |
| 42 | 42 | ||
| 43 | Errno ProxySocket::Initialize(Domain domain, Type type, Protocol socket_protocol) { | 43 | Errno ProxySocket::Initialize(Domain domain, Type type, Protocol socket_protocol) { |
| 44 | protocol = socket_protocol; | 44 | protocol = socket_protocol; |
| 45 | socket_options[0x1008] = reinterpret_cast<const char*>(&type); | 45 | SetSockOpt(fd, SO_TYPE, type); |
| 46 | 46 | ||
| 47 | return Errno::SUCCESS; | 47 | return Errno::SUCCESS; |
| 48 | } | 48 | } |
| @@ -101,7 +101,7 @@ std::pair<s32, Errno> ProxySocket::RecvFrom(int flags, std::vector<u8>& message, | |||
| 101 | ASSERT(message.size() < static_cast<size_t>(std::numeric_limits<int>::max())); | 101 | ASSERT(message.size() < static_cast<size_t>(std::numeric_limits<int>::max())); |
| 102 | 102 | ||
| 103 | { | 103 | { |
| 104 | std::lock_guard<std::mutex> guard(packets_mutex); | 104 | std::lock_guard guard(packets_mutex); |
| 105 | if (received_packets.size() > 0) { | 105 | if (received_packets.size() > 0) { |
| 106 | return ReceivePacket(flags, message, addr, message.size()); | 106 | return ReceivePacket(flags, message, addr, message.size()); |
| 107 | } | 107 | } |
| @@ -115,7 +115,7 @@ std::pair<s32, Errno> ProxySocket::RecvFrom(int flags, std::vector<u8>& message, | |||
| 115 | return {-1, Errno::AGAIN}; | 115 | return {-1, Errno::AGAIN}; |
| 116 | } | 116 | } |
| 117 | 117 | ||
| 118 | std::lock_guard<std::mutex> guard(packets_mutex); | 118 | std::lock_guard guard(packets_mutex); |
| 119 | if (received_packets.size() > 0) { | 119 | if (received_packets.size() > 0) { |
| 120 | return ReceivePacket(flags, message, addr, message.size()); | 120 | return ReceivePacket(flags, message, addr, message.size()); |
| 121 | } | 121 | } |
diff --git a/src/core/internal_network/socket_proxy.h b/src/core/internal_network/socket_proxy.h index c9155f1af..ad917cac3 100644 --- a/src/core/internal_network/socket_proxy.h +++ b/src/core/internal_network/socket_proxy.h | |||
| @@ -14,7 +14,7 @@ namespace Network { | |||
| 14 | 14 | ||
| 15 | class ProxySocket : public SocketBase { | 15 | class ProxySocket : public SocketBase { |
| 16 | public: | 16 | public: |
| 17 | ProxySocket(RoomNetwork& room_network_) noexcept; | 17 | explicit ProxySocket(RoomNetwork& room_network_) noexcept; |
| 18 | ~ProxySocket() override; | 18 | ~ProxySocket() override; |
| 19 | 19 | ||
| 20 | ProxySocket(const ProxySocket&) = delete; | 20 | ProxySocket(const ProxySocket&) = delete; |
| @@ -82,6 +82,7 @@ public: | |||
| 82 | 82 | ||
| 83 | bool IsOpened() const override; | 83 | bool IsOpened() const override; |
| 84 | 84 | ||
| 85 | private: | ||
| 85 | bool broadcast = false; | 86 | bool broadcast = false; |
| 86 | bool closed = false; | 87 | bool closed = false; |
| 87 | u32 send_timeout = 0; | 88 | u32 send_timeout = 0; |
diff --git a/src/core/internal_network/sockets.h b/src/core/internal_network/sockets.h index 92dc49993..a70429b19 100644 --- a/src/core/internal_network/sockets.h +++ b/src/core/internal_network/sockets.h | |||
| @@ -32,7 +32,7 @@ public: | |||
| 32 | std::unique_ptr<SocketBase> socket; | 32 | std::unique_ptr<SocketBase> socket; |
| 33 | SockAddrIn sockaddr_in; | 33 | SockAddrIn sockaddr_in; |
| 34 | }; | 34 | }; |
| 35 | virtual ~SocketBase() {} | 35 | virtual ~SocketBase() = default; |
| 36 | 36 | ||
| 37 | virtual SocketBase& operator=(const SocketBase&) = delete; | 37 | virtual SocketBase& operator=(const SocketBase&) = delete; |
| 38 | 38 | ||
| @@ -89,11 +89,7 @@ public: | |||
| 89 | 89 | ||
| 90 | virtual void HandleProxyPacket(const ProxyPacket& packet) = 0; | 90 | virtual void HandleProxyPacket(const ProxyPacket& packet) = 0; |
| 91 | 91 | ||
| 92 | #if defined(_WIN32) | ||
| 93 | SOCKET fd = INVALID_SOCKET; | 92 | SOCKET fd = INVALID_SOCKET; |
| 94 | #elif YUZU_UNIX | ||
| 95 | int fd = -1; | ||
| 96 | #endif | ||
| 97 | }; | 93 | }; |
| 98 | 94 | ||
| 99 | class Socket : public SocketBase { | 95 | class Socket : public SocketBase { |