Don't exit while synchronizing calico ippool
Signed-off-by: Duan Jiong <djduanjiong@gmail.com>
This commit is contained in:
@@ -339,12 +339,14 @@ func (c *IPPoolController) processIPPoolItem() bool {
|
||||
if err == nil {
|
||||
c.ippoolQueue.Forget(key)
|
||||
return true
|
||||
} else if delay != nil {
|
||||
c.ippoolQueue.AddAfter(key, *delay)
|
||||
}
|
||||
|
||||
if delay != nil {
|
||||
c.ippoolQueue.AddAfter(key, *delay)
|
||||
} else {
|
||||
c.ippoolQueue.AddRateLimited(key)
|
||||
}
|
||||
utilruntime.HandleError(fmt.Errorf("error processing ippool %v (will retry): %v", key, err))
|
||||
c.ippoolQueue.AddRateLimited(key)
|
||||
return true
|
||||
}
|
||||
|
||||
|
||||
@@ -695,9 +695,16 @@ func NewProvider(podInformer informercorev1.PodInformer, ksclient kubesphereclie
|
||||
})
|
||||
p.block = blockI
|
||||
|
||||
if err := p.syncIPPools(); err != nil {
|
||||
klog.Fatalf("failed to sync calico ippool to kubesphere ippool, err=%v", err)
|
||||
}
|
||||
go func() {
|
||||
for {
|
||||
if err := p.syncIPPools(); err != nil {
|
||||
klog.Infof("failed to sync calico ippool to kubesphere ippool, err=%v", err)
|
||||
time.Sleep(3 * time.Second)
|
||||
continue
|
||||
}
|
||||
break
|
||||
}
|
||||
}()
|
||||
|
||||
return p
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user