Unit test event counters and update to latest SDK (#415)

Author: JamesNK

Grpc.DotNet.sln

@@ -68,6 +68,7 @@ Project("{2150E333-8FDC-42A3-9474-1A3956D46DE8}") = "Proto", "Proto", "{BF1393D4
 		testassets\Proto\nested.proto = testassets\Proto\nested.proto
 		testassets\Proto\singleton.proto = testassets\Proto\singleton.proto
 		testassets\Proto\streaming.proto = testassets\Proto\streaming.proto
+		testassets\Proto\unimplemented.proto = testassets\Proto\unimplemented.proto
 	EndProjectSection
 EndProject
 Project("{9A19103F-16F7-4668-BE54-9A1E7A4F7556}") = "FunctionalTestsWebsite", "testassets\FunctionalTestsWebsite\FunctionalTestsWebsite.csproj", "{7B95289B-4992-4C0D-B26F-8EC58F81FC96}"

global.json

@@ -1,5 +1,5 @@
 {
   "sdk": {
-    "version": "3.0.100-preview8-013421"
+    "version": "3.0.100-preview8-013532"
   }
 }

perf/Grpc.AspNetCore.Microbenchmarks/Grpc.AspNetCore.Microbenchmarks.csproj

@@ -13,7 +13,7 @@
     <Protobuf Include=".\Proto\chat.proto" GrpcServices="Server" />
 
     <Compile Include="..\..\test\Shared\TestRequestBodyPipeFeature.cs" Link="Internal\TestRequestBodyPipeFeature.cs" />
-    <Compile Include="..\..\test\Shared\TestResponseBodyPipeFeature.cs" Link="Internal\TestResponseBodyPipeFeature.cs" />
+    <Compile Include="..\..\test\Shared\TestResponseBodyFeature.cs" Link="Internal\TestResponseBodyFeature.cs" />
 
     <FrameworkReference Include="Microsoft.AspNetCore.App" />
 

perf/Grpc.AspNetCore.Microbenchmarks/UnaryServerCallHandlerBenchmarkBase.cs

@@ -86,7 +86,7 @@ public void GlobalSetup()
             _httpContext.Request.ContentType = GrpcProtocolConstants.GrpcContentType;
 
             _httpContext.Features.Set<IRequestBodyPipeFeature>(new TestRequestBodyPipeFeature(_requestPipe));
-            _httpContext.Features.Set<IResponseBodyPipeFeature>(new TestResponseBodyPipeFeature(new TestPipeWriter()));
+            _httpContext.Features.Set<IHttpResponseBodyFeature>(new TestResponseBodyFeature(new TestPipeWriter()));
             _httpContext.Features.Set<IHttpResponseTrailersFeature>(new TestHttpResponseTrailersFeature
             {
                 Trailers = _trailers

src/Grpc.AspNetCore.Server/Internal/GrpcEventSource.cs

@@ -48,6 +48,17 @@ internal GrpcEventSource()
         {
         }
 
+        [NonEvent]
+        internal void ResetCounters()
+        {
+            _totalCalls = 0;
+            _currentCalls = 0;
+            _messageSent = 0;
+            _messageReceived = 0;
+            _callsFailed = 0;
+            _callsDeadlineExceeded = 0;
+        }
+
         // Used for testing
         internal GrpcEventSource(string eventSourceName)
             : base(eventSourceName)

src/Grpc.AspNetCore.Server/Internal/HttpContextServerCallContext.cs

@@ -432,7 +432,7 @@ private async Task DeadlineExceededAsync()
 
                 // Immediately send remaining response content and trailers
                 // If feature is null then reset/abort will still end request, but response won't have trailers
-                var completionFeature = HttpContext.Features.Get<IHttpResponseCompletionFeature>();
+                var completionFeature = HttpContext.Features.Get<IHttpResponseBodyFeature>();
                 if (completionFeature != null)
                 {
                     await completionFeature.CompleteAsync();

src/Grpc.Net.Client/Grpc.Net.Client.csproj

@@ -11,6 +11,13 @@
     <VersionPrefix>$(GrpcDotnetVersion)</VersionPrefix>
   </PropertyGroup>
 
+  <ItemGroup>
+    <KnownFrameworkReference Update="NETStandard.Library">
+      <!-- TODO(JamesNK): Recent .NET bits seems to have a general issue related to netstandard2.1 https://github.com/dotnet/sdk/pull/3463 -->
+      <RuntimeFrameworkName>NETStandard.Library</RuntimeFrameworkName>
+    </KnownFrameworkReference>
+  </ItemGroup>
+  
   <PropertyGroup>
     <!-- Include PDB in the built .nupkg -->
     <AllowedOutputExtensionsInPackageBuildOutputFolder>$(AllowedOutputExtensionsInPackageBuildOutputFolder);.pdb</AllowedOutputExtensionsInPackageBuildOutputFolder>

src/Grpc.Net.Client/HttpClientCallInvoker.cs

@@ -54,6 +54,7 @@ public HttpClientCallInvoker(HttpClient client, ILoggerFactory? loggerFactory)
         }
 
         internal Uri BaseAddress => _client.BaseAddress;
+        internal bool DisableClientDeadlineTimer { get; set; }
 
         /// <summary>
         /// Gets or sets the maximum message size in bytes that can be sent from the client.

src/Grpc.Net.Client/Internal/GrpcCall.cs

@@ -454,7 +454,7 @@ private async Task StartAsync(HttpClient client, HttpRequestMessage request)
         {
             using (StartScope())
             {
-                if (_timeout != null)
+                if (_timeout != null && !CallInvoker.DisableClientDeadlineTimer)
                 {
                     Log.StartingDeadlineTimeout(Logger, _timeout.Value);
 

src/Grpc.Net.Client/Internal/GrpcEventSource.cs

@@ -52,6 +52,17 @@ internal GrpcEventSource(string eventSourceName)
         {
         }
 
+        [NonEvent]
+        internal void ResetCounters()
+        {
+            _totalCalls = 0;
+            _currentCalls = 0;
+            _messageSent = 0;
+            _messageReceived = 0;
+            _callsFailed = 0;
+            _callsDeadlineExceeded = 0;
+        }
+
         [MethodImpl(MethodImplOptions.NoInlining)]
         [Event(eventId: 1, Level = EventLevel.Verbose)]
         public void CallStart(string method)