Merge pull request #18369 from dotnet/jkotalik/merge31

Merge 2.1 into 3.1

Author: John Luo

src/Security/Authentication/OpenIdConnect/samples/OpenIdConnectSample/Startup.cs

@@ -35,7 +35,7 @@ public Startup(IConfiguration config, IWebHostEnvironment env)
 
         private void CheckSameSite(HttpContext httpContext, CookieOptions options)
         {
-            if (options.SameSite > SameSiteMode.Unspecified)
+            if (options.SameSite == SameSiteMode.None)
             {
                 var userAgent = httpContext.Request.Headers["User-Agent"];
                 // TODO: Use your User Agent library of choice here.

src/Security/Authentication/test/WsFederation/WsFederationTest.cs

@@ -1,4 +1,4 @@
-// Copyright (c) .NET Foundation. All rights reserved.
+// Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
 
 using System;
@@ -440,4 +440,4 @@ protected override Task<HttpResponseMessage> SendAsync(HttpRequestMessage reques
             }
         }
     }
-}
+}

src/SignalR/common/Http.Connections/src/Internal/TaskExtensions.cs

@@ -1,6 +1,8 @@
 // Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
+
 using System.Runtime.CompilerServices;
+
 namespace System.Threading.Tasks
 {
     internal static class TaskExtensions
@@ -21,4 +23,4 @@ public static async Task NoThrow(this Task task)
         public void OnCompleted(Action continuation) => _task.GetAwaiter().OnCompleted(continuation);
         public void UnsafeOnCompleted(Action continuation) => OnCompleted(continuation);
     }
-}
+}

src/SignalR/common/Http.Connections/src/Internal/Transports/LongPollingServerTransport.cs

@@ -40,24 +40,24 @@ public async Task ProcessRequestAsync(HttpContext context, CancellationToken tok
                 var result = await _application.ReadAsync(token);
                 var buffer = result.Buffer;
 
-                if (buffer.IsEmpty && (result.IsCompleted || result.IsCanceled))
+                try
                 {
-                    Log.LongPolling204(_logger);
-                    context.Response.ContentType = "text/plain";
-                    context.Response.StatusCode = StatusCodes.Status204NoContent;
-                    return;
-                }
+                    if (buffer.IsEmpty && (result.IsCompleted || result.IsCanceled))
+                    {
+                        Log.LongPolling204(_logger);
+                        context.Response.ContentType = "text/plain";
+                        context.Response.StatusCode = StatusCodes.Status204NoContent;
+                        return;
+                    }
 
-                // We're intentionally not checking cancellation here because we need to drain messages we've got so far,
-                // but it's too late to emit the 204 required by being canceled.
+                    // We're intentionally not checking cancellation here because we need to drain messages we've got so far,
+                    // but it's too late to emit the 204 required by being canceled.
 
-                Log.LongPollingWritingMessage(_logger, buffer.Length);
+                    Log.LongPollingWritingMessage(_logger, buffer.Length);
 
-                context.Response.ContentLength = buffer.Length;
-                context.Response.ContentType = "application/octet-stream";
+                    context.Response.ContentLength = buffer.Length;
+                    context.Response.ContentType = "application/octet-stream";
 
-                try
-                {
                     _connection?.StartSendCancellation();
                     await context.Response.Body.WriteAsync(buffer, _connection?.SendingToken ?? default);
                 }

src/SignalR/common/Http.Connections/test/HttpConnectionDispatcherTests.cs

@@ -1098,7 +1098,6 @@ public override async Task WriteAsync(byte[] buffer, int offset, int count, Canc
                 await _sync.WaitToContinue();
                 cancellationToken.ThrowIfCancellationRequested();
             }
-#if NETCOREAPP2_1
             public override async ValueTask WriteAsync(ReadOnlyMemory<byte> buffer, CancellationToken cancellationToken = default)
             {
                 if (_isSSE)
@@ -1110,7 +1109,6 @@ public override async ValueTask WriteAsync(ReadOnlyMemory<byte> buffer, Cancella
                 await _sync.WaitToContinue();
                 cancellationToken.ThrowIfCancellationRequested();
             }
-#endif
         }
 
         [Fact]

src/SignalR/common/Shared/PipeWriterStream.cs

@@ -74,7 +74,6 @@ private ValueTask WriteCoreAsync(ReadOnlyMemory<byte> source, CancellationToken
 
             _length += source.Length;
             var task = _pipeWriter.WriteAsync(source);
-
             if (task.IsCompletedSuccessfully)
             {
                 // Cancellation can be triggered by PipeWriter.CancelPendingFlush

src/SignalR/common/testassets/Tests.Utils/VerifyNoErrorsScope.cs

@@ -1,4 +1,4 @@
-// Copyright (c) .NET Foundation. All rights reserved.
+// Copyright (c) .NET Foundation. All rights reserved.
 // Licensed under the Apache License, Version 2.0. See License.txt in the project root for license information.
 
 using System;
@@ -62,4 +62,4 @@ public void Dispose()
             }
         }
     }
-}
+}

src/SignalR/server/Core/src/HubConnectionContext.cs

@@ -318,6 +318,7 @@ private ValueTask TryWritePingAsync()
                 return default;
             }
 
+            // TODO: cancel?
             return new ValueTask(TryWritePingSlowAsync());
         }