King_Tech/FastTunnel
King_Tech/FastTunnel
1
0
Fork 0
mirror of https://github.com/FastTunnel/FastTunnel.git synced 2025-02-08 02:39:29 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

调整部分日志的级别

Browse Source
This commit is contained in:
Gui.H 2022-07-03 10:24:18 +08:00
parent c3a8378f75
commit f6d4d767ce
3 changed files with 14 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

21
FastTunnel.Core/Forwarder/Kestrel/MiddleWare/ForwarderMiddleware.cs
View File

@ -70,7 +70,7 @@ internal class ForwarderMiddleware
} }
/// <summary> /// <summary>
/// 用户发起的请求 /// 用户向服务端发起的请求
/// </summary> /// </summary>
/// <param name="context"></param> /// <param name="context"></param>
/// <returns></returns> /// <returns></returns>
@ -79,7 +79,7 @@ internal class ForwarderMiddleware
var feat = context.Features.Get<IFastTunnelFeature>(); var feat = context.Features.Get<IFastTunnelFeature>();
var requestId = Guid.NewGuid().ToString().Replace("-", ""); var requestId = Guid.NewGuid().ToString().Replace("-", "");
logger.LogInformation($"=========USER START {requestId}==========="); logger.LogDebug($"=========USER START {requestId}===========");
var web = feat.MatchWeb; var web = feat.MatchWeb;
TaskCompletionSource<(Stream, CancellationTokenSource)> tcs = new(); TaskCompletionSource<(Stream, CancellationTokenSource)> tcs = new();
@ -90,7 +90,8 @@ internal class ForwarderMiddleware
return; return;
} }
//IDuplexPipe res = null; await Task.Yield();
(Stream Stream, CancellationTokenSource TokenSource) res = (null, null); (Stream Stream, CancellationTokenSource TokenSource) res = (null, null);
try try
@ -121,13 +122,12 @@ internal class ForwarderMiddleware
await Task.WhenAny(t1, t2).WaitAsync(tokenSource.Token); await Task.WhenAny(t1, t2).WaitAsync(tokenSource.Token);
} }
catch (Exception ex) catch (Exception)
{ {
logger.LogError(ex, "[waitResponse]");
} }
finally finally
{ {
logger.LogInformation($"=========USER END {requestId}==========="); logger.LogDebug($"=========USER END {requestId}===========");
fastTunnelServer.ResponseTasks.TryRemove(requestId, out _); fastTunnelServer.ResponseTasks.TryRemove(requestId, out _);
await context.Transport.Input.CompleteAsync(); await context.Transport.Input.CompleteAsync();
@ -138,7 +138,7 @@ internal class ForwarderMiddleware
} }
/// <summary> /// <summary>
/// 内网发起的请求 /// 内网向服务端发起的请求
/// </summary> /// </summary>
/// <param name="context"></param> /// <param name="context"></param>
/// <returns></returns> /// <returns></returns>
@ -148,7 +148,7 @@ internal class ForwarderMiddleware
var feat = context.Features.Get<IFastTunnelFeature>(); var feat = context.Features.Get<IFastTunnelFeature>();
var requestId = feat.MessageId; var requestId = feat.MessageId;
logger.LogInformation($"=========CLINET START {requestId}==========="); logger.LogDebug($"=========CLINET START {requestId}===========");
if (!fastTunnelServer.ResponseTasks.TryRemove(requestId, out var responseStream)) if (!fastTunnelServer.ResponseTasks.TryRemove(requestId, out var responseStream))
{ {
@ -171,13 +171,12 @@ internal class ForwarderMiddleware
{ {
await closedAwaiter.Task; await closedAwaiter.Task;
} }
catch (Exception ex) catch (Exception)
{ {
logger.LogError(ex, "[setResponse]");
} }
finally finally
{ {
logger.LogInformation($"=========CLINET END {requestId}==========="); logger.LogDebug($"=========CLINET END {requestId}===========");
await context.Transport.Input.CompleteAsync(); await context.Transport.Input.CompleteAsync();
await context.Transport.Output.CompleteAsync(); await context.Transport.Output.CompleteAsync();
} }

4
FastTunnel.Core/Forwarder/Kestrel/MiddleWare/InitializerMiddleware.cs
View File

@ -30,9 +30,9 @@ internal class InitializerMiddleware
internal async Task OnConnectionAsync(ConnectionContext context) internal async Task OnConnectionAsync(ConnectionContext context)
{ {
logger.LogInformation("=========TryAnalysisPipeAsync SART==========="); logger.LogDebug("=========TryAnalysisPipeAsync SART===========");
await new FastTunelProtocol(context, fastTunnelServer).TryAnalysisPipeAsync(); await new FastTunelProtocol(context, fastTunnelServer).TryAnalysisPipeAsync();
logger.LogInformation("=========TryAnalysisPipeAsync END==========="); logger.LogDebug("=========TryAnalysisPipeAsync END===========");
await next(context); await next(context);
} }

4
FastTunnel.Core/Handlers/Client/SwapHandler.cs
View File

@ -31,7 +31,7 @@ public class SwapHandler : IClientHandler
var msgs = msg.Split('|'); var msgs = msg.Split('|');
var requestId = msgs[0]; var requestId = msgs[0];
var address = msgs[1]; var address = msgs[1];
_logger.LogInformation($"========Swap Start:{requestId}=========="); _logger.LogDebug($"========Swap Start:{requestId}==========");
try try
{ {
@ -52,7 +52,7 @@ public class SwapHandler : IClientHandler
} }
finally finally
{ {
_logger.LogInformation($"========Swap End:{requestId}=========="); _logger.LogDebug($"========Swap End:{requestId}==========");
} }
} }