Merge branch 'release/2.1' into dev

benchmarks/Kestrel.Performance/InMemoryTransportBenchmark.cs

@@ -205,10 +205,6 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Performance
                     }
                 }
             }
-
-            protected override void AbortCore(ConnectionAbortedException abortReason)
-            {
-            }
         }
 
         // Copied from https://github.com/aspnet/benchmarks/blob/dev/src/Benchmarks/Middleware/PlaintextMiddleware.cs

src/Connections.Abstractions/ConnectionContext.cs

@@ -25,5 +25,7 @@ namespace Microsoft.AspNetCore.Connections
             // ConnectioContext.Abort()
             Features.Get<IConnectionLifetimeFeature>()?.Abort();
         }
+
+        public virtual void Abort() => Abort(new ConnectionAbortedException("The connection was aborted by the application."));
     }
 }

src/Connections.Abstractions/DefaultConnectionContext.cs

@@ -65,8 +65,6 @@ namespace Microsoft.AspNetCore.Connections
 
         public CancellationToken ConnectionClosed { get; set; }
 
-        public void Abort() => Abort(abortReason: null);
-
         public override void Abort(ConnectionAbortedException abortReason)
         {
             ThreadPool.QueueUserWorkItem(cts => ((CancellationTokenSource)cts).Cancel(), _connectionClosedTokenSource);

src/Kestrel.Core/Internal/HttpConnectionMiddleware.cs

@@ -87,7 +87,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Core.Internal
                     (_, state) => ((HttpConnection)state).OnInputOrOutputCompleted(),
                     connection);
 
-                await AsTask(lifetimeFeature.ConnectionClosed);
+                await CancellationTokenAsTask(lifetimeFeature.ConnectionClosed);
 
                 connection.OnConnectionClosed();
 
@@ -99,8 +99,15 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Core.Internal
             }
         }
 
-        private Task AsTask(CancellationToken token)
+        private static Task CancellationTokenAsTask(CancellationToken token)
         {
+            if (token.IsCancellationRequested)
+            {
+                return Task.CompletedTask;
+            }
+
+            // Transports already dispatch prior to tripping ConnectionClosed
+            // since application code can register to this token.
             var tcs = new TaskCompletionSource<object>();
             token.Register(() => tcs.SetResult(null));
             return tcs.Task;

src/Kestrel.Transport.Abstractions/Internal/TransportConnection.cs

@@ -55,14 +55,15 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Transport.Abstractions.Internal
 
         public CancellationToken ConnectionClosed { get; set; }
 
-        // DO NOT remove this override to ConnectionContext.Abort(). Doing so would cause
-        // any TransportConnection that does not override Abort() or calls base.Abort()
+        // DO NOT remove this override to ConnectionContext.Abort. Doing so would cause
+        // any TransportConnection that does not override Abort or calls base.Abort
         // to stack overflow when IConnectionLifetimeFeature.Abort() is called.
+        // That said, all derived types should override this method should override
+        // this implementation of Abort because canceling pending output reads is not
+        // sufficient to abort the connection if there is backpressure.
         public override void Abort(ConnectionAbortedException abortReason)
         {
-            AbortCore(abortReason);
+            Output.CancelPendingRead();
         }
-
-        protected abstract void AbortCore(ConnectionAbortedException abortReason);
     }
 }

src/Kestrel.Transport.Libuv/Internal/LibuvConnection.cs

@@ -116,7 +116,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Transport.Libuv.Internal
             }
         }
 
-        protected override void AbortCore(ConnectionAbortedException abortReason)
+        public override void Abort(ConnectionAbortedException abortReason)
         {
             _abortReason = abortReason;
             Output.CancelPendingRead();

src/Kestrel.Transport.Sockets/Internal/SocketConnection.cs

@@ -92,7 +92,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.Transport.Sockets.Internal
             }
         }
 
-        protected override void AbortCore(ConnectionAbortedException abortReason)
+        public override void Abort(ConnectionAbortedException abortReason)
         {
             _abortReason = abortReason;
             Output.CancelPendingRead();

test/Kestrel.FunctionalTests/ResponseTests.cs

@@ -2459,7 +2459,7 @@ namespace Microsoft.AspNetCore.Server.Kestrel.FunctionalTests
                     await context.Response.Body.WriteAsync(scratchBuffer, 0, scratchBuffer.Length);
                     await Task.Delay(10);
                 }
-           
+
                 appCompletedTcs.SetResult(null);
             }, new TestServiceContext(LoggerFactory), listenOptions))
             {