//
// System.Web.HttpRuntime.cs
//
// Authors:
// Miguel de Icaza (miguel@novell.com)
// Marek Habersack <mhabersack@novell.com>
//
//
// 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.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;
#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 Exception initialException;
static bool firstRun;
static bool assemblyMappingEnabled;
static object assemblyMappingLock = new object ();
static object appOfflineLock = new object ();
public HttpRuntime ()
{
}
#endif
static HttpRuntime ()
{
#if !TARGET_J2EE
firstRun = true;
try {
WebConfigurationManager.Init ();
#if MONOWEB_DEP
SettingsMappingManager.Init ();
#endif
} 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)
initialException = queue_manager.InitialException;
trace_manager = new TraceManager ();
if (trace_manager.HasException)
initialException = trace_manager.InitialException;
cache = new Cache ();
internalCache = new Cache ();
internalCache.DependencyCache = internalCache;
#endif
do_RealProcessRequest = new WaitCallback (RealProcessRequest);
}
#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;
}
}
public static bool UsingIntegratedPipeline { get { return false; } }
[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;
ArrayList watchers = new ArrayList ();
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;
watchers.Add (watcher);
tmp = Path.Combine (app_dir, f);
if (File.Exists (tmp))
offlineFile = tmp;
}
if (offlineFile != null)
SetOfflineMode (true, offlineFile);
}
}
#endif
static void RealProcessRequest (object o)
{
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)
{
#if TARGET_J2EE
HttpContext context = HttpContext.Current;
if (context == null)
context = new HttpContext (req);
else
context.SetWorkerRequest (req);
#else
HttpContext context = new HttpContext (req);
#endif
HttpContext.Current = context;
bool error = false;
#if !TARGET_J2EE
if (firstRun) {
SetupOfflineWatch ();
firstRun = false;
if (initialException != null) {
FinishWithException (req, HttpException.NewWithCode ("Initial exception", initialException, WebEventCodes.RuntimeErrorRequestAbort));
error = true;
}
}
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;
//
// 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);
}
}
//
// 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;
ThreadPool.QueueUserWorkItem (new WaitCallback (ShutdownAppDomain), null);
}
#endif
//
// Shuts down the AppDomain
//
static void ShutdownAppDomain (object args)
{
queue_manager.Dispose ();
// This will call Session_End if needed.
InternalCache.InvokePrivateCallbacks ();
// Kill our application.
HttpApplicationFactory.Dispose ();
ThreadPool.QueueUserWorkItem (new WaitCallback (DoUnload), null);
}
static void DoUnload (object state)
{
#if TARGET_J2EE
// No unload support for appdomains under Grasshopper
#else
AppDomain.Unload (AppDomain.CurrentDomain);
#endif
}
static string content503 = "<!DOCTYPE HTML PUBLIC \"-//IETF//DTD HTML 2.0//EN\">\n" +
"<html><head>\n<title>503 Server Unavailable</title>\n</head><body>\n" +
"<h1>Server Unavailable</h1>\n" +
"</body></html>\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");
if (!File.Exists (compiled))
return null;
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);
}
Assembly ret = null;
try {
string asmPath = Path.Combine (dynamic_base, pf.Assembly + ".dll");
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;
}
}
}
}
|