opensource/grpc-go
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

interop test: Expect io.EOF from stream.Send() (#1858)

Browse Source
This commit is contained in:
Menghan Li
2018-02-12 14:41:34 -08:00
committed by GitHub
parent 08d626137c
commit 6c48c7f5c8
1 changed files with 2 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
interop/test_utils.go
View File

@ -241,10 +241,8 @@ func DoTimeoutOnSleepingServer(tc testpb.TestServiceClient, args ...grpc.CallOpt
ResponseType: testpb.PayloadType_COMPRESSABLE, ResponseType: testpb.PayloadType_COMPRESSABLE,
Payload: pl, Payload: pl,
} }
if err := stream.Send(req); err != nil { if err := stream.Send(req); err != nil && err != io.EOF {
if status.Code(err) != codes.DeadlineExceeded { grpclog.Fatalf("%v.Send(_) = %v", stream, err)
grpclog.Fatalf("%v.Send(_) = %v", stream, err)
}
} }
if _, err := stream.Recv(); status.Code(err) != codes.DeadlineExceeded { if _, err := stream.Recv(); status.Code(err) != codes.DeadlineExceeded {
grpclog.Fatalf("%v.Recv() = _, %v, want error code %d", stream, err, codes.DeadlineExceeded) grpclog.Fatalf("%v.Recv() = _, %v, want error code %d", stream, err, codes.DeadlineExceeded)