From 00f87e5bb5b95f1568bcba4876d33e11e8eef1b1 Mon Sep 17 00:00:00 2001
From: chrislu <chris.lu@gmail.com>
Date: Fri, 28 Jun 2024 14:54:39 -0700
Subject: [PATCH] remove unused

---
 weed/remote_storage/traverse_bfs.go | 62 -----------------------------
 1 file changed, 62 deletions(-)
 delete mode 100644 weed/remote_storage/traverse_bfs.go

diff --git a/weed/remote_storage/traverse_bfs.go b/weed/remote_storage/traverse_bfs.go
deleted file mode 100644
index 983555f6c..000000000
--- a/weed/remote_storage/traverse_bfs.go
+++ /dev/null
@@ -1,62 +0,0 @@
-package remote_storage
-
-import (
-	"github.com/seaweedfs/seaweedfs/weed/pb/filer_pb"
-	"github.com/seaweedfs/seaweedfs/weed/util"
-	"sync"
-	"time"
-)
-
-type ListDirectoryFunc func(parentDir util.FullPath, visitFn VisitFunc) error
-
-func TraverseBfs(listDirFn ListDirectoryFunc, parentPath util.FullPath, visitFn VisitFunc) (err error) {
-	K := 5
-
-	var dirQueueWg sync.WaitGroup
-	dirQueue := util.NewQueue()
-	dirQueueWg.Add(1)
-	dirQueue.Enqueue(parentPath)
-	var isTerminating bool
-
-	for i := 0; i < K; i++ {
-		go func() {
-			for {
-				if isTerminating {
-					break
-				}
-				t := dirQueue.Dequeue()
-				if t == nil {
-					time.Sleep(329 * time.Millisecond)
-					continue
-				}
-				dir := t.(util.FullPath)
-				processErr := processOneDirectory(listDirFn, dir, visitFn, dirQueue, &dirQueueWg)
-				if processErr != nil {
-					err = processErr
-				}
-				dirQueueWg.Done()
-			}
-		}()
-	}
-
-	dirQueueWg.Wait()
-	isTerminating = true
-	return
-
-}
-
-func processOneDirectory(listDirFn ListDirectoryFunc, parentPath util.FullPath, visitFn VisitFunc, dirQueue *util.Queue, dirQueueWg *sync.WaitGroup) error {
-
-	return listDirFn(parentPath, func(dir string, name string, isDirectory bool, remoteEntry *filer_pb.RemoteEntry) error {
-		if err := visitFn(dir, name, isDirectory, remoteEntry); err != nil {
-			return err
-		}
-		if !isDirectory {
-			return nil
-		}
-		dirQueueWg.Add(1)
-		dirQueue.Enqueue(parentPath.Child(name))
-		return nil
-	})
-
-}