// OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
// WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
//
-#if NET_2_0
+
using System;
+using System.Collections.Generic;
+using System.Globalization;
using System.IO;
using System.Net;
using System.Net.Sockets;
using System.Text;
using System.Threading;
+
using NUnit.Framework;
// ***************************************************************************************
// unregister it even after explicitly closing the listener.
// ***************************************************************************************
namespace MonoTests.System.Net {
+
[TestFixture]
+#if TARGET_JVM
+ [Ignore ("The class HttpListener is not supported")]
+#endif
public class HttpListener2Test {
+
+ private HttpListener _listener = null;
+
public class MyNetworkStream : NetworkStream {
public MyNetworkStream (Socket sock) : base (sock, true)
{
return listener;
}
+ public static HttpListener CreateAndStartListener (string prefix, AuthenticationSchemes authSchemes)
+ {
+ HttpListener listener = new HttpListener ();
+ listener.AuthenticationSchemes = authSchemes;
+ listener.Prefixes.Add (prefix);
+ listener.Start ();
+ return listener;
+ }
+
public static MyNetworkStream CreateNS (int port)
+ {
+ return CreateNS (port, 5000);
+ }
+
+ public static MyNetworkStream CreateNS (int port, int timeout_ms)
{
Socket sock = new Socket (AddressFamily.InterNetwork, SocketType.Stream, ProtocolType.Tcp);
sock.Connect (new IPEndPoint (IPAddress.Loopback, port));
+ sock.SendTimeout = timeout_ms;
+ sock.ReceiveTimeout = timeout_ms;
return new MyNetworkStream (sock);
}
{
IAsyncResult ares = listener.BeginGetContext (null, null);
timed_out = !ares.AsyncWaitHandle.WaitOne (timeout, false);
- if (timed_out)
+ if (timed_out)
return null;
return listener.EndGetContext (ares);
}
+
+ [TearDown]
+ public void Dispose()
+ {
+ if (_listener != null) {
+ _listener.Close();
+ _listener = null;
+ }
+ }
[Test]
public void Test1 ()
{
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test1/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test1/");
NetworkStream ns = CreateNS (9000);
Send (ns, "GET / HTTP/1.1\r\n\r\n"); // No host
string response = Receive (ns, 512);
ns.Close ();
- listener.Close ();
Assert.IsTrue (response.StartsWith ("HTTP/1.1 400"));
}
[Test]
public void Test2 ()
{
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test2/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test2/");
NetworkStream ns = CreateNS (9000);
Send (ns, "GET / HTTP/1.1\r\nHost: 127.0.0.1\r\n\r\n"); // no prefix
string response = Receive (ns, 512);
ns.Close ();
- listener.Close ();
Assert.IsTrue (response.StartsWith ("HTTP/1.1 400"));
}
[Test]
public void Test3 ()
{
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test3/");
- NetworkStream ns = CreateNS (9000);
- Send (ns, "MET / HTTP/1.1\r\nHost: 127.0.0.1\r\n\r\n"); // bad method
- string response = Receive (ns, 512);
- ns.Close ();
- listener.Close ();
- Assert.IsTrue (response.StartsWith ("HTTP/1.1 400"));
+ StringBuilder bad = new StringBuilder ();
+ for (int i = 0; i < 33; i++){
+ if (i != 13)
+ bad.Append ((char) i);
+ }
+ bad.Append ('(');
+ bad.Append (')');
+ bad.Append ('[');
+ bad.Append (']');
+ bad.Append ('<');
+ bad.Append ('>');
+ bad.Append ('@');
+ bad.Append (',');
+ bad.Append (';');
+ bad.Append (':');
+ bad.Append ('\\');
+ bad.Append ('"');
+ bad.Append ('/');
+ bad.Append ('?');
+ bad.Append ('=');
+ bad.Append ('{');
+ bad.Append ('}');
+
+ foreach (char b in bad.ToString ()){
+ HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test3/");
+ NetworkStream ns = CreateNS (9000);
+ Send (ns, String.Format ("MA{0} / HTTP/1.1\r\nHost: 127.0.0.1\r\n\r\n", b)); // bad method
+
+ string response = Receive (ns, 512);
+ ns.Close ();
+ listener.Close ();
+ Assert.AreEqual (true, response.StartsWith ("HTTP/1.1 400"), String.Format ("Failed on {0}", (int) b));
+ }
}
[Test]
public void Test4 ()
{
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test4/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test4/");
NetworkStream ns = CreateNS (9000);
Send (ns, "POST /test4/ HTTP/1.1\r\nHost: 127.0.0.1\r\n\r\n"); // length required
string response = Receive (ns, 512);
ns.Close ();
- listener.Close ();
Assert.IsTrue (response.StartsWith ("HTTP/1.1 411"));
}
[Test]
public void Test5 ()
{
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test5/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test5/");
NetworkStream ns = CreateNS (9000);
Send (ns, "POST / HTTP/1.1\r\nHost: 127.0.0.1\r\nTransfer-Encoding: pepe\r\n\r\n"); // not implemented
string response = Receive (ns, 512);
ns.Close ();
- listener.Close ();
Assert.IsTrue (response.StartsWith ("HTTP/1.1 501"));
}
[Test]
public void Test6 ()
{
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test6/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test6/");
NetworkStream ns = CreateNS (9000);
// not implemented! This is against the RFC. Should be a bad request/length required
Send (ns, "POST /test6/ HTTP/1.1\r\nHost: 127.0.0.1\r\nTransfer-Encoding: identity\r\n\r\n");
string response = Receive (ns, 512);
ns.Close ();
- listener.Close ();
Assert.IsTrue (response.StartsWith ("HTTP/1.1 501"));
}
[Test]
public void Test7 ()
{
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test7/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test7/");
NetworkStream ns = CreateNS (9000);
Send (ns, "POST /test7/ HTTP/1.1\r\nHost: 127.0.0.1\r\nContent-Length: 3\r\n\r\n123");
- HttpListenerContext ctx = listener.GetContext ();
+ HttpListenerContext ctx = _listener.GetContext ();
Send (ctx.Response.OutputStream, "%%%OK%%%");
+ ctx.Response.Close ();
string response = Receive (ns, 1024);
ns.Close ();
- listener.Close ();
Assert.IsTrue (response.StartsWith ("HTTP/1.1 200"));
Assert.IsTrue (-1 != response.IndexOf ("Transfer-Encoding: chunked"));
}
[Test]
public void Test8 ()
{
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test8/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test8/");
NetworkStream ns = CreateNS (9000);
// Just like Test7, but 1.0
Send (ns, "POST /test8/ HTTP/1.0\r\nHost: 127.0.0.1\r\nContent-Length: 3\r\n\r\n123");
- HttpListenerContext ctx = listener.GetContext ();
+ HttpListenerContext ctx = _listener.GetContext ();
Send (ctx.Response.OutputStream, "%%%OK%%%");
+ ctx.Response.Close ();
string response = Receive (ns, 512);
ns.Close ();
- listener.Close ();
Assert.IsTrue (response.StartsWith ("HTTP/1.1 200"));
Assert.IsTrue (-1 == response.IndexOf ("Transfer-Encoding: chunked"));
}
public void Test9 ()
{
// 1.0 + "Transfer-Encoding: chunked"
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test9/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test9/");
NetworkStream ns = CreateNS (9000);
Send (ns, "POST /test9/ HTTP/1.0\r\nHost: 127.0.0.1\r\nTransfer-Encoding: chunked\r\n\r\n3\r\n123\r\n0\r\n\r\n");
bool timeout;
string response = ReceiveWithTimeout (ns, 512, 1000, out timeout);
- Assert.IsFalse (timeout);
- listener.Close ();
ns.Close ();
+ Assert.IsFalse (timeout);
Assert.IsTrue (response.StartsWith ("HTTP/1.1 411"));
}
public void Test10 ()
{
// Same as Test9, but now we shutdown the socket for sending.
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test10/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test10/");
MyNetworkStream ns = CreateNS (9000);
Send (ns, "POST /test10/ HTTP/1.0\r\nHost: 127.0.0.1\r\nTransfer-Encoding: chunked\r\n\r\n3\r\n123\r\n0\r\n\r\n");
ns.GetSocket ().Shutdown (SocketShutdown.Send);
bool timeout;
string response = ReceiveWithTimeout (ns, 512, 1000, out timeout);
- Assert.IsFalse (timeout);
- listener.Close ();
ns.Close ();
+ Assert.IsFalse (timeout);
Assert.IsTrue (response.StartsWith ("HTTP/1.1 411"));
}
public void Test11 ()
{
// 0.9
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test11/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test11/");
MyNetworkStream ns = CreateNS (9000);
Send (ns, "POST /test11/ HTTP/0.9\r\nHost: 127.0.0.1\r\n\r\n123");
ns.GetSocket ().Shutdown (SocketShutdown.Send);
string input = Receive (ns, 512);
ns.Close ();
- listener.Close ();
Assert.IsTrue (input.StartsWith ("HTTP/1.1 400"));
}
public void Test12 ()
{
// 0.9
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test12/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test12/");
MyNetworkStream ns = CreateNS (9000);
Send (ns, "POST /test12/ HTTP/0.9\r\nHost: 127.0.0.1\r\nContent-Length: 3\r\n\r\n123");
ns.GetSocket ().Shutdown (SocketShutdown.Send);
string input = Receive (ns, 512);
ns.Close ();
- listener.Close ();
Assert.IsTrue (input.StartsWith ("HTTP/1.1 400"));
}
public void Test13 ()
{
// 0.9
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test13/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test13/");
MyNetworkStream ns = CreateNS (9000);
Send (ns, "GEt /test13/ HTTP/0.9\r\nHost: 127.0.0.1\r\n\r\n");
ns.GetSocket ().Shutdown (SocketShutdown.Send);
string input = Receive (ns, 512);
ns.Close ();
- listener.Close ();
Assert.IsTrue (input.StartsWith ("HTTP/1.1 400"));
}
[Test]
public void Test14 ()
{
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test14/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test14/");
MyNetworkStream ns = CreateNS (9000);
Send (ns, "POST /test14/ HTTP/1.0\r\nHost: 127.0.0.1\r\nContent-Length: 3\r\n\r\n123");
- HttpListenerContext c = listener.GetContext ();
+ HttpListenerContext c = _listener.GetContext ();
test14_request = c.Request;
test_evt = new ManualResetEvent (false);
Thread thread = new Thread (ReadToEnd);
Assert.IsTrue (false, "Timed out");
}
test_evt.Close ();
- Assert.AreEqual ("123", read_to_end, "Did not get the expected input.");
c.Response.Close ();
ns.Close ();
+ Assert.AreEqual ("123", read_to_end, "Did not get the expected input.");
}
string read_to_end;
public void Test15 ()
{
// 2 separate writes -> 2 packets. Body size > 8kB
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test15/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test15/");
MyNetworkStream ns = CreateNS (9000);
Send (ns, "POST /test15/ HTTP/1.0\r\nHost: 127.0.0.1\r\nContent-Length: 8888\r\n\r\n");
Thread.Sleep (800);
string data = new string ('a', 8888);
Send (ns, data);
- HttpListenerContext c = listener.GetContext ();
+ HttpListenerContext c = _listener.GetContext ();
HttpListenerRequest req = c.Request;
using (StreamReader r = new StreamReader (req.InputStream)) {
read_to_end = r.ReadToEnd ();
public void Test16 ()
{
// 1 single write with headers + body (size > 8kB)
- HttpListener listener = CreateAndStartListener ("http://127.0.0.1:9000/test16/");
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test16/");
MyNetworkStream ns = CreateNS (9000);
StringBuilder sb = new StringBuilder ();
sb.Append ("POST /test16/ HTTP/1.0\r\nHost: 127.0.0.1\r\nContent-Length: 8888\r\n\r\n");
sb.Append (eights);
string data = sb.ToString ();
Send (ns, data);
- HttpListenerContext c = listener.GetContext ();
+ HttpListenerContext c = _listener.GetContext ();
HttpListenerRequest req = c.Request;
using (StreamReader r = new StreamReader (req.InputStream)) {
read_to_end = r.ReadToEnd ();
c.Response.Close ();
ns.Close ();
}
+
+ [Test]
+ public void Test17 ()
+ {
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/test17/");
+ NetworkStream ns = CreateNS (9000);
+ Send (ns, "RANDOM /test17/ HTTP/1.1\r\nHost: 127.0.0.1\r\nContent-Length: 3\r\n\r\n123");
+ HttpListenerContext ctx = _listener.GetContext ();
+ Send (ctx.Response.OutputStream, "%%%OK%%%");
+ ctx.Response.Close ();
+ string response = Receive (ns, 1024);
+ ns.Close ();
+ Assert.IsTrue (response.StartsWith ("HTTP/1.1 200"));
+ Assert.IsTrue (-1 != response.IndexOf ("Transfer-Encoding: chunked"));
+ }
+
+ [Test]
+ public void Test_MultipleClosesOnOuputStreamAllowed ()
+ {
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/MultipleCloses/");
+ NetworkStream ns = CreateNS (9000);
+ Send (ns, "GET /MultipleCloses/ HTTP/1.1\r\nHost: 127.0.0.1\r\n\r\n");
+
+ HttpListenerContext ctx = _listener.GetContext ();
+ ctx.Response.OutputStream.Close ();
+ ctx.Response.OutputStream.Close ();
+ ctx.Response.OutputStream.Close ();
+ ctx.Response.Close ();
+ }
+
+ void SendCookie ()
+ {
+ NetworkStream ns = CreateNS (9000);
+ Send (ns, "GET /SendCookie/ HTTP/1.1\r\nHost: 127.0.0.1\r\n"+
+ "Cookie:$Version=\"1\"; "+
+ "Cookie1=Value1; $Path=\"/\"; "+
+ "CookieM=ValueM; $Path=\"/p2\"; $Domain=\"test\"; $Port=\"99\";"+
+ "Cookie2=Value2; $Path=\"/foo\";"+
+ "\r\n"+
+ "\r\n");
+ ns.Flush ();
+ Thread.Sleep (200);
+ ns.Close();
+ }
+
+ [Test]
+ public void ReceiveCookiesFromClient ()
+ {
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/SendCookie/");
+ Thread clientThread = new Thread (new ThreadStart (SendCookie));
+ clientThread.Start ();
+
+ HttpListenerContext context = _listener.GetContext();
+ HttpListenerRequest request = context.Request;
+
+ Assert.AreEqual (3, request.Cookies.Count, "#1");
+ foreach (Cookie c in request.Cookies) {
+ if (c.Name == "Cookie1") {
+ Assert.AreEqual ("Value1", c.Value, "#2");
+ Assert.AreEqual ("\"/\"", c.Path, "#3");
+ Assert.AreEqual (0, c.Port.Length, "#4");
+ Assert.AreEqual (0, c.Domain.Length, "#5");
+ } else if (c.Name == "CookieM") {
+ Assert.AreEqual ("ValueM", c.Value, "#6");
+ Assert.AreEqual ("\"/p2\"", c.Path, "#7");
+ Assert.AreEqual ("\"99\"", c.Port, "#8");
+ Assert.AreEqual ("\"test\"", c.Domain, "#9");
+ } else if (c.Name == "Cookie2") {
+ Assert.AreEqual ("Value2", c.Value, "#10");
+ Assert.AreEqual ("\"/foo\"", c.Path, "#11");
+ Assert.AreEqual (0, c.Port.Length, "#12");
+ Assert.AreEqual (0, c.Domain.Length, "#13");
+ } else
+ Assert.Fail ("Invalid cookie name " + c.Name);
+ }
+ }
+
+ private object _lock = new Object();
+ private string cookieResponse;
+
+ void ReceiveCookie () {
+ lock (_lock) {
+ NetworkStream ns = CreateNS (9000);
+ Send (ns, "GET /ReceiveCookie/ HTTP/1.1\r\nHost: 127.0.0.1\r\n\r\n");
+ cookieResponse = Receive (ns, 512);
+ }
+ }
+
+ [Test]
+ public void SendCookiestoClient ()
+ {
+ _listener = CreateAndStartListener ("http://127.0.0.1:9000/ReceiveCookie/");
+ Thread clientThread = new Thread (new ThreadStart (ReceiveCookie));
+ clientThread.Start ();
+
+ HttpListenerContext context = _listener.GetContext();
+ HttpListenerRequest request = context.Request;
+ HttpListenerResponse response = context.Response;
+
+ Cookie cookie = new Cookie ();
+ cookie.Name = "Name0";
+ cookie.Value = "Value0";
+ cookie.Domain = "blue";
+ cookie.Path = "/path/";
+ cookie.Port = "\"80\"";
+ cookie.Version = 1;
+ response.Cookies.Add (cookie);
+
+ string responseString = "<HTML><BODY>----</BODY></HTML>";
+ byte[] buffer = Encoding.UTF8.GetBytes(responseString);
+ response.ContentLength64 = buffer.Length;
+ Stream output = response.OutputStream;
+ output.Write(buffer, 0, buffer.Length);
+ output.Flush ();
+ response.Close();
+
+ lock (_lock) {
+ bool foundCookie = false;
+ foreach (String str in cookieResponse.Split ('\n')) {
+ if (!str.StartsWith ("Set-Cookie"))
+ continue;
+ Dictionary<string, String> dic = new Dictionary<string, String>();
+ foreach (String p in str.Substring (str.IndexOf (":") + 1).Split (';')) {
+ String[] parts = p.Split('=');
+ dic.Add (parts [0].Trim (), parts [1].Trim ());
+ }
+ Assert.AreEqual ("Value0", dic ["Name0"], "#1");
+ Assert.AreEqual ("blue", dic ["Domain"], "#2");
+ Assert.AreEqual ("\"/path/\"", dic ["Path"], "#3");
+ Assert.AreEqual ("\"80\"", dic ["Port"], "#4");
+ Assert.AreEqual ("1", dic ["Version"], "#5");
+ foundCookie = true;
+ break;
+ }
+ Assert.IsTrue (foundCookie, "#6");
+ }
+ }
+
+ [Test]
+ public void MultiResponses ()
+ {
+ Thread srv = new Thread (new ThreadStart (EchoServer));
+ srv.Start ();
+ Thread.Sleep (200);
+
+ for (int i = 0; i < 10; i++) {
+ string payload = string.Format (CultureInfo.InvariantCulture,
+ "Client{0}", i);
+
+ HttpWebRequest req = (HttpWebRequest) WebRequest.Create (
+ "http://localhost:8888/foobar/");
+ req.ServicePoint.Expect100Continue = false;
+ req.ServicePoint.UseNagleAlgorithm = false;
+ req.Method = "POST";
+ StreamWriter w = new StreamWriter (req.GetRequestStream ());
+ w.WriteLine (payload);
+ w.Close ();
+
+ HttpWebResponse resp = (HttpWebResponse) req.GetResponse ();
+ StreamReader r = new StreamReader (resp.GetResponseStream ());
+ Assert.AreEqual ("Hello, " + payload + "!", r.ReadToEnd ().Trim ());
+ r.Close ();
+ }
+
+ manualReset.Set ();
+ srv.Join ();
+ }
+
+ void EchoServer ()
+ {
+ _listener = new HttpListener ();
+ _listener.Prefixes.Add ("http://*:8888/foobar/");
+ _listener.Start ();
+
+ manualReset = new ManualResetEvent (false);
+
+ IAsyncResult result = _listener.BeginGetContext (
+ new AsyncCallback (EchoCallback), _listener);
+ manualReset.WaitOne ();
+ }
+
+ void EchoCallback (IAsyncResult result)
+ {
+ HttpListener listener = (HttpListener) result.AsyncState;
+ HttpListenerContext context = listener.EndGetContext (result);
+ HttpListenerRequest req = context.Request;
+ StreamReader r = new StreamReader (req.InputStream);
+ string reqBody = r.ReadToEnd ().Trim ();
+
+ HttpListenerResponse resp = context.Response;
+ StreamWriter o = new StreamWriter (resp.OutputStream);
+ o.WriteLine ("Hello, " + reqBody + "!");
+ o.Close ();
+
+ listener.BeginGetContext (new AsyncCallback (EchoCallback), listener);
+ }
+
+ private ManualResetEvent manualReset;
+
}
[TestFixture]
bool timedout;
string response = HttpListener2Test.ReceiveWithTimeout (ns, 1024, 3000, out timedout);
ns.Close ();
+ listener.Close ();
Assert.IsFalse (timedout);
}
StreamReader r = new StreamReader (request.InputStream);
string sr =r.ReadToEnd ();
HttpListener2Test.Send (c.Response.OutputStream, "Miguel is love");
+ c.Response.Close ();
+ }
+
+ //
+ // As it turns out, when we closed the OutputStream,
+ // we were not shutting down the connection, which was
+ // a documented pattern to close the connection
+ //
+ [Test]
+ public void Test_MultipleConnections ()
+ {
+ HttpListener listener = HttpListener2Test.CreateAndStartListener ("http://127.0.0.1:9000/multiple/");
+
+ // First one
+ NetworkStream ns = HttpListener2Test.CreateNS (9000);
+ HttpListener2Test.Send (ns, "POST /multiple/ HTTP/1.0\r\nHost: 127.0.0.1\r\nContent-Length: 3\r\n\r\n123");
+ HttpListenerContext ctx = listener.GetContext ();
+ HttpListener2Test.Send (ctx.Response.OutputStream, "%%%OK%%%");
+ ctx.Response.OutputStream.Close ();
+ string response = HttpListener2Test.Receive (ns, 1024);
+ ns.Close ();
+
+ // Second one
+ ns = HttpListener2Test.CreateNS (9000);
+ HttpListener2Test.Send (ns, "POST /multiple/ HTTP/1.0\r\nHost: 127.0.0.1\r\nContent-Length: 3\r\n\r\n123");
+ ctx = listener.GetContext ();
+ HttpListener2Test.Send (ctx.Response.OutputStream, "%%%OK%%%");
+ ctx.Response.OutputStream.Close ();
+ response = HttpListener2Test.Receive (ns, 1024);
+ ns.Close ();
+
+ listener.Close ();
+ }
+
+ //
+ // Test case for bug 341443, an pretty old bug, filed on November of 2007.
+ //
+ [Test]
+ public void Test_HostInUri ()
+ {
+ var wait = new ManualResetEvent (false);
+ var wait2 = new ManualResetEvent (false);
+
+ Thread t = new Thread (delegate (object a) {
+ wait.WaitOne ();
+
+ NetworkStream ns = HttpListener2Test.CreateNS (9145);
+ HttpListener2Test.Send (ns, "GET http://www.google.com/ HTTP/1.1\r\nHost: www.google.com\r\nContent-Length: 3\r\n\r\n123456");
+
+ wait2.WaitOne ();
+ ns.Close ();
+ });
+ t.Start ();
+
+ HttpListener listener = HttpListener2Test.CreateAndStartListener ("http://*:9145/");
+ wait.Set ();
+ HttpListenerContext ctx = listener.GetContext ();
+
+ Assert.AreEqual ("http://www.google.com:9145/", ctx.Request.Url.ToString ());
+ Assert.AreEqual ("http://www.google.com/", ctx.Request.RawUrl);
+ wait2.Set ();
+
+ listener.Close ();
+ }
+
+ [Test] // bug #513849
+ public void ClosePort ()
+ {
+ var h = new HttpListener ();
+ h.Prefixes.Add ("http://127.0.0.1:8080/");
+ h.Start ();
+ h.BeginGetContext (null, null);
+ h.Stop ();
+ TcpListener t = new TcpListener (IPAddress.Parse ("127.0.0.1"), 8080);
+ t.Start ();
+ t.Stop ();
}
}
}
-#endif
-
projects / mono.git / blobdiff