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

Few changes according to code review

This commit is contained in:
Shih-Ying Hsu 2014-03-05 11:17:16 -08:00
parent c9b60c13e4
commit 177b0e87bf
2 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/Microsoft.AspNet.Server.WebListener/AwaitableThrottle.cs
View File

@ -1,5 +1,5 @@
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------
// <copyright file="HttpListener.cs" company="Microsoft"> // <copyright file="AwaitableThrottle.cs" company="Microsoft">
// Copyright (c) Microsoft Corporation. All rights reserved. // Copyright (c) Microsoft Corporation. All rights reserved.
// </copyright> // </copyright>
//------------------------------------------------------------------------------ //------------------------------------------------------------------------------
@ -13,7 +13,7 @@ namespace Microsoft.AspNet.Server.WebListener
/// <summary> /// <summary>
/// Awaitable object that acts like a semaphore. The object would wait if more than maxConcurrent number of clients waits on it /// Awaitable object that acts like a semaphore. The object would wait if more than maxConcurrent number of clients waits on it
/// </summary> /// </summary>
public class AwaitableThrottle internal class AwaitableThrottle
{ {
private static readonly TaskAwaiter<bool> CompletedAwaiter = Task.FromResult(true).GetAwaiter(); private static readonly TaskAwaiter<bool> CompletedAwaiter = Task.FromResult(true).GetAwaiter();

2
src/Microsoft.AspNet.Server.WebListener/OwinWebListener.cs
View File

@ -500,6 +500,8 @@ namespace Microsoft.AspNet.Server.WebListener
} }
catch (Exception ex) catch (Exception ex)
{ {
// Request processing failed to be queued in threadpool
// Log the error message, release throttle and move on
LogHelper.LogException(_logger, "ProcessRequestAsync", ex); LogHelper.LogException(_logger, "ProcessRequestAsync", ex);
_requestProcessingThrottle.Release(); _requestProcessingThrottle.Release();
} }