summaryrefslogtreecommitdiff
path: root/src/core
diff options
context:
space:
mode:
authorGravatar FearlessTobi2022-08-01 22:47:39 +0200
committerGravatar FearlessTobi2022-08-15 20:25:42 +0200
commit6d41088153b4b932b4f2524d4252993a5642f998 (patch)
tree39ea8d5749f2a5bf9216b885780617e7f41c2a7e /src/core
parentcore/socket_proxy: Fix compilation (diff)
downloadyuzu-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.cpp6
-rw-r--r--src/core/hle/service/nifm/nifm.cpp1
-rw-r--r--src/core/internal_network/network.cpp8
-rw-r--r--src/core/internal_network/socket_proxy.cpp10
-rw-r--r--src/core/internal_network/socket_proxy.h3
-rw-r--r--src/core/internal_network/sockets.h6
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
33WebService::WebResult AnnounceMultiplayerSession::Register() { 33WebService::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
102void AnnounceMultiplayerSession::AnnounceMultiplayerLoop() { 102void 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
384void IGeneralService::CreateTemporaryNetworkProfile(Kernel::HLERequestContext& ctx) { 385void 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
404template <typename T> 404template <typename T>
405Errno Socket::SetSockOpt(SOCKET _fd, int option, T value) { 405Errno 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
37template <typename T> 37template <typename T>
38Errno ProxySocket::SetSockOpt(SOCKET _fd, int option, T value) { 38Errno 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
43Errno ProxySocket::Initialize(Domain domain, Type type, Protocol socket_protocol) { 43Errno 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
15class ProxySocket : public SocketBase { 15class ProxySocket : public SocketBase {
16public: 16public:
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
85private:
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
99class Socket : public SocketBase { 95class Socket : public SocketBase {