huahaofeng
/
aspnetcore
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Lazy create ResourceInvoker.InvokeNextResourceFilter statemachine

This commit is contained in:
Ben Adams 2019-04-12 03:02:23 +01:00 committed by Ryan Nowak
parent 8bb54fc22a
commit 1a7e606504
1 changed files with 30 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
src/Mvc/Mvc.Core/src/Infrastructure/ResourceInvoker.cs
View File

@ -911,7 +911,7 @@ namespace Microsoft.AspNetCore.Mvc.Infrastructure
return _resourceExecutedContext; return _resourceExecutedContext;
} }
private async Task InvokeNextResourceFilter() private Task InvokeNextResourceFilter()
{ {
try try
{ {
@ -919,9 +919,14 @@ namespace Microsoft.AspNetCore.Mvc.Infrastructure
var next = State.ResourceNext; var next = State.ResourceNext;
var state = (object)null; var state = (object)null;
var isCompleted = false; var isCompleted = false;
while (!isCompleted) while (!isCompleted)
{ {
await Next(ref next, ref scope, ref state, ref isCompleted); var lastTask = Next(ref next, ref scope, ref state, ref isCompleted);
if (!lastTask.IsCompletedSuccessfully)
{
return Awaited(this, lastTask, next, scope, state, isCompleted);
}
} }
} }
catch (Exception exception) catch (Exception exception)
@ -933,6 +938,29 @@ namespace Microsoft.AspNetCore.Mvc.Infrastructure
} }
Debug.Assert(_resourceExecutedContext != null); Debug.Assert(_resourceExecutedContext != null);
return Task.CompletedTask;
static async Task Awaited(ResourceInvoker invoker, Task lastTask, State next, Scope scope, object state, bool isCompleted)
{
try
{
await lastTask;
while (!isCompleted)
{
await invoker.Next(ref next, ref scope, ref state, ref isCompleted);
}
}
catch (Exception exception)
{
invoker._resourceExecutedContext = new ResourceExecutedContext(invoker._resourceExecutingContext, invoker._filters)
{
ExceptionDispatchInfo = ExceptionDispatchInfo.Capture(exception),
};
}
Debug.Assert(invoker._resourceExecutedContext != null);
}
} }
private async Task InvokeNextExceptionFilterAsync() private async Task InvokeNextExceptionFilterAsync()