modification for the print out information
This commit is contained in:
@ -129,10 +129,10 @@ func DoStreamingRoundTrip(tc testpb.TestServiceClient, stream testpb.TestService
|
|||||||
Payload: pl,
|
Payload: pl,
|
||||||
}
|
}
|
||||||
if err := stream.Send(req); err != nil {
|
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 {
|
if _, err := stream.Recv(); err != nil {
|
||||||
grpclog.Fatal("%v.StreamingCall(_) = _, %v: ", tc, err)
|
grpclog.Fatal("%v.StreamingCall(_) = _, %v", tc, err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@ -64,7 +64,7 @@ func runStream(b *testing.B, maxConcurrentCalls int) {
|
|||||||
tc := testpb.NewTestServiceClient(conn)
|
tc := testpb.NewTestServiceClient(conn)
|
||||||
stream, err := tc.StreamingCall(context.Background())
|
stream, err := tc.StreamingCall(context.Background())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
grpclog.Fatalf("%v.StreamingCall(_) = _,%v: ", tc, err)
|
grpclog.Fatalf("%v.StreamingCall(_) = _, %v", tc, err)
|
||||||
}
|
}
|
||||||
// Warm up connection.
|
// Warm up connection.
|
||||||
for i := 0; i < 10; i++ {
|
for i := 0; i < 10; i++ {
|
||||||
|
@ -94,7 +94,7 @@ func closeLoopStream() {
|
|||||||
s, conn, tc := buildConnection()
|
s, conn, tc := buildConnection()
|
||||||
stream, err := tc.StreamingCall(context.Background())
|
stream, err := tc.StreamingCall(context.Background())
|
||||||
if err != nil {
|
if err != nil {
|
||||||
grpclog.Fatalf("%v.StreamingCall(_) = _,%v: ", tc, err)
|
grpclog.Fatalf("%v.StreamingCall(_) = _, %v", tc, err)
|
||||||
}
|
}
|
||||||
for i := 0; i < 100; i++ {
|
for i := 0; i < 100; i++ {
|
||||||
streamCaller(tc, stream)
|
streamCaller(tc, stream)
|
||||||
|
Reference in New Issue
Block a user