summaryrefslogtreecommitdiffstats
path: root/src/core/internal_network
diff options
context:
space:
mode:
authorFearlessTobi <thm.frey@gmail.com>2022-08-01 22:47:39 +0200
committerFearlessTobi <thm.frey@gmail.com>2022-08-15 20:25:42 +0200
commit6d41088153b4b932b4f2524d4252993a5642f998 (patch)
tree39ea8d5749f2a5bf9216b885780617e7f41c2a7e /src/core/internal_network
parentcore/socket_proxy: Fix compilation (diff)
downloadyuzu-6d41088153b4b932b4f2524d4252993a5642f998.tar
yuzu-6d41088153b4b932b4f2524d4252993a5642f998.tar.gz
yuzu-6d41088153b4b932b4f2524d4252993a5642f998.tar.bz2
yuzu-6d41088153b4b932b4f2524d4252993a5642f998.tar.lz
yuzu-6d41088153b4b932b4f2524d4252993a5642f998.tar.xz
yuzu-6d41088153b4b932b4f2524d4252993a5642f998.tar.zst
yuzu-6d41088153b4b932b4f2524d4252993a5642f998.zip
Diffstat (limited to '')
-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
4 files changed, 12 insertions, 15 deletions
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() {
return {};
}
- char ip_addr[16] = {};
- ASSERT(inet_ntop(AF_INET, &interface->ip_address, ip_addr, sizeof(ip_addr)) != nullptr);
+ std::array<char, 16> ip_addr = {};
+ ASSERT(inet_ntop(AF_INET, &interface->ip_address, ip_addr.data(), sizeof(ip_addr)) != nullptr);
return TranslateIPv4(interface->ip_address);
}
@@ -402,9 +402,9 @@ Socket::Socket(Socket&& rhs) noexcept {
}
template <typename T>
-Errno Socket::SetSockOpt(SOCKET _fd, int option, T value) {
+Errno Socket::SetSockOpt(SOCKET fd_, int option, T value) {
const int result =
- setsockopt(_fd, SOL_SOCKET, option, reinterpret_cast<const char*>(&value), sizeof(value));
+ setsockopt(fd_, SOL_SOCKET, option, reinterpret_cast<const char*>(&value), sizeof(value));
if (result != SOCKET_ERROR) {
return Errno::SUCCESS;
}
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) {
closed) {
return;
}
- std::lock_guard<std::mutex> guard(packets_mutex);
+ std::lock_guard guard(packets_mutex);
received_packets.push(packet);
}
template <typename T>
-Errno ProxySocket::SetSockOpt(SOCKET _fd, int option, T value) {
+Errno ProxySocket::SetSockOpt(SOCKET fd_, int option, T value) {
socket_options[option] = reinterpret_cast<const char*>(&value);
return Errno::SUCCESS;
}
Errno ProxySocket::Initialize(Domain domain, Type type, Protocol socket_protocol) {
protocol = socket_protocol;
- socket_options[0x1008] = reinterpret_cast<const char*>(&type);
+ SetSockOpt(fd, SO_TYPE, type);
return Errno::SUCCESS;
}
@@ -101,7 +101,7 @@ std::pair<s32, Errno> ProxySocket::RecvFrom(int flags, std::vector<u8>& message,
ASSERT(message.size() < static_cast<size_t>(std::numeric_limits<int>::max()));
{
- std::lock_guard<std::mutex> guard(packets_mutex);
+ std::lock_guard guard(packets_mutex);
if (received_packets.size() > 0) {
return ReceivePacket(flags, message, addr, message.size());
}
@@ -115,7 +115,7 @@ std::pair<s32, Errno> ProxySocket::RecvFrom(int flags, std::vector<u8>& message,
return {-1, Errno::AGAIN};
}
- std::lock_guard<std::mutex> guard(packets_mutex);
+ std::lock_guard guard(packets_mutex);
if (received_packets.size() > 0) {
return ReceivePacket(flags, message, addr, message.size());
}
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 {
class ProxySocket : public SocketBase {
public:
- ProxySocket(RoomNetwork& room_network_) noexcept;
+ explicit ProxySocket(RoomNetwork& room_network_) noexcept;
~ProxySocket() override;
ProxySocket(const ProxySocket&) = delete;
@@ -82,6 +82,7 @@ public:
bool IsOpened() const override;
+private:
bool broadcast = false;
bool closed = false;
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:
std::unique_ptr<SocketBase> socket;
SockAddrIn sockaddr_in;
};
- virtual ~SocketBase() {}
+ virtual ~SocketBase() = default;
virtual SocketBase& operator=(const SocketBase&) = delete;
@@ -89,11 +89,7 @@ public:
virtual void HandleProxyPacket(const ProxyPacket& packet) = 0;
-#if defined(_WIN32)
SOCKET fd = INVALID_SOCKET;
-#elif YUZU_UNIX
- int fd = -1;
-#endif
};
class Socket : public SocketBase {