raphiaura/KytyPS5
1
0
Fork 0
mirror of https://github.com/KytyPS5/KytyPS5.git synced 2026-10-28 05:46:56 +01:00
Code Issues Packages Projects Releases Wiki Activity

net: share native connect and accept

Browse Source
This commit is contained in:
nmzik
2026-09-06 04:47:15 +04:00
parent cdec5c515b
commit ddcdb654ad
1 changed files with 7 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/libs/network.cpp
+7 -14
View File
@@ -1712,23 +1712,17 @@ int KYTY_SYSV_ABI Connect(int s, const void* addr, uint32_t addrlen) {
return -1; return -1;
} }
#if defined(_WIN32)
sockaddr_storage host_addr {}; sockaddr_storage host_addr {};
int host_addrlen = 0; SocketLength host_addrlen = 0;
if (ConvertGuestSockaddr(addr, addrlen, &host_addr, &host_addrlen) != 0) { if (ConvertGuestSockaddr(addr, addrlen, &host_addr, &host_addrlen) != 0) {
return -1; return -1;
} }
if (::connect(socket, reinterpret_cast<const sockaddr*>(&host_addr), host_addrlen) == if (::connect(socket, reinterpret_cast<const sockaddr*>(&host_addr), host_addrlen) != 0) {
SOCKET_ERROR) {
return SetHostSocketError(); return SetHostSocketError();
} }
return 0; return 0;
#else
*Posix::GetErrorAddr() = Posix::POSIX_ENOSYS;
return -1;
#endif
} }
int KYTY_SYSV_ABI Listen(int s, int backlog) { int KYTY_SYSV_ABI Listen(int s, int backlog) {
@@ -1765,9 +1759,8 @@ int KYTY_SYSV_ABI Accept(int s, void* addr, uint32_t* addrlen) {
return -1; return -1;
} }
#if defined(_WIN32)
sockaddr_storage host_addr {}; sockaddr_storage host_addr {};
int host_addrlen = sizeof(host_addr); SocketLength host_addrlen = sizeof(host_addr);
NativeSocket accepted = NativeSocket accepted =
::accept(socket, reinterpret_cast<sockaddr*>(&host_addr), &host_addrlen); ::accept(socket, reinterpret_cast<sockaddr*>(&host_addr), &host_addrlen);
if (accepted == INVALID_NATIVE_SOCKET) { if (accepted == INVALID_NATIVE_SOCKET) {
@@ -1776,7 +1769,11 @@ int KYTY_SYSV_ABI Accept(int s, void* addr, uint32_t* addrlen) {
const int fd = AllocSocketFd(accepted); const int fd = AllocSocketFd(accepted);
if (fd < 0) { if (fd < 0) {
#if defined(_WIN32)
closesocket(accepted); closesocket(accepted);
#else
::close(accepted);
#endif
*Posix::GetErrorAddr() = Posix::POSIX_EMFILE; *Posix::GetErrorAddr() = Posix::POSIX_EMFILE;
return -1; return -1;
} }
@@ -1794,10 +1791,6 @@ int KYTY_SYSV_ABI Accept(int s, void* addr, uint32_t* addrlen) {
} }
return fd; return fd;
#else
*Posix::GetErrorAddr() = Posix::POSIX_ENOSYS;
return -1;
#endif
} }
int KYTY_SYSV_ABI Shutdown(int s, int how) { int KYTY_SYSV_ABI Shutdown(int s, int how) {