wasSharpNET
/Network/HTTP/HTTPServer.cs |
@@ -14,10 +14,12 @@ |
public abstract class HTTPServer |
{ |
private int activeRequests; |
|
private readonly HttpListener HTTPListener = new HttpListener() |
{ |
AuthenticationSchemes = AuthenticationSchemes.None |
}; |
|
private int processedRequests; |
|
private readonly AutoResetEvent StopServerEvent = new AutoResetEvent(false); |
@@ -66,12 +68,12 @@ |
|
private void Listen(object state) |
{ |
var callbackState = (HTTPServerCallbackState) state; |
var callbackState = (HTTPServerCallbackState)state; |
|
while (callbackState.Listener.IsListening) |
{ |
callbackState.Listener.BeginGetContext(ContextCallback, callbackState); |
var n = WaitHandle.WaitAny(new WaitHandle[] {callbackState.ContextRetrieved, StopServerEvent}); |
var n = WaitHandle.WaitAny(new WaitHandle[] { callbackState.ContextRetrieved, StopServerEvent }); |
|
if (n.Equals(1)) |
{ |
@@ -87,7 +89,7 @@ |
|
private void ContextCallback(IAsyncResult ar) |
{ |
var callbackState = (HTTPServerCallbackState) ar.AsyncState; |
var callbackState = (HTTPServerCallbackState)ar.AsyncState; |
HttpListenerContext httpContext = null; |
|
Interlocked.Increment(ref processedRequests); |
@@ -135,4 +137,4 @@ |
public AutoResetEvent ContextRetrieved { get; } |
} |
} |
} |
} |
/Network/IPAddressExtensions.cs |
@@ -26,7 +26,7 @@ |
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); |
} |
@@ -42,7 +42,7 @@ |
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); |
} |
@@ -55,4 +55,4 @@ |
return network1.Equals(network2); |
} |
} |
} |
} |
/Network/SubnetMask.cs |
@@ -31,13 +31,13 @@ |
|
for (var i = 0; i < 4; i++) |
{ |
if (i*8 + 8 <= netPartLength) |
if (i * 8 + 8 <= netPartLength) |
binaryMask[i] = 255; |
else if (i*8 > netPartLength) |
else if (i * 8 > netPartLength) |
binaryMask[i] = 0; |
else |
{ |
var oneLength = netPartLength - i*8; |
var oneLength = netPartLength - i * 8; |
var binaryDigit = |
string.Empty.PadLeft(oneLength, '1').PadRight(8, '0'); |
binaryMask[i] = Convert.ToByte(binaryDigit, 2); |
@@ -61,4 +61,4 @@ |
return CreateByHostBitLength(b.Length); |
} |
} |
} |
} |
/Network/TCP/Utilities.cs |
@@ -26,7 +26,7 @@ |
{ |
var l = new TcpListener(address, 0); |
l.Start(); |
port = ((IPEndPoint) l.LocalEndpoint).Port; |
port = ((IPEndPoint)l.LocalEndpoint).Port; |
l.Stop(); |
return true; |
} |
@@ -37,4 +37,4 @@ |
} |
} |
} |
} |
} |