Fix grpc h2load go gRPC clients (#1515)

Author: JamesNK

build/grpc-v2-scenarios.yml

@@ -97,7 +97,7 @@ steps:
           messageBody: |
             {
               "name": "benchmarksdriver2",
-              "args": [ "--application.aspnetcoreversion Latest --table GrpcBenchmarks --sql SQL_CONNECTION_STRING --session $(session) --profile ${{ parameters.profile }} --no-metadata --no-measurements --load.variables.duration ${{ parameters.duration }} --load.variables.warmup ${{ parameters.warmup }} ${{ s.arguments }} ${{ protocol.arguments }} ${{ stream.arguments }} --property scenario=unary --property payload=0" ]
+              "args": [ "--application.aspnetcoreversion Latest --table GrpcBenchmarks --sql SQL_CONNECTION_STRING --session $(session) --profile ${{ parameters.profile }} --no-metadata --no-measurements --load.variables.duration ${{ parameters.duration }} --load.variables.warmup ${{ parameters.warmup }} ${{ s.arguments }} ${{ protocol.arguments }} ${{ stream.arguments }} --property scenario=unary --property payload=0 --variable body=AAAAAAcKBVdvcmxk --variable path=/grpc.testing.BenchmarkService/UnaryCall" ]	
             }
 - ${{ each s in parameters.scenarios }}:
   - ${{ each callType in parameters.callTypes }}:

src/BenchmarksApps/Grpc/GoClient/grpc-go-client.yml

@@ -7,6 +7,7 @@ jobs:
       dockerContextDirectory: src/BenchmarksApps/Grpc/GoClient/
       dockerFile: src/BenchmarksApps/Grpc/GoClient/Dockerfile
     readyStateText: gRPC Client
+    waitForExit: true
     variables:
       connections: 1
       warmup: 5
@@ -27,5 +28,7 @@ jobs:
       WARMUP: '{{warmup}}'
       REQUEST_SIZE: '{{requestSize}}'
       RESPONSE_SIZE: '{{responseSize}}'
+      #GRPC_GO_LOG_VERBOSITY_LEVEL: 99
+      #GRPC_GO_LOG_SEVERITY_LEVEL: info
     options:
       requiredOperatingSystem: linux

src/BenchmarksApps/Grpc/GoClient/main.go

@@ -86,6 +86,8 @@ func main() {
 		opts = append(opts, grpc.WithInsecure())
 	}
 
+	opts = append(opts, grpc.WithBlock())
+
 	// Create connections and related collections
 	buildConnections(context.Background(), opts)
 
@@ -115,6 +117,8 @@ func main() {
 		runWithConn(connectionID, cc)
 	}
 	// Wait for caller threads to finish
+
+	fmt.Print("Waiting for caller threads to finish\n")
 	finishedWg.Wait()
 
 	fmt.Print("Caller threads finished\n")

src/BenchmarksDriver2/benchmarks.grpc.yml

@@ -78,16 +78,22 @@ scenarios:
       job: grpcAspNetCoreServer
     load:
       job: h2LoadClient
+      variables:
+        presetHeaders: grpc
   grpccoreserver-h2loadclient:
     application:
       job: grpcCoreServer
     load:
       job: h2LoadClient
+      variables:
+        presetHeaders: grpc
   grpcgoserver-h2loadclient:
     application:
       job: grpcGoServer
     load:
       job: h2LoadClient
+      variables:
+        presetHeaders: grpc
 
 profiles:
   aspnet-physical-lin:

src/H2LoadClient/Program.cs

@@ -64,6 +64,11 @@ static async Task Main(string[] args)
                     Console.WriteLine($"Header: {key}={value}");
                 }
 
+                if (Headers.Count == 0)
+                {
+                    Console.WriteLine("No headers");
+                }
+
                 if (optionBody.HasValue())
                 {
                     var requestBody = Convert.FromBase64String(optionBody.Value());
@@ -77,11 +82,14 @@ static async Task Main(string[] args)
                 }
 
                 var process = StartProcess();
+
+                Console.WriteLine("Waiting for process exit");
                 process.WaitForExit();
 
                 // Wait for all Output messages to be flushed and available in Output
                 await Task.Delay(100);
 
+                Console.WriteLine("Parsing output");
                 ParseOutput();
             });
 

src/H2LoadClient/h2load.yml

@@ -22,7 +22,8 @@ jobs:
       duration: 15
       warmup: 5
       protocol: h2c
+      body: ''
       presetHeaders: none
-    arguments: "-c {{connections}} -t {{threads}} -m {{streams}} -d {{duration}} -w {{warmup}} -u {{serverUri}}:{{serverPort}}{{path}} -p {{ protocol }} {{headers[presetHeaders]}} {% if body != null %} --body {{ body }} {% endif %}"
+    arguments: "-c {{connections}} -t {{threads}} -m {{streams}} -d {{duration}} -w {{warmup}} -u {{serverUri}}:{{serverPort}}{{path}} -p {{ protocol }} {{headers[presetHeaders]}} {% if body != '' %} --body {{ body }} {% endif %}"
     options:
       requiredOperatingSystem: linux