fix bug : should drain channel of timer after stop (#612)

grpc-ecosystem · Aug 14, 2023 · a53adc7 · a53adc7
1 parent 36583ea
commit a53adc7
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/interceptors/retry/retry.go b/interceptors/retry/retry.go
@@ -260,7 +260,9 @@ func waitRetryBackoff(attempt uint, parentCtx context.Context, callOpts *options
 		timer := time.NewTimer(waitTime)
 		select {
 		case <-parentCtx.Done():
-			timer.Stop()
+			if !timer.Stop() {
+				<-timer.C
+			}
 			return contextErrToGrpcErr(parentCtx.Err())
 		case <-timer.C:
 		}