sync: list another prefix when finsh one (#5646)

juicedata · Feb 14, 2025 · 39afff4 · 39afff4
1 parent 330985e
commit 39afff4
Showing 1 changed file with 8 additions and 15 deletions.
diff --git a/pkg/sync/sync.go b/pkg/sync/sync.go
@@ -1373,23 +1373,16 @@ func startProducer(tasks chan<- object.Object, src, dst object.ObjectStorage, pr
 				logger.Infof("ignore prefix %s", c.Key())
 				continue
 			}
-			select {
-			case config.concurrentList <- 1:
-				wg.Add(1)
-				go func(prefix string) {
-					defer wg.Done()
-					err := startProducer(tasks, src, dst, prefix, listDepth-1, config)
-					if err != nil {
-						logger.Fatalf("list prefix %s: %s", prefix, err)
-					}
-					<-config.concurrentList
-				}(c.Key())
-			default:
-				err := startProducer(tasks, src, dst, c.Key(), listDepth-1, config)
+			wg.Add(1)
+			go func(prefix string) {
+				defer wg.Done()
+				err := startProducer(tasks, src, dst, prefix, listDepth-1, config)
 				if err != nil {
-					logger.Fatalf("list prefix %s: %s", c.Key(), err)
+					logger.Fatalf("list prefix %s: %s", prefix, err)
 				}
-			}
+				<-config.concurrentList
+			}(c.Key())
+			config.concurrentList <- 1
 		}
 	}()