1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
|
namespace System.Web.Mvc {
using System;
using System.Web.Mvc.Async;
using System.Web.Routing;
public abstract class AsyncController : Controller, IAsyncManagerContainer, IAsyncController {
private static readonly object _executeTag = new object();
private static readonly object _executeCoreTag = new object();
private readonly AsyncManager _asyncManager = new AsyncManager();
public AsyncManager AsyncManager {
get {
return _asyncManager;
}
}
protected virtual IAsyncResult BeginExecute(RequestContext requestContext, AsyncCallback callback, object state) {
if (requestContext == null) {
throw new ArgumentNullException("requestContext");
}
VerifyExecuteCalledOnce();
Initialize(requestContext);
return AsyncResultWrapper.Begin(callback, state, BeginExecuteCore, EndExecuteCore, _executeTag);
}
protected virtual IAsyncResult BeginExecuteCore(AsyncCallback callback, object state) {
// If code in this method needs to be updated, please also check the ExecuteCore() method
// of Controller to see if that code also must be updated.
PossiblyLoadTempData();
try {
string actionName = RouteData.GetRequiredString("action");
IActionInvoker invoker = ActionInvoker;
IAsyncActionInvoker asyncInvoker = invoker as IAsyncActionInvoker;
if (asyncInvoker != null) {
// asynchronous invocation
BeginInvokeDelegate beginDelegate = delegate(AsyncCallback asyncCallback, object asyncState) {
return asyncInvoker.BeginInvokeAction(ControllerContext, actionName, asyncCallback, asyncState);
};
EndInvokeDelegate endDelegate = delegate(IAsyncResult asyncResult) {
if (!asyncInvoker.EndInvokeAction(asyncResult)) {
HandleUnknownAction(actionName);
}
};
return AsyncResultWrapper.Begin(callback, state, beginDelegate, endDelegate, _executeCoreTag);
}
else {
// synchronous invocation
Action action = () => {
if (!invoker.InvokeAction(ControllerContext, actionName)) {
HandleUnknownAction(actionName);
}
};
return AsyncResultWrapper.BeginSynchronous(callback, state, action, _executeCoreTag);
}
}
catch {
PossiblySaveTempData();
throw;
}
}
protected override IActionInvoker CreateActionInvoker() {
return new AsyncControllerActionInvoker();
}
protected virtual void EndExecute(IAsyncResult asyncResult) {
AsyncResultWrapper.End(asyncResult, _executeTag);
}
protected virtual void EndExecuteCore(IAsyncResult asyncResult) {
// If code in this method needs to be updated, please also check the ExecuteCore() method
// of Controller to see if that code also must be updated.
try {
AsyncResultWrapper.End(asyncResult, _executeCoreTag);
}
finally {
PossiblySaveTempData();
}
}
#region IAsyncController Members
IAsyncResult IAsyncController.BeginExecute(RequestContext requestContext, AsyncCallback callback, object state) {
return BeginExecute(requestContext, callback, state);
}
void IAsyncController.EndExecute(IAsyncResult asyncResult) {
EndExecute(asyncResult);
}
#endregion
}
}
|
