// // System.Web.HttpRuntime.cs // // Authors: // Miguel de Icaza (miguel@novell.com) // Marek Habersack // // // Copyright (C) 2005-2010 Novell, Inc (http://www.novell.com) // // Permission is hereby granted, free of charge, to any person obtaining // a copy of this software and associated documentation files (the // "Software"), to deal in the Software without restriction, including // without limitation the rights to use, copy, modify, merge, publish, // distribute, sublicense, and/or sell copies of the Software, and to // permit persons to whom the Software is furnished to do so, subject to // the following conditions: // // The above copyright notice and this permission notice shall be // included in all copies or substantial portions of the Software. // // THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, // EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF // MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND // NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS BE // LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN ACTION // OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE. // // // TODO: Call HttpRequest.CloseInputStream when we finish a request, as we are using the IntPtr stream. // using System.IO; using System.Text; using System.Globalization; using System.Collections; using System.Collections.Concurrent; using System.Reflection; using System.Security; using System.Security.Permissions; using System.Web.Caching; using System.Web.Configuration; using System.Web.Management; using System.Web.UI; using System.Web.Util; #if MONOWEB_DEP using Mono.Web.Util; #endif using System.Threading; #if TARGET_J2EE using Mainsoft.Web; #else using System.CodeDom.Compiler; using System.Web.Compilation; #endif namespace System.Web { // CAS - no InheritanceDemand here as the class is sealed [AspNetHostingPermission (SecurityAction.LinkDemand, Level = AspNetHostingPermissionLevel.Minimal)] public sealed class HttpRuntime { static bool domainUnloading; static SplitOrderedList registeredAssemblies; #if TARGET_J2EE static QueueManager queue_manager { get { return _runtime._queue_manager; } } static TraceManager trace_manager { get { return _runtime._trace_manager; } } static Cache cache { get { return _runtime._cache; } } static Cache internalCache { get { return _runtime._internalCache; } } static WaitCallback do_RealProcessRequest; QueueManager _queue_manager; TraceManager _trace_manager; Cache _cache; Cache _internalCache; public HttpRuntime () { WebConfigurationManager.Init (); _queue_manager = new QueueManager (); _trace_manager = new TraceManager (); _cache = new Cache (); _internalCache = new Cache(); _internalCache.DependencyCache = _cache; } static HttpRuntime _runtimeInstance { get { HttpRuntime runtime = (HttpRuntime) AppDomain.CurrentDomain.GetData ("HttpRuntime"); if (runtime == null) lock (typeof (HttpRuntime)) { runtime = (HttpRuntime) AppDomain.CurrentDomain.GetData ("HttpRuntime"); if (runtime == null) { runtime = new HttpRuntime (); AppDomain.CurrentDomain.SetData ("HttpRuntime", runtime); } } return runtime; } } static HttpRuntime _runtime { get { if (HttpContext.Current != null) return HttpContext.Current.HttpRuntimeInstance; else return _runtimeInstance; } } #else static QueueManager queue_manager; static TraceManager trace_manager; static Cache cache; static Cache internalCache; static WaitCallback do_RealProcessRequest; static HttpWorkerRequest.EndOfSendNotification end_of_send_cb; static Exception initialException; static bool firstRun; static bool assemblyMappingEnabled; static object assemblyMappingLock = new object (); static object appOfflineLock = new object (); static HttpRuntimeSection runtime_section; public HttpRuntime () { } #endif static HttpRuntime () { #if !TARGET_J2EE firstRun = true; try { WebConfigurationManager.Init (); #if MONOWEB_DEP SettingsMappingManager.Init (); #endif runtime_section = (HttpRuntimeSection) WebConfigurationManager.GetSection ("system.web/httpRuntime"); } catch (Exception ex) { initialException = ex; } // The classes in whose constructors exceptions may be thrown, should be handled the same way QueueManager // and TraceManager are below. The constructors themselves MUST NOT throw any exceptions - we MUST be sure // the objects are created here. The exceptions will be dealt with below, in RealProcessRequest. queue_manager = new QueueManager (); if (queue_manager.HasException) { if (initialException == null) initialException = queue_manager.InitialException; else { Console.Error.WriteLine ("Exception during QueueManager initialization:"); Console.Error.WriteLine (queue_manager.InitialException); } } trace_manager = new TraceManager (); if (trace_manager.HasException) { if (initialException == null) initialException = trace_manager.InitialException; else { Console.Error.WriteLine ("Exception during TraceManager initialization:"); Console.Error.WriteLine (trace_manager.InitialException); } } registeredAssemblies = new SplitOrderedList (StringComparer.Ordinal); cache = new Cache (); internalCache = new Cache (); internalCache.DependencyCache = internalCache; #endif do_RealProcessRequest = new WaitCallback (state => { try { RealProcessRequest (state); } catch {} }); end_of_send_cb = new HttpWorkerRequest.EndOfSendNotification (EndOfSend); } internal static SplitOrderedList RegisteredAssemblies { get { return registeredAssemblies; } } #region AppDomain handling internal static bool DomainUnloading { get { return domainUnloading; } } [MonoDocumentationNote ("Currently returns path to the application root")] public static string AspClientScriptPhysicalPath { get { return AppDomainAppPath; } } [MonoDocumentationNote ("Currently returns path to the application root")] public static string AspClientScriptVirtualPath { get { return AppDomainAppVirtualPath; } } // // http://radio.weblogs.com/0105476/stories/2002/07/12/executingAspxPagesWithoutAWebServer.html // public static string AppDomainAppId { [AspNetHostingPermission (SecurityAction.Demand, Level = AspNetHostingPermissionLevel.High)] get { // // This value should not change across invocations // string dirname = (string) AppDomain.CurrentDomain.GetData (".appId"); if ((dirname != null) && (dirname.Length > 0) && SecurityManager.SecurityEnabled) { new FileIOPermission (FileIOPermissionAccess.PathDiscovery, dirname).Demand (); } return dirname; } } // Physical directory for the application public static string AppDomainAppPath { get { string dirname = (string) AppDomain.CurrentDomain.GetData (".appPath"); if (SecurityManager.SecurityEnabled) { new FileIOPermission (FileIOPermissionAccess.PathDiscovery, dirname).Demand (); } return dirname; } } public static string AppDomainAppVirtualPath { get { return (string) AppDomain.CurrentDomain.GetData (".appVPath"); } } public static string AppDomainId { [AspNetHostingPermission (SecurityAction.Demand, Level = AspNetHostingPermissionLevel.High)] get { return (string) AppDomain.CurrentDomain.GetData (".domainId"); } } public static string AspInstallDirectory { get { string dirname = (string) AppDomain.CurrentDomain.GetData (".hostingInstallDir"); if ((dirname != null) && (dirname.Length > 0) && SecurityManager.SecurityEnabled) { new FileIOPermission (FileIOPermissionAccess.PathDiscovery, dirname).Demand (); } return dirname; } } #endregion static string _actual_bin_directory; public static string BinDirectory { get { if (_actual_bin_directory == null) { string[] parts = AppDomain.CurrentDomain.SetupInformation.PrivateBinPath.Split (';'); string mypath = AppDomainAppPath; string tmp; foreach (string p in parts) { tmp = Path.Combine (mypath, p); if (Directory.Exists (tmp)) { _actual_bin_directory = tmp; break; } } if (_actual_bin_directory == null) _actual_bin_directory = Path.Combine (mypath, "bin"); if (_actual_bin_directory [_actual_bin_directory.Length - 1] != Path.DirectorySeparatorChar) _actual_bin_directory += Path.DirectorySeparatorChar; } if (SecurityManager.SecurityEnabled) new FileIOPermission (FileIOPermissionAccess.PathDiscovery, _actual_bin_directory).Demand (); return _actual_bin_directory; } } public static Cache Cache { get { return cache; } } internal static Cache InternalCache { get { return internalCache; } } public static string ClrInstallDirectory { get { string dirname = Path.GetDirectoryName (typeof (Object).Assembly.Location); if ((dirname != null) && (dirname.Length > 0) && SecurityManager.SecurityEnabled) { new FileIOPermission (FileIOPermissionAccess.PathDiscovery, dirname).Demand (); } return dirname; } } public static string CodegenDir { get { string dirname = AppDomain.CurrentDomain.SetupInformation.DynamicBase; if (SecurityManager.SecurityEnabled) { new FileIOPermission (FileIOPermissionAccess.PathDiscovery, dirname).Demand (); } return dirname; } } public static bool IsOnUNCShare { [AspNetHostingPermission (SecurityAction.Demand, Level = AspNetHostingPermissionLevel.Low)] get { return RuntimeHelpers.IsUncShare; } } public static string MachineConfigurationDirectory { get { string dirname = Path.GetDirectoryName (ICalls.GetMachineConfigPath ()); if ((dirname != null) && (dirname.Length > 0) && SecurityManager.SecurityEnabled) { new FileIOPermission (FileIOPermissionAccess.PathDiscovery, dirname).Demand (); } return dirname; } } internal static HttpRuntimeSection Section { get { return runtime_section; } } public static bool UsingIntegratedPipeline { get { return false; } } #if NET_4_5 public static Version IISVersion { get { // Null means not hosted by IIS return null; } } public static Version TargetFramework { get { return runtime_section.TargetFramework; } } #endif [SecurityPermission (SecurityAction.Demand, UnmanagedCode = true)] public static void Close () { // Remove all items from cache. } internal static HttpWorkerRequest QueuePendingRequest (bool started_internally) { HttpWorkerRequest next = queue_manager.GetNextRequest (null); if (next == null) return null; if (!started_internally) { next.StartedInternally = true; ThreadPool.QueueUserWorkItem (do_RealProcessRequest, next); return null; } return next; } #if !TARGET_J2EE static readonly string[] app_offline_files = {"app_offline.htm", "App_Offline.htm", "APP_OFFLINE.HTM"}; static string app_offline_file; static bool AppIsOffline (HttpContext context) { if (!HttpApplicationFactory.ApplicationDisabled || app_offline_file == null) return false; HttpResponse response = context.Response; response.Clear (); response.ContentType = "text/html"; response.ExpiresAbsolute = DateTime.UtcNow; response.StatusCode = 503; response.TransmitFile (app_offline_file, true); context.Request.ReleaseResources (); context.Response.ReleaseResources (); HttpContext.Current = null; HttpApplication.requests_total_counter.Increment (); return true; } static void AppOfflineFileRenamed (object sender, RenamedEventArgs args) { AppOfflineFileChanged (sender, args); } static void AppOfflineFileChanged (object sender, FileSystemEventArgs args) { lock (appOfflineLock) { bool offline; switch (args.ChangeType) { case WatcherChangeTypes.Created: case WatcherChangeTypes.Changed: offline = true; break; case WatcherChangeTypes.Deleted: offline = false; break; case WatcherChangeTypes.Renamed: RenamedEventArgs rargs = args as RenamedEventArgs; if (rargs != null && String.Compare (rargs.Name, "app_offline.htm", StringComparison.OrdinalIgnoreCase) == 0) offline = true; else offline = false; break; default: offline = false; break; } SetOfflineMode (offline, args.FullPath); } } static void SetOfflineMode (bool offline, string filePath) { if (!offline) { app_offline_file = null; if (HttpApplicationFactory.ApplicationDisabled) HttpRuntime.UnloadAppDomain (); } else { app_offline_file = filePath; HttpApplicationFactory.DisableWatchers (); HttpApplicationFactory.ApplicationDisabled = true; InternalCache.InvokePrivateCallbacks (); HttpApplicationFactory.Dispose (); } } static void SetupOfflineWatch () { lock (appOfflineLock) { FileSystemEventHandler seh = new FileSystemEventHandler (AppOfflineFileChanged); RenamedEventHandler reh = new RenamedEventHandler (AppOfflineFileRenamed); string app_dir = AppDomainAppPath; FileSystemWatcher watcher; string offlineFile = null, tmp; foreach (string f in app_offline_files) { watcher = new FileSystemWatcher (); watcher.Path = Path.GetDirectoryName (app_dir); watcher.Filter = Path.GetFileName (f); watcher.NotifyFilter |= NotifyFilters.Size; watcher.Deleted += seh; watcher.Changed += seh; watcher.Created += seh; watcher.Renamed += reh; watcher.EnableRaisingEvents = true; tmp = Path.Combine (app_dir, f); if (File.Exists (tmp)) offlineFile = tmp; } if (offlineFile != null) SetOfflineMode (true, offlineFile); } } #endif static void RealProcessRequest (object o) { if (domainUnloading) { Console.Error.WriteLine ("Domain is unloading, not processing the request."); return; } HttpWorkerRequest req = (HttpWorkerRequest) o; bool started_internally = req.StartedInternally; do { Process (req); req = QueuePendingRequest (started_internally); } while (started_internally && req != null); } static void Process (HttpWorkerRequest req) { bool error = false; #if TARGET_J2EE HttpContext context = HttpContext.Current; if (context == null) context = new HttpContext (req); else context.SetWorkerRequest (req); #else if (firstRun) { firstRun = false; if (initialException != null) { FinishWithException (req, HttpException.NewWithCode ("Initial exception", initialException, WebEventCodes.RuntimeErrorRequestAbort)); error = true; } SetupOfflineWatch (); } HttpContext context = new HttpContext (req); #endif HttpContext.Current = context; #if !TARGET_J2EE if (AppIsOffline (context)) return; #endif // // Get application instance (create or reuse an instance of the correct class) // HttpApplication app = null; if (!error) { try { app = HttpApplicationFactory.GetApplication (context); } catch (Exception e) { FinishWithException (req, HttpException.NewWithCode (String.Empty, e, WebEventCodes.RuntimeErrorRequestAbort)); error = true; } } if (error) { context.Request.ReleaseResources (); context.Response.ReleaseResources (); HttpContext.Current = null; } else { context.ApplicationInstance = app; req.SetEndOfSendNotification (end_of_send_cb, context); // // Ask application to service the request // #if TARGET_J2EE IHttpAsyncHandler ihah = app; if (context.Handler == null) ihah.BeginProcessRequest (context, new AsyncCallback (request_processed), context); else app.Tick (); //ihh.ProcessRequest (context); IHttpExtendedHandler extHandler = context.Handler as IHttpExtendedHandler; if (extHandler != null && !extHandler.IsCompleted) return; if (context.Error is UnifyRequestException) return; ihah.EndProcessRequest (null); #else IHttpHandler ihh = app; // IAsyncResult appiar = ihah.BeginProcessRequest (context, new AsyncCallback (request_processed), context); // ihah.EndProcessRequest (appiar); ihh.ProcessRequest (context); #endif HttpApplicationFactory.Recycle (app); } } static void EndOfSend (HttpWorkerRequest ignored1, object ignored2) { } // // ProcessRequest method is executed in the AppDomain of the application // // Observations: // ProcessRequest does not guarantee that `wr' will be processed synchronously, // the request can be queued and processed later. // [AspNetHostingPermission (SecurityAction.Demand, Level = AspNetHostingPermissionLevel.Medium)] public static void ProcessRequest (HttpWorkerRequest wr) { if (wr == null) throw new ArgumentNullException ("wr"); // // Queue our request, fetch the next available one from the queue // HttpWorkerRequest request = queue_manager.GetNextRequest (wr); if (request == null) return; QueuePendingRequest (false); RealProcessRequest (request); } #if TARGET_J2EE // // Callback to be invoked by IHttpAsyncHandler.BeginProcessRequest // static void request_processed (IAsyncResult iar) { HttpContext context = (HttpContext) iar.AsyncState; context.Request.ReleaseResources (); context.Response.ReleaseResources (); } #endif #if TARGET_JVM [MonoNotSupported ("UnloadAppDomain is not supported")] public static void UnloadAppDomain () { throw new NotImplementedException ("UnloadAppDomain is not supported"); } #else // // Called when we are shutting down or we need to reload an application // that has been modified (touch global.asax) // [SecurityPermission (SecurityAction.Demand, UnmanagedCode = true)] public static void UnloadAppDomain () { // // TODO: call ReleaseResources // domainUnloading = true; HttpApplicationFactory.DisableWatchers (); ThreadPool.QueueUserWorkItem (delegate { try { ShutdownAppDomain (); } catch (Exception e){ Console.Error.WriteLine (e); } }); } #endif // // Shuts down the AppDomain // static void ShutdownAppDomain () { queue_manager.Dispose (); // This will call Session_End if needed. InternalCache.InvokePrivateCallbacks (); // Kill our application. HttpApplicationFactory.Dispose (); ThreadPool.QueueUserWorkItem (delegate { try { DoUnload (); } catch { }}); } static void DoUnload () { #if TARGET_J2EE // No unload support for appdomains under Grasshopper #else AppDomain.Unload (AppDomain.CurrentDomain); #endif } static string content503 = "\n" + "\n503 Server Unavailable\n\n" + "

Server Unavailable

\n" + "\n"; static void FinishWithException (HttpWorkerRequest wr, HttpException e) { int code = e.GetHttpCode (); wr.SendStatus (code, HttpWorkerRequest.GetStatusDescription (code)); wr.SendUnknownResponseHeader ("Connection", "close"); Encoding enc = Encoding.ASCII; wr.SendUnknownResponseHeader ("Content-Type", "text/html; charset=" + enc.WebName); string msg = e.GetHtmlErrorMessage (); byte [] contentBytes = enc.GetBytes (msg); wr.SendUnknownResponseHeader ("Content-Length", contentBytes.Length.ToString ()); wr.SendResponseFromMemory (contentBytes, contentBytes.Length); wr.FlushResponse (true); wr.CloseConnection (); HttpApplication.requests_total_counter.Increment (); } // // This is called from the QueueManager if a request // can not be processed (load, no resources, or // appdomain unload). // static internal void FinishUnavailable (HttpWorkerRequest wr) { wr.SendStatus (503, "Service unavailable"); wr.SendUnknownResponseHeader ("Connection", "close"); Encoding enc = Encoding.ASCII; wr.SendUnknownResponseHeader ("Content-Type", "text/html; charset=" + enc.WebName); byte [] contentBytes = enc.GetBytes (content503); wr.SendUnknownResponseHeader ("Content-Length", contentBytes.Length.ToString ()); wr.SendResponseFromMemory (contentBytes, contentBytes.Length); wr.FlushResponse (true); wr.CloseConnection (); HttpApplication.requests_total_counter.Increment (); } [AspNetHostingPermissionAttribute(SecurityAction.Demand, Level = AspNetHostingPermissionLevel.Unrestricted)] [MonoDocumentationNote ("Always returns null on Mono")] public static NamedPermissionSet GetNamedPermissionSet () { return null; } #if !TARGET_J2EE static internal void WritePreservationFile (Assembly asm, string genericNameBase) { if (asm == null) throw new ArgumentNullException ("asm"); if (String.IsNullOrEmpty (genericNameBase)) throw new ArgumentNullException ("genericNameBase"); string compiled = Path.Combine (AppDomain.CurrentDomain.SetupInformation.DynamicBase, genericNameBase + ".compiled"); PreservationFile pf = new PreservationFile (); try { pf.VirtualPath = String.Concat ("/", genericNameBase, "/"); AssemblyName an = asm.GetName (); pf.Assembly = an.Name; pf.ResultType = BuildResultTypeCode.TopLevelAssembly; pf.Save (compiled); } catch (Exception ex) { throw new HttpException ( String.Format ("Failed to write preservation file {0}", genericNameBase + ".compiled"), ex); } } static Assembly ResolveAssemblyHandler(object sender, ResolveEventArgs e) { AssemblyName an = new AssemblyName (e.Name); string dynamic_base = AppDomain.CurrentDomain.SetupInformation.DynamicBase; string compiled = Path.Combine (dynamic_base, an.Name + ".compiled"); string asmPath; if (!File.Exists (compiled)) { string fn = an.FullName; if (!RegisteredAssemblies.Find ((uint)fn.GetHashCode (), fn, out asmPath)) return null; } else { PreservationFile pf; try { pf = new PreservationFile (compiled); } catch (Exception ex) { throw new HttpException ( String.Format ("Failed to read preservation file {0}", an.Name + ".compiled"), ex); } asmPath = Path.Combine (dynamic_base, pf.Assembly + ".dll"); } if (String.IsNullOrEmpty (asmPath)) return null; Assembly ret = null; try { ret = Assembly.LoadFrom (asmPath); } catch (Exception) { // ignore } return ret; } internal static void EnableAssemblyMapping (bool enable) { lock (assemblyMappingLock) { if (assemblyMappingEnabled == enable) return; if (enable) AppDomain.CurrentDomain.AssemblyResolve += new ResolveEventHandler (ResolveAssemblyHandler); else AppDomain.CurrentDomain.AssemblyResolve -= new ResolveEventHandler (ResolveAssemblyHandler); assemblyMappingEnabled = enable; } } #endif // #if !TARGET_J2EE internal static TraceManager TraceManager { get { return trace_manager; } } } }