Skip to content

Commit 856c5da

Browse files
committed
[rpc] defer Stop ticker for GC
1 parent 565ff53 commit 856c5da

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

rpc/common.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -136,6 +136,7 @@ func GetGroupControllerCapabilities(ctx context.Context, conn *grpc.ClientConn)
136136
func ProbeForever(ctx context.Context, conn *grpc.ClientConn, singleProbeTimeout time.Duration) error {
137137
logger := klog.FromContext(ctx)
138138
ticker := time.NewTicker(probeInterval)
139+
defer ticker.Stop()
139140

140141
for {
141142
select {

0 commit comments

Comments
 (0)