From db71b8f9657a820bb64403ea50444eae3677915a Mon Sep 17 00:00:00 2001 From: iamqizhao Date: Thu, 13 Aug 2015 10:50:38 -0700 Subject: [PATCH 1/2] fix Timeout interop test --- interop/client/client.go | 4 ++++ 1 file changed, 4 insertions(+) diff --git a/interop/client/client.go b/interop/client/client.go index 335b1fef..4f9a0c42 100644 --- a/interop/client/client.go +++ b/interop/client/client.go @@ -266,6 +266,10 @@ func doTimeoutOnSleepingServer(tc testpb.TestServiceClient) { ctx, _ := context.WithTimeout(context.Background(), 1*time.Millisecond) stream, err := tc.FullDuplexCall(ctx) if err != nil { + if grpc.Code(err) == codes.DeadlineExceeded) { + grpclog.Println("TimeoutOnSleepingServer done") + return + } grpclog.Fatalf("%v.FullDuplexCall(_) = _, %v", tc, err) } pl := newPayload(testpb.PayloadType_COMPRESSABLE, 27182) From 3d7251c81c8f9503d1396186ba73dbead0987ed5 Mon Sep 17 00:00:00 2001 From: iamqizhao Date: Thu, 13 Aug 2015 10:53:48 -0700 Subject: [PATCH 2/2] minor fix --- interop/client/client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/interop/client/client.go b/interop/client/client.go index 4f9a0c42..5ee8d522 100644 --- a/interop/client/client.go +++ b/interop/client/client.go @@ -266,7 +266,7 @@ func doTimeoutOnSleepingServer(tc testpb.TestServiceClient) { ctx, _ := context.WithTimeout(context.Background(), 1*time.Millisecond) stream, err := tc.FullDuplexCall(ctx) if err != nil { - if grpc.Code(err) == codes.DeadlineExceeded) { + if grpc.Code(err) == codes.DeadlineExceeded { grpclog.Println("TimeoutOnSleepingServer done") return }