diff --git a/pkg/compute/models/cloudproviderregions.go b/pkg/compute/models/cloudproviderregions.go index de84ba62c9..7d87b895c1 100644 --- a/pkg/compute/models/cloudproviderregions.go +++ b/pkg/compute/models/cloudproviderregions.go @@ -457,7 +457,7 @@ func (self *SCloudproviderregion) getSyncTaskKey() string { } } -func (self *SCloudproviderregion) submitSyncTask(ctx context.Context, userCred mcclient.TokenCredential, syncRange SSyncRange, waitChan chan bool) { +func (self *SCloudproviderregion) submitSyncTask(ctx context.Context, userCred mcclient.TokenCredential, syncRange SSyncRange) { self.markStartSync(userCred) RunSyncCloudproviderRegionTask(ctx, self.getSyncTaskKey(), func() { nopanic.Run(func() { @@ -467,9 +467,6 @@ func (self *SCloudproviderregion) submitSyncTask(ctx context.Context, userCred m log.Errorf("DoSync faild %v", err) } }) - if waitChan != nil { - waitChan <- true - } }) } diff --git a/pkg/compute/models/cloudproviders.go b/pkg/compute/models/cloudproviders.go index 3f8b4307d2..23bd5754d4 100644 --- a/pkg/compute/models/cloudproviders.go +++ b/pkg/compute/models/cloudproviders.go @@ -1413,14 +1413,11 @@ func (provider *SCloudprovider) syncCloudproviderRegions(ctx context.Context, us for i := range cprs { if cprs[i].Enabled && cprs[i].CanSync() && (!autoSync || cprs[i].needAutoSync()) && (len(regionIds) == 0 || utils.IsInStringArray(cprs[i].CloudregionId, regionIds)) { syncCnt += 1 - var waitChan chan bool = nil if wg != nil { wg.Add(1) - waitChan = make(chan bool) } - cprs[i].submitSyncTask(ctx, userCred, syncRange, waitChan) + cprs[i].submitSyncTask(ctx, userCred, syncRange) if wg != nil { - <-waitChan wg.Done() } }