diff --git a/benchmark/benchmark.go b/benchmark/benchmark.go index 83d5f5bd8..f7b806333 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 76e996886..f5bc32f42 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 fdb322332..55ffea19c 100644 --- a/benchmark/client/main.go +++ b/benchmark/client/main.go @@ -21,7 +21,10 @@ var ( server = flag.String("server", "", "The server address") maxConcurrentRPCs = flag.Int("max_concurrent_rpcs", 1, "The max number of concurrent RPCs") duration = flag.Int("duration", math.MaxInt32, "The duration in seconds to run the benchmark client") - rpcType = flag.Int("rpc_type", 0, "client rpc type") + rpcType = flag.Int("rpc_type", 0, + `Configure different client rpc type. Valid options are: + 0 : unary call; + 1 : streaming call.`) ) func unaryCaller(client testpb.TestServiceClient) { @@ -91,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)