From 3246b0fe79d222137853de55bfef5fe55a804c7f Mon Sep 17 00:00:00 2001
From: chestack <wangbo_bupt@163.com>
Date: Thu, 14 Jul 2022 14:54:06 +0800
Subject: [PATCH] Get latest vpc data from apiserver instead of cache

---
 pkg/controller/init.go | 4 ++--
 pkg/controller/vpc.go  | 3 ++-
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/pkg/controller/init.go b/pkg/controller/init.go
index 6c5e3c92884..a494e4e359e 100644
--- a/pkg/controller/init.go
+++ b/pkg/controller/init.go
@@ -205,13 +205,13 @@ func (c *Controller) initClusterRouter() error {
 
 // InitLoadBalancer init the default tcp and udp cluster loadbalancer
 func (c *Controller) initLoadBalancer() error {
-	vpcs, err := c.vpcsLister.List(labels.Everything())
+	vpcs, err := c.config.KubeOvnClient.KubeovnV1().Vpcs().List(context.Background(), metav1.ListOptions{})
 	if err != nil {
 		klog.Errorf("failed to list vpc: %v", err)
 		return err
 	}
 
-	for _, orivpc := range vpcs {
+	for _, orivpc := range vpcs.Items {
 		vpc := orivpc.DeepCopy()
 		vpcLb := c.GenVpcLoadBalancer(vpc.Name)
 
diff --git a/pkg/controller/vpc.go b/pkg/controller/vpc.go
index a234ca25acf..fde0b09d723 100644
--- a/pkg/controller/vpc.go
+++ b/pkg/controller/vpc.go
@@ -291,7 +291,8 @@ func (c *Controller) addLoadBalancer(vpc string) (*VpcLoadBalancer, error) {
 }
 
 func (c *Controller) handleAddOrUpdateVpc(key string) error {
-	orivpc, err := c.vpcsLister.Get(key)
+	// get latest vpc info
+	orivpc, err := c.config.KubeOvnClient.KubeovnV1().Vpcs().Get(context.Background(), key, metav1.GetOptions{})
 	if err != nil {
 		if k8serrors.IsNotFound(err) {
 			return nil