diff --git a/benchmark/benchmark.go b/benchmark/benchmark.go index f7b80633..0e46b56d 100644 --- a/benchmark/benchmark.go +++ b/benchmark/benchmark.go @@ -129,10 +129,10 @@ func DoStreamingRoundTrip(tc testpb.TestServiceClient, stream testpb.TestService Payload: pl, } if err := stream.Send(req); err != nil { - grpclog.Fatalf("%v.StreamingCall(_) = _, %v: ", tc, err) + grpclog.Fatalf("%v.StreamingCall(_) = _, %v", tc, err) } if _, err := stream.Recv(); err != nil { - grpclog.Fatal("%v.StreamingCall(_) = _, %v: ", tc, err) + grpclog.Fatal("%v.StreamingCall(_) = _, %v", tc, err) } } diff --git a/benchmark/benchmark_test.go b/benchmark/benchmark_test.go index f5bc32f4..f6b0c200 100644 --- a/benchmark/benchmark_test.go +++ b/benchmark/benchmark_test.go @@ -64,7 +64,7 @@ func runStream(b *testing.B, maxConcurrentCalls int) { tc := testpb.NewTestServiceClient(conn) stream, err := tc.StreamingCall(context.Background()) if err != nil { - grpclog.Fatalf("%v.StreamingCall(_) = _,%v: ", tc, err) + grpclog.Fatalf("%v.StreamingCall(_) = _, %v", tc, err) } // Warm up connection. for i := 0; i < 10; i++ { diff --git a/benchmark/client/main.go b/benchmark/client/main.go index 55ffea19..07744af4 100644 --- a/benchmark/client/main.go +++ b/benchmark/client/main.go @@ -94,7 +94,7 @@ func closeLoopStream() { s, conn, tc := buildConnection() stream, err := tc.StreamingCall(context.Background()) if err != nil { - grpclog.Fatalf("%v.StreamingCall(_) = _,%v: ", tc, err) + grpclog.Fatalf("%v.StreamingCall(_) = _, %v", tc, err) } for i := 0; i < 100; i++ { streamCaller(tc, stream)