minor fix
This commit is contained in:
@ -266,7 +266,7 @@ func doTimeoutOnSleepingServer(tc testpb.TestServiceClient) {
|
|||||||
ctx, _ := context.WithTimeout(context.Background(), 1*time.Millisecond)
|
ctx, _ := context.WithTimeout(context.Background(), 1*time.Millisecond)
|
||||||
stream, err := tc.FullDuplexCall(ctx)
|
stream, err := tc.FullDuplexCall(ctx)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
if grpc.Code(err) == codes.DeadlineExceeded) {
|
if grpc.Code(err) == codes.DeadlineExceeded {
|
||||||
grpclog.Println("TimeoutOnSleepingServer done")
|
grpclog.Println("TimeoutOnSleepingServer done")
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user