mcs/class/System/System.Net/ListenerAsyncResult.cs

   1 //
   2 // System.Net.ListenerAsyncResult
   3 //
   4 // Authors:
   5 //      Gonzalo Paniagua Javier (gonzalo@ximian.com)
   6 //
   7 // Copyright (c) 2005 Ximian, Inc (http://www.ximian.com)
   8 //
   9
  10 //
  11 // Permission is hereby granted, free of charge, to any person obtaining
  12 // a copy of this software and associated documentation files (the
  13 // "Software"), to deal in the Software without restriction, including
  14 // without limitation the rights to use, copy, modify, merge, publish,
  15 // distribute, sublicense, and/or sell copies of the Software, and to
  16 // permit persons to whom the Software is furnished to do so, subject to
  17 // the following conditions:
  18 //
  19 // The above copyright notice and this permission notice shall be
  20 // included in all copies or substantial portions of the Software.
  21 //
  22 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
  23 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
  24 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
  25 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
  26 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
  27 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  28 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  29 //
  30
  31 #if NET_2_0 && SECURITY_DEP
  32
  33 using System.Threading;
  34 namespace System.Net {
  35         class ListenerAsyncResult : IAsyncResult {
  36                 ManualResetEvent handle;
  37                 bool synch;
  38                 bool completed;
  39                 AsyncCallback cb;
  40                 object state;
  41                 Exception exception;
  42                 HttpListenerContext context;
  43                 object locker = new object ();
  44
  45                 public ListenerAsyncResult (AsyncCallback cb, object state)
  46                 {
  47                         this.cb = cb;
  48                         this.state = state;
  49                 }
  50
  51                 internal void Complete (string error)
  52                 {
  53                         //FIXME: error_code?
  54                         exception = new HttpListenerException (0, error);
  55                         lock (locker) {
  56                                 completed = true;
  57                                 if (handle != null)
  58                                         handle.Set ();
  59
  60                                 if (cb != null)
  61                                         ThreadPool.QueueUserWorkItem (InvokeCallback, this);
  62                         }
  63                 }
  64
  65                 static void InvokeCallback (object o)
  66                 {
  67                         ListenerAsyncResult ares = (ListenerAsyncResult) o;
  68                         ares.cb (ares);
  69                 }
  70
  71                 internal void Complete (HttpListenerContext context)
  72                 {
  73                         Complete (context, false);
  74                 }
  75
  76                 internal void Complete (HttpListenerContext context, bool synch)
  77                 {
  78                         this.synch = synch;
  79                         this.context = context;
  80                         lock (locker) {
  81                                 completed = true;
  82                                 if (handle != null)
  83                                         handle.Set ();
  84
  85                                 if ((context.Listener.AuthenticationSchemes == AuthenticationSchemes.Basic || context.Listener.AuthenticationSchemes == AuthenticationSchemes.Negotiate) && context.Request.Headers ["Authorization"] == null) {
  86                                         context.Listener.EndGetContext (this);
  87                                         context.Response.StatusCode = 401;
  88                                         context.Response.Headers ["WWW-Authenticate"] = AuthenticationSchemes.Basic + "realm=\"\"";
  89                                         context.Response.OutputStream.Close ();
  90                                         context.Listener.BeginGetContext (cb, state);
  91                                 } else if (cb != null)
  92                                         ThreadPool.QueueUserWorkItem (InvokeCallback, this);
  93                         }
  94                 }
  95
  96                 internal HttpListenerContext GetContext ()
  97                 {
  98                         if (exception != null)
  99                                 throw exception;
 100
 101                         return context;
 102                 }
 103
 104                 public object AsyncState {
 105                         get { return state; }
 106                 }
 107
 108                 public WaitHandle AsyncWaitHandle {
 109                         get {
 110                                 lock (locker) {
 111                                         if (handle == null)
 112                                                 handle = new ManualResetEvent (completed);
 113                                 }
 114
 115                                 return handle;
 116                         }
 117                 }
 118
 119                 public bool CompletedSynchronously {
 120                         get { return synch; }
 121                 }
 122
 123                 public bool IsCompleted {
 124                         get {
 125                                 lock (locker) {
 126                                         return completed;
 127                                 }
 128                         }
 129                 }
 130         }
 131 }
 132 #endif
 133