Commit 8211b546 authored by justcoding121's avatar justcoding121

connection perf

parent a8e16d49
...@@ -186,6 +186,7 @@ namespace Titanium.Web.Proxy ...@@ -186,6 +186,7 @@ namespace Titanium.Web.Proxy
private static async Task HandleHttpSessionRequest(TcpClient client, string httpCmd, Stream clientStream, private static async Task HandleHttpSessionRequest(TcpClient client, string httpCmd, Stream clientStream,
CustomBinaryReader clientStreamReader, StreamWriter clientStreamWriter, bool isHttps) CustomBinaryReader clientStreamReader, StreamWriter clientStreamWriter, bool isHttps)
{ {
TcpConnection connection = null;
while (true) while (true)
{ {
...@@ -268,7 +269,7 @@ namespace Titanium.Web.Proxy ...@@ -268,7 +269,7 @@ namespace Titanium.Web.Proxy
} }
//construct the web request that we are going to issue on behalf of the client. //construct the web request that we are going to issue on behalf of the client.
var connection = await TcpConnectionManager.GetClient(args.WebSession.Request.RequestUri.Host, args.WebSession.Request.RequestUri.Port, args.IsHttps, version).ConfigureAwait(false); connection = await TcpConnectionManager.GetClient(args.WebSession.Request.RequestUri.Host, args.WebSession.Request.RequestUri.Port, args.IsHttps, version).ConfigureAwait(false);
args.WebSession.Request.RequestLocked = true; args.WebSession.Request.RequestLocked = true;
...@@ -342,8 +343,6 @@ namespace Titanium.Web.Proxy ...@@ -342,8 +343,6 @@ namespace Titanium.Web.Proxy
return; return;
} }
await TcpConnectionManager.ReleaseClient(connection);
// read the next request // read the next request
httpCmd = await clientStreamReader.ReadLineAsync().ConfigureAwait(false); httpCmd = await clientStreamReader.ReadLineAsync().ConfigureAwait(false);
...@@ -356,6 +355,8 @@ namespace Titanium.Web.Proxy ...@@ -356,6 +355,8 @@ namespace Titanium.Web.Proxy
} }
if (connection!=null)
await TcpConnectionManager.ReleaseClient(connection);
} }
private static async Task WriteConnectResponse(StreamWriter clientStreamWriter, Version httpVersion) private static async Task WriteConnectResponse(StreamWriter clientStreamWriter, Version httpVersion)
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment