diff options
Diffstat (limited to 'weed/util/bounded_tree/bounded_tree.go')
| -rw-r--r-- | weed/util/bounded_tree/bounded_tree.go | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/weed/util/bounded_tree/bounded_tree.go b/weed/util/bounded_tree/bounded_tree.go index 8c99ad83d..40b9c4e47 100644 --- a/weed/util/bounded_tree/bounded_tree.go +++ b/weed/util/bounded_tree/bounded_tree.go @@ -1,6 +1,8 @@ package bounded_tree import ( + "sync" + "github.com/chrislusf/seaweedfs/weed/glog" "github.com/chrislusf/seaweedfs/weed/util" ) @@ -13,6 +15,7 @@ type Node struct { type BoundedTree struct { root *Node + sync.Mutex } func NewBoundedTree() *BoundedTree { @@ -30,8 +33,8 @@ type VisitNodeFunc func(path util.FullPath) (childDirectories []string, err erro // A leaf node, which has no children, represents a directory not visited. // A non-leaf node or a non-existing node represents a directory already visited, or does not need to visit. func (t *BoundedTree) EnsureVisited(p util.FullPath, visitFn VisitNodeFunc) { - // println() - // println("EnsureVisited", p) + t.Lock() + defer t.Unlock() if t.root == nil { return |