/Network/HTTP/HTTPServer.cs |
@@ -13,9 +13,6 @@ |
{ |
public abstract class HTTPServer : IDisposable |
{ |
private readonly ManualResetEventSlim listenStop = new ManualResetEventSlim(false); |
|
private readonly ManualResetEventSlim stopListen = new ManualResetEventSlim(false); |
private int activeRequests; |
|
private HttpListener HTTPListener; |
@@ -27,10 +24,8 @@ |
|
public bool IsRunning => HTTPListener != null && HTTPListener.IsListening; |
|
public void Dispose() |
{ |
stopListen.Set(); |
} |
private readonly ManualResetEventSlim stopListen = new ManualResetEventSlim(false); |
private readonly ManualResetEventSlim listenStop = new ManualResetEventSlim(false); |
|
public bool Start(List<string> prefixes) |
{ |
@@ -42,7 +37,9 @@ |
// Add all prefixes. |
HTTPListener.Prefixes.Clear(); |
foreach (var prefix in prefixes) |
{ |
HTTPListener.Prefixes.Add(prefix); |
} |
|
// Do not bomb if the client disconnects. |
HTTPListener.IgnoreWriteExceptions = true; |
@@ -58,13 +55,13 @@ |
|
private void Listen(object state) |
{ |
var callbackState = (HTTPServerCallbackState) state; |
HTTPServerCallbackState 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; |
|
try |
@@ -84,7 +81,7 @@ |
|
private void ContextCallback(IAsyncResult ar) |
{ |
var callbackState = (HTTPServerCallbackState) ar.AsyncState; |
var callbackState = (HTTPServerCallbackState)ar.AsyncState; |
HttpListenerContext httpContext; |
|
Interlocked.Increment(ref processedRequests); |
@@ -114,6 +111,11 @@ |
} |
} |
|
public void Dispose() |
{ |
stopListen.Set(); |
} |
|
private class HTTPServerCallbackState |
{ |
public HTTPServerCallbackState(HttpListener listener) |
@@ -129,4 +131,4 @@ |
public AutoResetEvent ContextRetrieved { get; } |
} |
} |
} |
} |
/Network/IPAddressExtensions.cs |
@@ -25,7 +25,9 @@ |
|
var broadcastAddress = new byte[ipAdressBytes.Length]; |
for (var i = 0; i < broadcastAddress.Length; i++) |
broadcastAddress[i] = (byte) (ipAdressBytes[i] | (subnetMaskBytes[i] ^ 255)); |
{ |
broadcastAddress[i] = (byte)(ipAdressBytes[i] | (subnetMaskBytes[i] ^ 255)); |
} |
return new IPAddress(broadcastAddress); |
} |
|
@@ -39,7 +41,9 @@ |
|
var broadcastAddress = new byte[ipAdressBytes.Length]; |
for (var i = 0; i < broadcastAddress.Length; i++) |
broadcastAddress[i] = (byte) (ipAdressBytes[i] & subnetMaskBytes[i]); |
{ |
broadcastAddress[i] = (byte)(ipAdressBytes[i] & subnetMaskBytes[i]); |
} |
return new IPAddress(broadcastAddress); |
} |
|
@@ -51,4 +55,4 @@ |
return network1.Equals(network2); |
} |
} |
} |
} |
/Network/SubnetMask.cs |
@@ -30,14 +30,11 @@ |
var binaryMask = new byte[4]; |
|
for (var i = 0; i < 4; i++) |
{ |
if (i * 8 + 8 <= netPartLength) |
{ |
binaryMask[i] = 255; |
} |
else if (i * 8 > netPartLength) |
{ |
binaryMask[i] = 0; |
} |
else |
{ |
var oneLength = netPartLength - i * 8; |
@@ -45,6 +42,7 @@ |
string.Empty.PadLeft(oneLength, '1').PadRight(8, '0'); |
binaryMask[i] = Convert.ToByte(binaryDigit, 2); |
} |
} |
return new IPAddress(binaryMask); |
} |
|
@@ -63,4 +61,4 @@ |
return CreateByHostBitLength(b.Length); |
} |
} |
} |
} |