Skip to content

Commit bbff059

Browse files
committed
make sure listener cleanup
Signed-off-by: roc <[email protected]>
1 parent 23c2b27 commit bbff059

File tree

1 file changed

+8
-0
lines changed

1 file changed

+8
-0
lines changed

internal/controller/clbbinding.go

Lines changed: 8 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -238,10 +238,18 @@ func (r *CLBBindingReconciler[T]) ensureListener(ctx context.Context, bd clbbind
238238
pool := portpool.Allocator.GetPool(binding.Pool)
239239
if pool == nil { // 端口池不存在,移除 binding 并并记录事件
240240
r.Recorder.Event(bd.GetObject(), corev1.EventTypeWarning, "PortPoolDeleted", fmt.Sprintf("port pool has been deleted (%s/%s/%d)", binding.Pool, binding.LoadbalancerId, binding.LoadbalancerPort))
241+
// 确保监听器被清理
242+
if err := r.cleanupPortBinding(ctx, binding); err != nil {
243+
return binding, errors.WithStack(err)
244+
}
241245
return nil, nil
242246
} else {
243247
if !pool.IsLbExists(portpool.NewLBKeyFromBinding(binding)) { // lb 被删除,移除 binding 并记录到事件
244248
r.Recorder.Event(bd.GetObject(), corev1.EventTypeWarning, "CLBDeleted", fmt.Sprintf("clb has been deleted (%s/%s/%d)", binding.Pool, binding.LoadbalancerId, binding.LoadbalancerPort))
249+
// 确保监听器被清理
250+
if err := r.cleanupPortBinding(ctx, binding); err != nil {
251+
return binding, errors.WithStack(err)
252+
}
245253
return nil, nil
246254
}
247255
}

0 commit comments

Comments
 (0)