Add HTTP event source logging to gRPC benchmark client (#1771)

Author: JamesNK

perf/benchmarkapps/GrpcClient/GrpcClient.csproj

@@ -21,6 +21,8 @@
       <CopyToOutputDirectory>PreserveNewest</CopyToOutputDirectory>
     </None>
 
+    <Compile Include="..\..\..\test\Shared\HttpEventSourceListener.cs" Link="HttpEventSourceListener.cs" />
+
     <PackageReference Include="Microsoft.Crank.EventSources" Version="$(MicrosoftCrankEventSourcesPackageVersion)" />
     <PackageReference Include="Microsoft.Extensions.Logging" Version="$(MicrosoftExtensionsPackageVersion)" />
     <PackageReference Include="Microsoft.Extensions.Logging.Console" Version="$(MicrosoftExtensionsPackageVersion)" />

perf/benchmarkapps/GrpcClient/Program.cs

@@ -31,6 +31,7 @@
 using Grpc.Core;
 using Grpc.Net.Client;
 using Grpc.Testing;
+using Grpc.Tests.Shared;
 using Microsoft.Crank.EventSources;
 using Microsoft.Extensions.Logging;
 
@@ -103,11 +104,27 @@ public static async Task<int> Main(string[] args)
                 BenchmarksEventSource.Measure("IsServerGC", isServerGC.ToString());
                 BenchmarksEventSource.Measure("ProcessorCount", processorCount);
 
+                HttpEventSourceListener? listener = null;
+                if (_options.LogLevel != LogLevel.None)
+                {
+                    Log($"Setting up logging. Log level: {_options.LogLevel}");
+
+                    _loggerFactory = LoggerFactory.Create(c =>
+                    {
+                        c.AddConsole();
+                        c.SetMinimumLevel(_options.LogLevel);
+                    });
+
+                    listener = new HttpEventSourceListener(_loggerFactory);
+                }
+
                 CreateChannels();
 
                 await StartScenario();
 
                 await StopJobAsync();
+
+                listener?.Dispose();
             }, new ReflectionBinder<ClientOptions>(options));
 
             Log("gRPC Client");
@@ -383,15 +400,6 @@ private static void CreateChannels()
             _latencyPerConnection = new List<List<double>>(_options.Connections);
             _latencyAverage = new List<(double sum, int count)>(_options.Connections);
 
-            if (_options.LogLevel != LogLevel.None)
-            {
-                _loggerFactory = LoggerFactory.Create(c =>
-                {
-                    c.AddConsole();
-                    c.SetMinimumLevel(_options.LogLevel);
-                });
-            }
-
             // Channel does not care about scheme
             var initialUri = _options.Url!;
             var resolvedUri = initialUri.Authority;