5 // Ankit Jain <jankit@novell.com>
6 // Atsushi Enomoto <atsushi@ximian.com>
8 // Copyright (C) 2006,2009 Novell, Inc. http://www.novell.com
10 // Permission is hereby granted, free of charge, to any person obtaining
11 // a copy of this software and associated documentation files (the
12 // "Software"), to deal in the Software without restriction, including
13 // without limitation the rights to use, copy, modify, merge, publish,
14 // distribute, sublicense, and/or sell copies of the Software, and to
15 // permit persons to whom the Software is furnished to do so, subject to
16 // the following conditions:
18 // The above copyright notice and this permission notice shall be
19 // included in all copies or substantial portions of the Software.
21 // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
22 // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
23 // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
24 // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE
25 // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION
26 // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
27 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
30 using System.Collections.Generic;
33 using System.Threading;
35 using System.ServiceModel;
36 using System.ServiceModel.Activation;
37 using System.ServiceModel.Configuration;
38 using System.ServiceModel.Description;
40 namespace System.ServiceModel.Channels {
42 internal class SvcHttpHandler : IHttpHandler
49 Queue<HttpContext> pending = new Queue<HttpContext> ();
52 AutoResetEvent wait = new AutoResetEvent (false);
53 AutoResetEvent listening = new AutoResetEvent (false);
55 public SvcHttpHandler (Type type, Type factoryType, string path)
58 this.factory_type = factoryType;
62 public bool IsReusable
67 public ServiceHostBase Host {
71 public HttpContext WaitForRequest (TimeSpan timeout)
73 DateTime start = DateTime.Now;
75 if (pending.Count > 0) {
76 var ctx = pending.Dequeue ();
77 if (ctx.AllErrors != null && ctx.AllErrors.Length > 0)
78 return WaitForRequest (timeout - (DateTime.Now - start));
83 return wait.WaitOne (timeout - (DateTime.Now - start), false) && !closing ?
84 WaitForRequest (timeout - (DateTime.Now - start)) : null;
87 public void ProcessRequest (HttpContext context)
89 request_url = context.Request.Url;
91 pending.Enqueue (context);
98 public void EndRequest (HttpContext context)
113 void EnsureServiceHost ()
118 //ServiceHost for this not created yet
119 var baseUri = new Uri (HttpContext.Current.Request.Url.GetLeftPart (UriPartial.Path));
120 if (factory_type != null) {
121 host = ((ServiceHostFactory) Activator.CreateInstance (factory_type)).CreateServiceHost (type, new Uri [] {baseUri});
124 host = new ServiceHost (type, baseUri);
127 if (host.Description.Endpoints.Count == 0)
128 //FIXME: Binding: Get from web.config.
129 host.AddServiceEndpoint (ContractDescription.GetContract (type).Name,
130 new BasicHttpBinding (), new Uri (path, UriKind.Relative));
132 var c = host.BaseAddresses;
137 //listening.WaitOne ();