apps/linker
1
0
Fork 0
mirror of https://github.com/snltty/linker.git synced 2025-10-28 19:31:50 +08:00
Code Issues Packages Projects Releases Wiki Activity

185

Browse Source
This commit is contained in:
snltty
2025-06-25 16:12:07 +08:00
parent 9d4d8def13
commit 1fca19dfbc
5 changed files with 12 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/linker.messenger.forward/proxy/ForwardProxyUdp.cs
View File

@@ -50,6 +50,10 @@ namespace linker.messenger.forward.proxy
try try
{ {
SocketReceiveFromResult result = await token.SourceSocket.ReceiveFromAsync(bytes, tempRemoteEP).ConfigureAwait(false); SocketReceiveFromResult result = await token.SourceSocket.ReceiveFromAsync(bytes, tempRemoteEP).ConfigureAwait(false);
if(result.ReceivedBytes == 0)
{
break;
}
token.Proxy.SourceEP = result.RemoteEndPoint as IPEndPoint; token.Proxy.SourceEP = result.RemoteEndPoint as IPEndPoint;
token.Proxy.Data = bytes.AsMemory(0, result.ReceivedBytes); token.Proxy.Data = bytes.AsMemory(0, result.ReceivedBytes);

2
src/linker.messenger.listen/TcpServer.cs
View File

@@ -43,7 +43,7 @@ namespace linker.messenger.listen
if (result.ReceivedBytes == 0) if (result.ReceivedBytes == 0)
{ {
LoggerHelper.Instance.Error($"udp server recv 0"); LoggerHelper.Instance.Error($"udp server recv 0");
continue; break;
} }
IPEndPoint ep = result.RemoteEndPoint as IPEndPoint; IPEndPoint ep = result.RemoteEndPoint as IPEndPoint;
try try

2
src/linker.messenger.socks5/TunnelProxyUdp.cs
View File

@@ -46,6 +46,7 @@ namespace linker.messenger.socks5
try try
{ {
SocketReceiveFromResult result = await token.SourceSocket.ReceiveFromAsync(bytes, tempRemoteEP).ConfigureAwait(false); SocketReceiveFromResult result = await token.SourceSocket.ReceiveFromAsync(bytes, tempRemoteEP).ConfigureAwait(false);
if (result.ReceivedBytes == 0) break;
token.Proxy.SourceEP = result.RemoteEndPoint as IPEndPoint; token.Proxy.SourceEP = result.RemoteEndPoint as IPEndPoint;
token.Proxy.Data = bytes.AsMemory(0, result.ReceivedBytes); token.Proxy.Data = bytes.AsMemory(0, result.ReceivedBytes);
@@ -211,6 +212,7 @@ namespace linker.messenger.socks5
while (true) while (true)
{ {
SocketReceiveFromResult result = await socket.ReceiveFromAsync(udpToken.Buffer, SocketFlags.None, target).ConfigureAwait(false); SocketReceiveFromResult result = await socket.ReceiveFromAsync(udpToken.Buffer, SocketFlags.None, target).ConfigureAwait(false);
if (result.ReceivedBytes == 0) break;
udpToken.Proxy.Data = udpToken.Buffer.AsMemory(0, result.ReceivedBytes); udpToken.Proxy.Data = udpToken.Buffer.AsMemory(0, result.ReceivedBytes);
udpToken.Update(); udpToken.Update();
await SendToConnection(udpToken).ConfigureAwait(false); await SendToConnection(udpToken).ConfigureAwait(false);

5
src/linker.tunnel/transport/TransportMsQuic.cs
View File

@@ -571,7 +571,10 @@ namespace linker.tunnel.transport
while (true) while (true)
{ {
SocketReceiveFromResult result = await local.ReceiveFromAsync(buffer, tempEp).ConfigureAwait(false); SocketReceiveFromResult result = await local.ReceiveFromAsync(buffer, tempEp).ConfigureAwait(false);
if (result.ReceivedBytes == 0) break; if (result.ReceivedBytes == 0)
{
break;
}
if (result.ReceivedBytes == endBytes.Length && buffer.AsMemory(0, result.ReceivedBytes).Span.SequenceEqual(endBytes)) if (result.ReceivedBytes == endBytes.Length && buffer.AsMemory(0, result.ReceivedBytes).Span.SequenceEqual(endBytes))
{ {

2
version.txt
View File

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