diff --git a/weed/remote_storage/hdfs/hdfs_storage_client.go b/weed/remote_storage/hdfs/hdfs_storage_client.go
index e4d7dcb44..5b4ce0b29 100644
--- a/weed/remote_storage/hdfs/hdfs_storage_client.go
+++ b/weed/remote_storage/hdfs/hdfs_storage_client.go
@@ -66,7 +66,7 @@ var _ = remote_storage.RemoteStorageClient(&hdfsRemoteStorageClient{})
 
 func (c *hdfsRemoteStorageClient) Traverse(loc *remote_pb.RemoteStorageLocation, visitFn remote_storage.VisitFunc) (err error) {
 
-	return TraverseBfs(func(parentDir util.FullPath, visitFn remote_storage.VisitFunc) error {
+	return remote_storage.TraverseBfs(func(parentDir util.FullPath, visitFn remote_storage.VisitFunc) error {
 		children, err := c.client.ReadDir(string(parentDir))
 		if err != nil {
 			return err
diff --git a/weed/remote_storage/hdfs/traverse_bfs.go b/weed/remote_storage/traverse_bfs.go
similarity index 78%
rename from weed/remote_storage/hdfs/traverse_bfs.go
rename to weed/remote_storage/traverse_bfs.go
index 755771283..4056f8715 100644
--- a/weed/remote_storage/hdfs/traverse_bfs.go
+++ b/weed/remote_storage/traverse_bfs.go
@@ -1,16 +1,15 @@
-package hdfs
+package remote_storage
 
 import (
 	"github.com/chrislusf/seaweedfs/weed/pb/filer_pb"
-	"github.com/chrislusf/seaweedfs/weed/remote_storage"
 	"github.com/chrislusf/seaweedfs/weed/util"
 	"sync"
 	"time"
 )
 
-type ListDirectoryFunc func(parentDir util.FullPath, visitFn remote_storage.VisitFunc) error
+type ListDirectoryFunc func(parentDir util.FullPath, visitFn VisitFunc) error
 
-func TraverseBfs(listDirFn ListDirectoryFunc, parentPath util.FullPath, visitFn remote_storage.VisitFunc) (err error) {
+func TraverseBfs(listDirFn ListDirectoryFunc, parentPath util.FullPath, visitFn VisitFunc) (err error) {
 	K := 5
 
 	var dirQueueWg sync.WaitGroup
@@ -46,7 +45,7 @@ func TraverseBfs(listDirFn ListDirectoryFunc, parentPath util.FullPath, visitFn
 
 }
 
-func processOneDirectory(listDirFn ListDirectoryFunc, parentPath util.FullPath, visitFn remote_storage.VisitFunc, dirQueue *util.Queue, dirQueueWg *sync.WaitGroup) (error) {
+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 {