wasSharpNET – Diff between revs 22 and 27

Subversion Repositories:

?pathlinks?

Rev 22 – Go to most recent revision – Details – Blame – Last modification – View Log

 namespace wasSharpNET.Network.HTTP
+{
     public abstract class HTTPServer : IDisposable
+    {
+        private readonly ManualResetEventSlim listenStop = new ManualResetEventSlim(false);
         private readonly ManualResetEventSlim stopListen = new ManualResetEventSlim(false);
         private int activeRequests;
         public AuthenticationSchemes AuthenticationSchemes { get; set; } =
             AuthenticationSchemes.None;
         public bool IsRunning => HTTPListener != null && HTTPListener.IsListening;
+        public void Dispose()
+        {
-        private readonly ManualResetEventSlim stopListen = new ManualResetEventSlim(false);
+            stopListen.Set();
         private readonly ManualResetEventSlim listenStop = new ManualResetEventSlim(false);
         public bool Start(List<string> prefixes)
             };
             // Add all prefixes.
             HTTPListener.Prefixes.Clear();
-            foreach (var prefix in prefixes)
             foreach (var prefix in prefixes)
-                HTTPListener.Prefixes.Add(prefix);
                 HTTPListener.Prefixes.Add(prefix);
             // Do not bomb if the client disconnects.
             HTTPListener.IgnoreWriteExceptions = true;
             return listenStop.Wait(timeout);
+        }
         private void Listen(object state)
         {
-            HTTPServerCallbackState callbackState = (HTTPServerCallbackState)state;
+            var callbackState = (HTTPServerCallbackState) state;
             while (callbackState.Listener.IsListening)
             {
                 callbackState.Listener?.BeginGetContext(ContextCallback, callbackState);
-                if (WaitHandle.WaitAny(new[] { callbackState.ContextRetrieved, stopListen.WaitHandle }) != 1)
+                if (WaitHandle.WaitAny(new[] {callbackState.ContextRetrieved, stopListen.WaitHandle}) != 1)
                     continue;
         public abstract void ProcessHTTPContext(HttpListenerContext context);
         private void ContextCallback(IAsyncResult ar)
+        {
-            var callbackState = (HTTPServerCallbackState)ar.AsyncState;
+            var callbackState = (HTTPServerCallbackState) ar.AsyncState;
             HttpListenerContext httpContext;
+            {
                 Interlocked.Decrement(ref activeRequests);
+            }
+        }
-        public void Dispose()
-        {
-            stopListen.Set();
-        }
         private class HTTPServerCallbackState
+        {
             public HTTPServerCallbackState(HttpListener listener)
+            {
             public HttpListener Listener { get; }
             public AutoResetEvent ContextRetrieved { get; }
+        }
     }
+}