Added operation cancel operation

src/Http/Http.Abstractions/src/PublicAPI.Unshipped.txt

@@ -1,4 +1,5 @@
 #nullable enable
+const Microsoft.AspNetCore.Http.StatusCodes.Status499ClientClosedRequest = 499 -> int
 Microsoft.AspNetCore.Http.HttpResults.EmptyHttpResult
 Microsoft.AspNetCore.Http.HttpResults.EmptyHttpResult.ExecuteAsync(Microsoft.AspNetCore.Http.HttpContext! httpContext) -> System.Threading.Tasks.Task!
 static Microsoft.AspNetCore.Http.HttpResults.EmptyHttpResult.Instance.get -> Microsoft.AspNetCore.Http.HttpResults.EmptyHttpResult!

src/Http/Http.Abstractions/src/StatusCodes.cs

@@ -283,6 +283,11 @@ public static class StatusCodes
     /// </summary>
     public const int Status451UnavailableForLegalReasons = 451;
 
+    /// <summary>
+    /// HTTP status code 499.
+    /// </summary>
+    public const int Status499ClientClosedRequest = 499;
+
     /// <summary>
     /// HTTP status code 500.
     /// </summary>

src/Http/WebUtilities/src/ReasonPhrases.cs

@@ -66,6 +66,7 @@ public static class ReasonPhrases
         { 429, "Too Many Requests" },
         { 431, "Request Header Fields Too Large" },
         { 451, "Unavailable For Legal Reasons" },
+        { 499, "Client Closed Request" },
 
         { 500, "Internal Server Error" },
         { 501, "Not Implemented" },

src/Middleware/Diagnostics/src/DeveloperExceptionPage/DeveloperExceptionPageMiddlewareImpl.cs

@@ -101,6 +101,18 @@ public async Task Invoke(HttpContext context)
         }
         catch (Exception ex)
         {
+            if (ex is OperationCanceledException && context.RequestAborted.IsCancellationRequested)
+            {
+                _logger.RequestAbortedException();
+
+                if (!context.Response.HasStarted)
+                {
+                    context.Response.StatusCode = StatusCodes.Status499ClientClosedRequest;
+                }
+
+                return;
+            }
+
             _logger.UnhandledException(ex);
 
             if (context.Response.HasStarted)

src/Middleware/Diagnostics/src/DiagnosticsLoggerExtensions.cs

@@ -11,6 +11,9 @@ internal static partial class DiagnosticsLoggerExtensions
     [LoggerMessage(1, LogLevel.Error, "An unhandled exception has occurred while executing the request.", EventName = "UnhandledException")]
     public static partial void UnhandledException(this ILogger logger, Exception exception);
 
+    [LoggerMessage(4, LogLevel.Debug, "The request has aborted.", EventName = "RequestAborted")]
+    public static partial void RequestAbortedException(this ILogger logger);
+
     // ExceptionHandlerMiddleware
     [LoggerMessage(2, LogLevel.Warning, "The response has already started, the error handler will not be executed.", EventName = "ResponseStarted")]
     public static partial void ResponseStartedErrorHandler(this ILogger logger);

src/Middleware/Diagnostics/src/ExceptionHandler/ExceptionHandlerMiddlewareImpl.cs

@@ -112,6 +112,18 @@ static async Task Awaited(ExceptionHandlerMiddlewareImpl middleware, HttpContext
 
     private async Task HandleException(HttpContext context, ExceptionDispatchInfo edi)
     {
+        if (edi.SourceException is OperationCanceledException && context.RequestAborted.IsCancellationRequested)
+        {
+            _logger.RequestAbortedException();
+
+            if (!context.Response.HasStarted)
+            {
+                context.Response.StatusCode = StatusCodes.Status499ClientClosedRequest;
+            }
+
+            return;
+        }
+
         _logger.UnhandledException(edi.SourceException);
         // We can't do anything if the response has already started, just abort.
         if (context.Response.HasStarted)

src/Servers/IIS/IIS/src/Core/IISHttpContext.Log.cs

@@ -24,5 +24,8 @@ public static void ConnectionBadRequest(ILogger logger, string connectionId, Mic
 
         [LoggerMessage(4, LogLevel.Debug, @"Connection id ""{ConnectionId}"" bad request data: ""{message}""", EventName = nameof(ConnectionBadRequest))]
         private static partial void ConnectionBadRequest(ILogger logger, string connectionId, string message, Microsoft.AspNetCore.Http.BadHttpRequestException ex);
+
+        [LoggerMessage(5, LogLevel.Debug, @"Connection ID ""{ConnectionId}"", Request ID ""{TraceIdentifier}"": The request has aborted.", EventName = "RequestAborted")]
+        public static partial void RequestAborted(ILogger logger, string connectionId, string traceIdentifier);
     }
 }

src/Servers/IIS/IIS/src/Core/IISHttpContext.cs

@@ -718,6 +718,10 @@ protected void ReportApplicationError(Exception ex)
 
         Log.ApplicationError(_logger, ((IHttpConnectionFeature)this).ConnectionId, ((IHttpRequestIdentifierFeature)this).TraceIdentifier, ex);
     }
+    protected void ReportRequestAborted()
+    {
+        Log.RequestAborted(_logger, ((IHttpConnectionFeature)this).ConnectionId, ((IHttpRequestIdentifierFeature)this).TraceIdentifier);
+    }
 
     public void PostCompletion(NativeMethods.REQUEST_NOTIFICATION_STATUS requestNotificationStatus)
     {

src/Servers/IIS/IIS/src/Core/IISHttpContextOfT.cs

@@ -4,6 +4,7 @@
 using System.Buffers;
 using Microsoft.AspNetCore.Builder;
 using Microsoft.AspNetCore.Hosting.Server;
+using Microsoft.AspNetCore.Http;
 using Microsoft.Extensions.Logging;
 
 namespace Microsoft.AspNetCore.Server.IIS.Core;
@@ -19,7 +20,6 @@ public IISHttpContextOfT(MemoryPool<byte> memoryPool, IHttpApplication<TContext>
     {
         _application = application;
     }
-
     public override async Task<bool> ProcessRequestAsync()
     {
         var context = default(TContext);
@@ -43,7 +43,15 @@ public override async Task<bool> ProcessRequestAsync()
             }
             catch (Exception ex)
             {
-                ReportApplicationError(ex);
+                if (ex is OperationCanceledException && _requestAborted)
+                {
+                    ReportRequestAborted();
+                }
+                else
+                {
+                    ReportApplicationError(ex);
+                }
+
                 success = false;
             }
 
@@ -82,9 +90,9 @@ public override async Task<bool> ProcessRequestAsync()
             }
             else if (!HasResponseStarted && _requestRejectedException == null)
             {
-                // If the request was aborted and no response was sent, there's no
-                // meaningful status code to log.
-                StatusCode = 0;
+                // If the request was aborted and no response was sent, we use status code 499 for logging
+                // https://learn.microsoft.com/en-us/azure/application-gateway/http-response-codes#499--client-closed-the-connection
+                StatusCode = StatusCodes.Status499ClientClosedRequest;
                 success = false;
             }
 

src/Servers/Kestrel/Core/src/Internal/Http/HttpProtocol.cs

@@ -698,7 +698,14 @@ private async Task ProcessRequests<TContext>(IHttpApplication<TContext> applicat
             }
             catch (Exception ex)
             {
-                ReportApplicationError(ex);
+                if (ex is OperationCanceledException && _connectionAborted)
+                {
+                    Log.RequestAborted(ConnectionId, TraceIdentifier);
+                }
+                else
+                {
+                    ReportApplicationError(ex);
+                }
             }
 
             KestrelEventSource.Log.RequestStop(this);
@@ -739,9 +746,9 @@ private async Task ProcessRequests<TContext>(IHttpApplication<TContext> applicat
                 }
                 else if (!HasResponseStarted)
                 {
-                    // If the request was aborted and no response was sent, there's no
-                    // meaningful status code to log.
-                    StatusCode = 0;
+                    // If the request was aborted and no response was sent, we use status code 499 for logging
+                    // https://learn.microsoft.com/en-us/azure/application-gateway/http-response-codes#499--client-closed-the-connection
+                    StatusCode = StatusCodes.Status499ClientClosedRequest;
                 }
             }
 

src/Servers/Kestrel/Core/src/Internal/Infrastructure/KestrelTrace.General.cs

@@ -64,6 +64,11 @@ public void Http3DisabledWithHttp1AndNoTls(EndPoint endPoint)
         GeneralLog.Http3DisabledWithHttp1AndNoTls(_generalLogger, endPoint);
     }
 
+    public void RequestAborted(string connectionId, string traceIdentifier)
+    {
+        GeneralLog.RequestAbortedException(_generalLogger, connectionId, traceIdentifier);
+    }
+
     private static partial class GeneralLog
     {
         [LoggerMessage(13, LogLevel.Error, @"Connection id ""{ConnectionId}"", Request id ""{TraceIdentifier}"": An unhandled exception was thrown by the application.", EventName = "ApplicationError")]
@@ -99,6 +104,9 @@ private static partial class GeneralLog
         [LoggerMessage(65, LogLevel.Warning, "HTTP/3 is not enabled for {Endpoint}. HTTP/3 requires TLS. Connections to this endpoint will use HTTP/1.1.", EventName = "Http3DisabledWithHttp1AndNoTls")]
         public static partial void Http3DisabledWithHttp1AndNoTls(ILogger logger, EndPoint endPoint);
 
+        [LoggerMessage(66, LogLevel.Debug, @"Connection id ""{ConnectionId}"", Request id ""{TraceIdentifier}"": The request has aborted.", EventName = "RequestAborted")]
+        public static partial void RequestAbortedException(ILogger logger, string connectionId, string traceIdentifier);
+
         // Highest shared ID is 65. New consecutive IDs start at 66
     }
 }