Merge pull request #6183 from mvarblow/issue-1978

[Fixes #1978] Extending MarshalByRef object lease
This commit is contained in:
Sébastien Ros
2015-12-17 12:32:04 -08:00
6 changed files with 46 additions and 1 deletions

View File

@@ -78,5 +78,9 @@ namespace Orchard.Localization {
return string.Equals(_localized, that._localized); return string.Equals(_localized, that._localized);
} }
public override object InitializeLifetimeService() {
// never expire the cross-AppDomain lease on this object
return null;
}
} }
} }

View File

@@ -415,5 +415,9 @@ namespace Orchard.Logging {
} }
} }
public override object InitializeLifetimeService() {
// never expire the cross-AppDomain lease on this object
return null;
}
} }
} }

View File

@@ -2,6 +2,8 @@
using System.Collections.Generic; using System.Collections.Generic;
using System.IO; using System.IO;
using System.Linq; using System.Linq;
using System.Runtime.Remoting;
using System.Runtime.Remoting.Lifetime;
using System.Security; using System.Security;
using System.Web.Hosting; using System.Web.Hosting;
using Orchard.Parameters; using Orchard.Parameters;
@@ -32,28 +34,46 @@ namespace Orchard.Host {
[SecurityCritical] [SecurityCritical]
public override object InitializeLifetimeService() { public override object InitializeLifetimeService() {
// never expire the license // never expire the cross-AppDomain lease on this object
return null; return null;
} }
private static void ExtendLifeTimeLeases(TextReader input, TextWriter output) {
// Orchard objects passed as parameters into this AppDomain should derive from MarshalByRefObject and have
// infinite lease timeouts by means of their InitializeLifetimeService overrides. For the input/output
// stream objects we approximate that behavior by immediately renewing the lease for 30 days.
ExtendLifeTimeLease(input);
ExtendLifeTimeLease(output);
}
private static void ExtendLifeTimeLease(MarshalByRefObject obj) {
if (RemotingServices.IsObjectOutOfAppDomain(obj)) {
var lease = (ILease)RemotingServices.GetLifetimeService(obj);
lease.Renew(TimeSpan.FromDays(30));
}
}
[SecuritySafeCritical] [SecuritySafeCritical]
void IRegisteredObject.Stop(bool immediate) { void IRegisteredObject.Stop(bool immediate) {
HostingEnvironment.UnregisterObject(this); HostingEnvironment.UnregisterObject(this);
} }
public CommandReturnCodes StartSession(TextReader input, TextWriter output) { public CommandReturnCodes StartSession(TextReader input, TextWriter output) {
ExtendLifeTimeLeases(input, output);
_agent = CreateAgent(); _agent = CreateAgent();
return StartHost(_agent, input, output); return StartHost(_agent, input, output);
} }
public void StopSession(TextReader input, TextWriter output) { public void StopSession(TextReader input, TextWriter output) {
if (_agent != null) { if (_agent != null) {
ExtendLifeTimeLeases(input, output);
StopHost(_agent, input, output); StopHost(_agent, input, output);
_agent = null; _agent = null;
} }
} }
public CommandReturnCodes RunCommand(TextReader input, TextWriter output, Logger logger, OrchardParameters args) { public CommandReturnCodes RunCommand(TextReader input, TextWriter output, Logger logger, OrchardParameters args) {
ExtendLifeTimeLeases(input, output);
var agent = CreateAgent(); var agent = CreateAgent();
CommandReturnCodes result = (CommandReturnCodes)agent.GetType().GetMethod("RunSingleCommand").Invoke(agent, new object[] { CommandReturnCodes result = (CommandReturnCodes)agent.GetType().GetMethod("RunSingleCommand").Invoke(agent, new object[] {
input, input,
@@ -66,6 +86,7 @@ namespace Orchard.Host {
} }
public CommandReturnCodes RunCommandInSession(TextReader input, TextWriter output, Logger logger, OrchardParameters args) { public CommandReturnCodes RunCommandInSession(TextReader input, TextWriter output, Logger logger, OrchardParameters args) {
ExtendLifeTimeLeases(input, output);
CommandReturnCodes result = (CommandReturnCodes)_agent.GetType().GetMethod("RunCommand").Invoke(_agent, new object[] { CommandReturnCodes result = (CommandReturnCodes)_agent.GetType().GetMethod("RunCommand").Invoke(_agent, new object[] {
input, input,
output, output,
@@ -77,6 +98,7 @@ namespace Orchard.Host {
} }
public CommandReturnCodes RunCommands(TextReader input, TextWriter output, Logger logger, IEnumerable<ResponseLine> responseLines) { public CommandReturnCodes RunCommands(TextReader input, TextWriter output, Logger logger, IEnumerable<ResponseLine> responseLines) {
ExtendLifeTimeLeases(input, output);
var agent = CreateAgent(); var agent = CreateAgent();
CommandReturnCodes result = StartHost(agent, input, output); CommandReturnCodes result = StartHost(agent, input, output);

View File

@@ -17,5 +17,10 @@ namespace Orchard {
_output.WriteLine(format, args); _output.WriteLine(format, args);
} }
} }
public override object InitializeLifetimeService() {
// never expire the cross-AppDomain lease on this object
return null;
}
} }
} }

View File

@@ -10,5 +10,10 @@ namespace Orchard {
public IList<string> Arguments { get; set; } public IList<string> Arguments { get; set; }
public IList<string> ResponseFiles { get; set; } public IList<string> ResponseFiles { get; set; }
public IDictionary<string, string> Switches { get; set; } public IDictionary<string, string> Switches { get; set; }
public override object InitializeLifetimeService() {
// never expire the cross-AppDomain lease on this object
return null;
}
} }
} }

View File

@@ -10,6 +10,11 @@ namespace Orchard.ResponseFiles {
public string LineText { get; set; } public string LineText { get; set; }
public int LineNumber { get; set; } public int LineNumber { get; set; }
public string[] Args { get; set; } public string[] Args { get; set; }
public override object InitializeLifetimeService() {
// never expire the cross-AppDomain lease on this object
return null;
}
} }
public class ResponseFileReader { public class ResponseFileReader {