King_Tech/FastTunnel
King_Tech/FastTunnel
2
0
Fork 0
mirror of https://github.com/FastTunnel/FastTunnel.git synced 2024-09-20 23:48:30 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

初步实现

Browse Source
This commit is contained in:
Gui.H 2021-06-17 08:48:27 +08:00
parent a7b6be89ee
commit d898f1d5ea
4 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
FastTunnel.Core/FastTunnel.Core.csproj
View File

@ -22,7 +22,7 @@
</PropertyGroup> </PropertyGroup>
<ItemGroup> <ItemGroup>
<Compile Remove="AsyncSocketSwapV2.cs" /> <Compile Remove="AsyncSocketSwap.cs" />
<Compile Remove="Client\SuiDaoServer.cs.BASE.cs" /> <Compile Remove="Client\SuiDaoServer.cs.BASE.cs" />
<Compile Remove="Client\SuiDaoServer.cs.LOCAL.cs" /> <Compile Remove="Client\SuiDaoServer.cs.LOCAL.cs" />
<Compile Remove="Client\SuiDaoServer.cs.REMOTE.cs" /> <Compile Remove="Client\SuiDaoServer.cs.REMOTE.cs" />

2
FastTunnel.Core/Handlers/Client/HttpRequestHandler.cs
View File

@ -59,7 +59,7 @@ namespace FastTunnel.Core.Handlers.Client
throw; throw;
} }
new AsyncSocketSwap(connecter.Socket, localConnecter.Socket).StartSwapAsync(); new AsyncSocketSwapV2(connecter.Socket, localConnecter.Socket).StartSwapAsync();
} }
} }
} }

2
FastTunnel.Core/Handlers/Client/NewSSHHandler.cs
View File

@ -20,7 +20,7 @@ namespace FastTunnel.Core.Handlers.Client
var localConnecter_ssh = new Connecter(request_ssh.SSHConfig.LocalIp, request_ssh.SSHConfig.LocalPort, 5000); var localConnecter_ssh = new Connecter(request_ssh.SSHConfig.LocalIp, request_ssh.SSHConfig.LocalPort, 5000);
localConnecter_ssh.Connect(); localConnecter_ssh.Connect();
new AsyncSocketSwap(connecter_ssh.Socket, localConnecter_ssh.Socket).StartSwapAsync(); new AsyncSocketSwapV2(connecter_ssh.Socket, localConnecter_ssh.Socket).StartSwapAsync();
} }
} }
} }

2
FastTunnel.Core/Handlers/Server/SwapMessageHandler.cs
View File

@ -32,7 +32,7 @@ namespace FastTunnel.Core.Handlers.Server
server.RequestTemp.TryRemove(SwapMsg.msgId, out _); server.RequestTemp.TryRemove(SwapMsg.msgId, out _);
// Join // Join
new AsyncSocketSwap(request.CustomerClient, client) new AsyncSocketSwapV2(request.CustomerClient, client)
.BeforeSwap(() => .BeforeSwap(() =>
{ {
if (request.Buffer != null) client.Send(request.Buffer); if (request.Buffer != null) client.Send(request.Buffer);