GitHub/netch
1
0
Fork 0
mirror of https://github.com/netchx/netch.git synced 2026-03-14 17:43:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

[Redirector] Fix udp always retry connect

Browse Source
This commit is contained in:
Connection Refused
2021-10-19 15:42:51 +08:00
parent e31be8fd4b
commit 8a2898666a
1 changed files with 5 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
Redirector/EventHandler.cpp
View File

@@ -352,19 +352,11 @@ void udpSend(ENDPOINT_ID id, const unsigned char* target, const char* buffer, in
auto remote = udpContext[id];
udpContextLock.unlock();
UP += length;
if (remote->tcpSocket == INVALID_SOCKET && !remote->Associate())
return;
if (remote->tcpSocket == INVALID_SOCKET || remote->udpSocket == INVALID_SOCKET)
if (remote->udpSocket == INVALID_SOCKET)
{
if (remote->tcpSocket) closesocket(remote->tcpSocket);
if (remote->udpSocket) closesocket(remote->udpSocket);
remote->tcpSocket = INVALID_SOCKET;
remote->udpSocket = INVALID_SOCKET;
if (!remote->Associate())
return;
if (!remote->CreateUDP())
return;
@@ -374,14 +366,8 @@ void udpSend(ENDPOINT_ID id, const unsigned char* target, const char* buffer, in
thread(udpReceiveHandler, id, remote, option).detach();
}
if (remote->Send((PSOCKADDR_IN6)target, buffer, length) != length)
{
if (remote->tcpSocket) closesocket(remote->tcpSocket);
if (remote->udpSocket) closesocket(remote->udpSocket);
remote->tcpSocket = INVALID_SOCKET;
remote->udpSocket = INVALID_SOCKET;
}
if (remote->Send((PSOCKADDR_IN6)target, buffer, length) == length)
UP += length;
}
void udpCanReceive(ENDPOINT_ID id)