some fix

Signed-off-by: roc <[email protected]>

Author: imroc

charts/tke-extend-network-controller/values.yaml

@@ -25,7 +25,7 @@ concurrency:
   dedicatedClbListenerController: 30
   podController: 30
   nodeController: 30
-  clbPortPoolController: 1
+  clbPortPoolController: 10
   dedicatedClbServiceController: 1
 
 # -- Logging otpions of the controller

internal/controller/clbportpool_controller.go

@@ -22,6 +22,7 @@ import (
 	"reflect"
 	"strings"
 
+	portpoolutil "github.com/imroc/tke-extend-network-controller/internal/portpool/util"
 	"github.com/pkg/errors"
 	corev1 "k8s.io/api/core/v1"
 	"k8s.io/apimachinery/pkg/runtime"
@@ -267,6 +268,10 @@ func (r *CLBPortPoolReconciler) ensureLb(ctx context.Context, pool *networkingv1
 
 // 同步端口池
 func (r *CLBPortPoolReconciler) sync(ctx context.Context, pool *networkingv1alpha1.CLBPortPool) (result ctrl.Result, err error) {
+	// 确保分配器缓存中存在该 port pool，放在最开头，避免同时创建 CLBPortPool 和 CLBBinding 导致分配端口时找不到 pool
+	if !portpool.Allocator.IsPoolExists(pool.Name) { // 分配器缓存中不存在，则添加
+		portpool.Allocator.EnsurePool(portpoolutil.NewPortPool(pool, r.Client, r.Recorder))
+	}
 	// 初始化状态
 	if pool.Status.State == "" {
 		pool.Status.State = networkingv1alpha1.CLBPortPoolStatePending

pkg/clb/error.go

@@ -9,7 +9,7 @@ func IsLbIdNotFoundError(err error) bool {
 }
 
 func IsLoadBalancerNotExistsError(err error) bool {
-	return strings.Contains(err.Error(), "LoadBalancer not exist")
+	return strings.Contains(err.Error(), "LoadBalancer not exist") || strings.Contains(err.Error(), "LB not exist")
 }
 
 func IsRequestLimitExceededError(err error) bool {