This commit is contained in:
snltty
2025-06-25 16:03:58 +08:00
parent 60ba7ba0b7
commit 9d4d8def13
3 changed files with 13 additions and 5 deletions

View File

@@ -1,4 +1,5 @@
using linker.libs.extends; using linker.libs;
using linker.libs.extends;
using System.Net; using System.Net;
using System.Net.Sockets; using System.Net.Sockets;
@@ -39,18 +40,24 @@ namespace linker.messenger.listen
try try
{ {
SocketReceiveFromResult result = await socketUdp.ReceiveFromAsync(buffer, SocketFlags.None, endPoint).ConfigureAwait(false); SocketReceiveFromResult result = await socketUdp.ReceiveFromAsync(buffer, SocketFlags.None, endPoint).ConfigureAwait(false);
if (result.ReceivedBytes == 0) break; if (result.ReceivedBytes == 0)
{
LoggerHelper.Instance.Error($"udp server recv 0");
continue;
}
IPEndPoint ep = result.RemoteEndPoint as IPEndPoint; IPEndPoint ep = result.RemoteEndPoint as IPEndPoint;
try try
{ {
await resolverTransfer.BeginReceive(socketUdp, ep, buffer.AsMemory(0, result.ReceivedBytes)).ConfigureAwait(false); await resolverTransfer.BeginReceive(socketUdp, ep, buffer.AsMemory(0, result.ReceivedBytes)).ConfigureAwait(false);
} }
catch (Exception) catch (Exception ex)
{ {
LoggerHelper.Instance.Error($"udp server recv {ex}");
} }
} }
catch (Exception) catch (Exception ex)
{ {
LoggerHelper.Instance.Error($"udp server recv {ex}");
break; break;
} }
} }

View File

@@ -346,6 +346,7 @@ namespace linker.tunnel.connection
ReadResult result = await pipe.Reader.ReadAsync(); ReadResult result = await pipe.Reader.ReadAsync();
if (result.IsCompleted && result.Buffer.IsEmpty) if (result.IsCompleted && result.Buffer.IsEmpty)
{ {
cancellationTokenSource.Cancel();
break; break;
} }

View File

@@ -1,5 +1,5 @@
v1.8.5 v1.8.5
2025-06-25 15:13:09 2025-06-25 16:03:58
1. 一些累计更新 1. 一些累计更新
2. 备用信标服务器 2. 备用信标服务器
3. 设置默认中继节点 3. 设置默认中继节点