Merge pull request #999 from iamqizhao/interop

fix the flakiness of timeout_on_sleeping_server interop test
This commit is contained in:
Menghan Li
2016-11-23 12:59:59 -08:00
committed by GitHub

View File

@ -254,7 +254,9 @@ func DoTimeoutOnSleepingServer(tc testpb.TestServiceClient) {
Payload: pl,
}
if err := stream.Send(req); err != nil {
grpclog.Fatalf("%v.Send(%v) = %v", stream, req, err)
if grpc.Code(err) != codes.DeadlineExceeded {
grpclog.Fatalf("%v.Send(_) = %v", stream, err)
}
}
if _, err := stream.Recv(); grpc.Code(err) != codes.DeadlineExceeded {
grpclog.Fatalf("%v.Recv() = _, %v, want error code %d", stream, err, codes.DeadlineExceeded)