Fixed singlethread HTTPServer.Connection() blocking listeners from accepting more connections
parent
7e1291815c
commit
40e4eddbbd
|
@ -4,6 +4,7 @@ using ln.logging;
|
||||||
using ln.http.exceptions;
|
using ln.http.exceptions;
|
||||||
using System.IO;
|
using System.IO;
|
||||||
using System.Text;
|
using System.Text;
|
||||||
|
using System.Threading;
|
||||||
using ln.protocols.helper;
|
using ln.protocols.helper;
|
||||||
|
|
||||||
namespace ln.http
|
namespace ln.http
|
||||||
|
@ -35,8 +36,10 @@ namespace ln.http
|
||||||
|
|
||||||
public void RemoveRouter(HttpRouter httpRouter) => RemoveRouter(httpRouter.Route);
|
public void RemoveRouter(HttpRouter httpRouter) => RemoveRouter(httpRouter.Route);
|
||||||
public void RemoveRouter(HttpRouterDelegate routerDelegate) => _routerDelegates.Remove(routerDelegate);
|
public void RemoveRouter(HttpRouterDelegate routerDelegate) => _routerDelegates.Remove(routerDelegate);
|
||||||
|
|
||||||
public void Connection(HttpConnection httpConnection)
|
public void Connection(HttpConnection httpConnection) =>
|
||||||
|
ThreadPool.QueueUserWorkItem((state => ConnectionWorker(httpConnection)));
|
||||||
|
public void ConnectionWorker(HttpConnection httpConnection)
|
||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
|
|
|
@ -10,7 +10,7 @@
|
||||||
<Copyright>(c) 2020 Harald Wolff-Thobaben</Copyright>
|
<Copyright>(c) 2020 Harald Wolff-Thobaben</Copyright>
|
||||||
<PackageTags>http server</PackageTags>
|
<PackageTags>http server</PackageTags>
|
||||||
<LangVersion>9</LangVersion>
|
<LangVersion>9</LangVersion>
|
||||||
<PackageVersion>0.5.3</PackageVersion>
|
<PackageVersion>0.6.1</PackageVersion>
|
||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
|
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
|
|
Loading…
Reference in New Issue