2022-07-30 20:16:47 +02:00
|
|
|
// SPDX-FileCopyrightText: Copyright 2022 yuzu Emulator Project
|
|
|
|
// SPDX-License-Identifier: GPL-2.0-or-later
|
2022-07-30 05:58:23 +02:00
|
|
|
|
|
|
|
#pragma once
|
|
|
|
|
|
|
|
#include <mutex>
|
|
|
|
#include <vector>
|
|
|
|
#include <queue>
|
|
|
|
|
|
|
|
#include "core/internal_network/sockets.h"
|
|
|
|
#include "network/network.h"
|
|
|
|
|
|
|
|
namespace Network {
|
|
|
|
|
|
|
|
class ProxySocket : public SocketBase {
|
|
|
|
public:
|
|
|
|
ProxySocket(RoomNetwork& room_network_) noexcept;
|
|
|
|
~ProxySocket() override;
|
|
|
|
|
|
|
|
ProxySocket(const ProxySocket&) = delete;
|
|
|
|
ProxySocket& operator=(const ProxySocket&) = delete;
|
|
|
|
|
|
|
|
ProxySocket(ProxySocket&& rhs) noexcept;
|
|
|
|
|
|
|
|
// Avoid closing sockets implicitly
|
|
|
|
ProxySocket& operator=(ProxySocket&&) noexcept = delete;
|
|
|
|
|
|
|
|
void HandleProxyPacket(const ProxyPacket& packet);
|
|
|
|
|
|
|
|
Errno Initialize(Domain domain, Type type, Protocol socket_protocol) override;
|
|
|
|
|
|
|
|
Errno Close() override;
|
|
|
|
|
|
|
|
std::pair<AcceptResult, Errno> Accept() override;
|
|
|
|
|
|
|
|
Errno Connect(SockAddrIn addr_in) override;
|
|
|
|
|
|
|
|
std::pair<SockAddrIn, Errno> GetPeerName() override;
|
|
|
|
|
|
|
|
std::pair<SockAddrIn, Errno> GetSockName() override;
|
|
|
|
|
|
|
|
Errno Bind(SockAddrIn addr) override;
|
|
|
|
|
|
|
|
Errno Listen(s32 backlog) override;
|
|
|
|
|
|
|
|
Errno Shutdown(ShutdownHow how) override;
|
|
|
|
|
|
|
|
std::pair<s32, Errno> Recv(int flags, std::vector<u8>& message) override;
|
|
|
|
|
|
|
|
std::pair<s32, Errno> RecvFrom(int flags, std::vector<u8>& message, SockAddrIn* addr) override;
|
|
|
|
|
|
|
|
std::pair<s32, Errno> ReceivePacket(int flags, std::vector<u8>& message, SockAddrIn* addr,
|
|
|
|
std::size_t max_length);
|
|
|
|
|
|
|
|
std::pair<s32, Errno> Send(const std::vector<u8>& message, int flags) override;
|
|
|
|
|
|
|
|
void SendPacket(ProxyPacket& packet);
|
|
|
|
|
|
|
|
std::pair<s32, Errno> SendTo(u32 flags, const std::vector<u8>& message,
|
|
|
|
const SockAddrIn* addr) override;
|
|
|
|
|
|
|
|
Errno SetLinger(bool enable, u32 linger) override;
|
|
|
|
|
|
|
|
Errno SetReuseAddr(bool enable) override;
|
|
|
|
|
|
|
|
Errno SetBroadcast(bool enable) override;
|
|
|
|
|
|
|
|
Errno SetKeepAlive(bool enable) override;
|
|
|
|
|
|
|
|
Errno SetSndBuf(u32 value) override;
|
|
|
|
|
|
|
|
Errno SetRcvBuf(u32 value) override;
|
|
|
|
|
|
|
|
Errno SetSndTimeo(u32 value) override;
|
|
|
|
|
|
|
|
Errno SetRcvTimeo(u32 value) override;
|
|
|
|
|
|
|
|
Errno SetNonBlock(bool enable) override;
|
|
|
|
|
|
|
|
template <typename T>
|
|
|
|
Errno SetSockOpt(SOCKET fd, int option, T value);
|
|
|
|
|
|
|
|
bool IsOpened() const override;
|
|
|
|
|
|
|
|
bool broadcast = false;
|
|
|
|
bool closed = false;
|
|
|
|
u32 send_timeout = 0;
|
|
|
|
u32 receive_timeout = 0;
|
|
|
|
std::map<int, const char*> socket_options;
|
|
|
|
bool is_bound = false;
|
|
|
|
SockAddrIn local_endpoint{};
|
|
|
|
bool blocking = true;
|
|
|
|
std::queue<ProxyPacket> received_packets;
|
|
|
|
Protocol protocol;
|
|
|
|
|
|
|
|
std::mutex packets_mutex;
|
|
|
|
|
|
|
|
RoomNetwork& room_network;
|
|
|
|
};
|
|
|
|
|
|
|
|
} // namespace Network
|