feat: skip in deleting ips and networks

Author: cheina97

pkg/ipam/initialize.go

@@ -25,6 +25,8 @@ import (
 // +kubebuilder:rbac:groups=ipam.liqo.io,resources=networks,verbs=get;list;watch
 
 func (lipam *LiqoIPAM) initialize(ctx context.Context) error {
+	lipam.mutex.Lock()
+	defer lipam.mutex.Unlock()
 	klog.Info("Initializing IPAM")
 
 	if err := lipam.initializeNetworks(ctx); err != nil {

pkg/ipam/ips.go

@@ -93,6 +93,11 @@ func (lipam *LiqoIPAM) listIPsOnCluster(ctx context.Context, cl client.Client) (
 	for i := range ipList.Items {
 		ip := &ipList.Items[i]
 
+		deleting := !ip.GetDeletionTimestamp().IsZero()
+		if deleting {
+			continue
+		}
+
 		address := ip.Status.IP.String()
 		if address == "" {
 			klog.Warningf("IP %q has no address", ip.Name)

pkg/ipam/networks.go

@@ -92,6 +92,11 @@ func (lipam *LiqoIPAM) listNetworksOnCluster(ctx context.Context, cl client.Clie
 	for i := range networks.Items {
 		net := &networks.Items[i]
 
+		deleting := !net.GetDeletionTimestamp().IsZero()
+		if deleting {
+			continue
+		}
+
 		cidr := net.Status.CIDR.String()
 		if cidr == "" {
 			continue

pkg/ipam/sync.go

@@ -39,6 +39,8 @@ func (lipam *LiqoIPAM) sync(ctx context.Context, syncFrequency time.Duration) {
 
 	err := wait.PollUntilContextCancel(ctx, syncFrequency, false,
 		func(ctx context.Context) (done bool, err error) {
+			lipam.mutex.Lock()
+			defer lipam.mutex.Unlock()
 			klog.Info("Started IPAM cache sync routine")
 
 			// Sync networks.