uhttpsharp/uhttpsharp/HttpServer.cs at master · bonesoul/uhttpsharp · GitHub

History

93 lines (75 loc) · 2.79 KB

Raw

* This library is free software; you can redistribute it and/or

* modify it under the terms of the GNU Lesser General Public

* License as published by the Free Software Foundation; either

* version 2.1 of the License, or (at your option) any later version.

* This library is distributed in the hope that it will be useful,

* but WITHOUT ANY WARRANTY; without even the implied warranty of

* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU

* Lesser General Public License for more details.

* You should have received a copy of the GNU Lesser General Public

* License along with this library; if not, write to the Free Software

* Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA

using log4net;

using System;

using System.Collections.Generic;

using System.Reflection;

using System.Threading.Tasks;

using uhttpsharp.Listeners;

using uhttpsharp.RequestProviders;

namespace uhttpsharp

{

public sealed class HttpServer : IDisposable

{

private static readonly ILog Logger = LogManager.GetLogger(MethodBase.GetCurrentMethod().DeclaringType);

private bool _isActive;

private readonly IList<IHttpRequestHandler> _handlers = new List<IHttpRequestHandler>();

private readonly IList<IHttpListener> _listeners = new List<IHttpListener>();

private readonly IHttpRequestProvider _requestProvider;

public HttpServer(IHttpRequestProvider requestProvider)

{

_requestProvider = requestProvider;

}

public void Use(IHttpRequestHandler handler)

{

_handlers.Add(handler);

}

public void Use(IHttpListener listener)

{

_listeners.Add(listener);

}

public void Start()

{

_isActive = true;

foreach (var listener in _listeners)

{

IHttpListener tempListener = listener;

Task.Factory.StartNew(() => Listen(tempListener));

}

Logger.InfoFormat("Embedded uhttpserver started.");

}

private async void Listen(IHttpListener listener)

{

var aggregatedHandler = _handlers.Aggregate();

while (_isActive)

{

try

{

new HttpClientHandler(await listener.GetClient().ConfigureAwait(false), aggregatedHandler, _requestProvider);

}

catch (Exception e)

{

Logger.Warn("Error while getting client", e);

}

Logger.InfoFormat("Embedded uhttpserver stopped.");

}

public void Dispose()

{

_isActive = false;

}

uhttpsharp/uhttpsharp/HttpServer.cs at master · bonesoul/uhttpsharp · GitHub

Expand file tree

Breadcrumbs

HttpServer.cs

Latest commit

History

Breadcrumbs

HttpServer.cs

File metadata and controls