mcs/class/System.Web/System.Web/QueueManager.cs

   1 //
   2 // System.Web.QueueManager
   3 //
   4 // Authors:
   5 //      Gonzalo Paniagua Javier (gonzalo@ximian.com)
   6 //
   7 // (C) 2003-2009 Novell, Inc (http://www.novell.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 using System;
  32 using System.Collections;
  33 using System.Diagnostics;
  34 using System.Text;
  35 using System.Threading;
  36 using System.Web.Configuration;
  37
  38 namespace System.Web
  39 {
  40         sealed class QueueManager
  41         {
  42                 // keep the defaults in sync with the ones in HttpRuntimeSection.cs
  43                 int minFree = 8;
  44                 int minLocalFree = 4;
  45                 int queueLimit = 5000;
  46                 Queue queue;
  47                 bool disposing;
  48                 Exception initialException;
  49                 PerformanceCounter requestsQueuedCounter;
  50
  51                 public QueueManager ()
  52                 {
  53                         Exception ex = null;
  54
  55                         try {
  56                                 HttpRuntimeSection config = HttpRuntime.Section;
  57                                 if (config != null) {
  58                                         minFree = config.MinFreeThreads;
  59                                         minLocalFree = config.MinLocalRequestFreeThreads;
  60                                         queueLimit = config.AppRequestQueueLimit;
  61                                 }
  62                         } catch (Exception e) {
  63                                 ex = e;
  64                         }
  65
  66                         try {
  67                                 queue = new Queue (queueLimit);
  68                         } catch (Exception e) {
  69                                 if (ex == null) {
  70                                         initialException = e;
  71                                 } else {
  72                                         StringBuilder sb = new StringBuilder ("Several exceptions occurred:\n");
  73                                         sb.AppendFormat ("--- Exception Q1:\n{0}\n", ex.ToString ());
  74                                         sb.AppendFormat ("--- Exception Q2:\n{0}\n", e.ToString ());
  75                                         initialException = new Exception (sb.ToString ());
  76                                 }
  77                         }
  78
  79                         if (initialException == null && ex != null)
  80                                 initialException = ex;
  81
  82                         requestsQueuedCounter = new PerformanceCounter ("ASP.NET", "Requests Queued");
  83                         requestsQueuedCounter.RawValue = 0;
  84                 }
  85
  86                 public bool HasException {
  87                         get { return initialException != null; }
  88                 }
  89
  90                 public Exception InitialException {
  91                         get { return initialException; }
  92                 }
  93
  94                 bool CanExecuteRequest (HttpWorkerRequest req)
  95                 {
  96                         if (disposing)
  97                                 return false;
  98
  99                         int threads, cports;
 100                         ThreadPool.GetAvailableThreads (out threads, out cports);
 101                         bool local = (req != null && req.GetLocalAddress () == "127.0.0.1");
 102                         return (threads > minFree) || (local && threads > minLocalFree);
 103                 }
 104
 105                 public HttpWorkerRequest GetNextRequest (HttpWorkerRequest req)
 106                 {
 107                         if (!CanExecuteRequest (req)) {
 108                                 if (!disposing && req != null) {
 109                                         lock (queue) {
 110                                                 Queue (req);
 111                                         }
 112                                 }
 113
 114                                 return null;
 115                         }
 116
 117                         HttpWorkerRequest result;
 118                         lock (queue) {
 119                                 result = Dequeue ();
 120                                 if (result != null) {
 121                                         if (req != null)
 122                                                 Queue (req);
 123                                 } else {
 124                                         result = req;
 125                                 }
 126                         }
 127
 128                         return result;
 129                 }
 130
 131                 void Queue (HttpWorkerRequest wr)
 132                 {
 133                         if (queue.Count < queueLimit) {
 134                                 queue.Enqueue (wr);
 135                                 requestsQueuedCounter.Increment ();
 136                                 return;
 137                         }
 138
 139                         HttpRuntime.FinishUnavailable (wr);
 140                 }
 141
 142                 HttpWorkerRequest Dequeue ()
 143                 {
 144                         if (queue.Count > 0) {
 145                                 HttpWorkerRequest request = (HttpWorkerRequest) queue.Dequeue ();
 146                                 requestsQueuedCounter.Decrement ();
 147                                 return request;
 148                         }
 149
 150                         return null;
 151                 }
 152
 153                 public void Dispose ()
 154                 {
 155                         if (disposing)
 156                                 return;
 157
 158                         disposing = true;
 159                         HttpWorkerRequest wr;
 160                         while ((wr = GetNextRequest (null)) != null)
 161                                 HttpRuntime.FinishUnavailable (wr);
 162
 163                         queue = null;
 164                 }
 165         }
 166 }
 167