seaweedfs/weed/util/bptree/bptree.go

package bptree

// started by copying from https://sourcegraph.com/github.com/timtadh/data-structures@master/-/tree/tree/bptree

/* A BpTree is a B+Tree with support for duplicate keys. This makes it behave as
 * a MultiMap. Additionally you can use the Range operator to select k/v in a
 * range. If from > to it will iterate backwards.
 */
type BpTree struct {
	root *BpNode
}

type loc_iterator func() (i int, leaf *BpNode, li loc_iterator)

func NewBpTree(node_size int) *BpTree {
	return &BpTree{
		root: NewLeaf(node_size, false),
	}
}

func (self *BpTree) Has(key Hashable) bool {
	if len(self.root.keys) == 0 {
		return false
	}
	j, l := self.root.get_start(key)
	return l.keys[j].Equals(key)
}

func (self *BpTree) Count(key Hashable) int {
	if len(self.root.keys) == 0 {
		return 0
	}
	j, l := self.root.get_start(key)
	count := 0
	end := false
	for !end && l.keys[j].Equals(key) {
		count++
		j, l, end = next_location(j, l)
	}
	return count
}

func (self *BpTree) Add(key Hashable, value interface{}) (err error) {
	new_root, err := self.root.put(key, value)
	if err != nil {
		return err
	}
	self.root = new_root
	return nil
}

func (self *BpTree) Replace(key Hashable, where WhereFunc, value interface{}) (err error) {
	li := self.root.forward(key, key)
	for i, leaf, next := li(); next != nil; i, leaf, next = next() {
		if where(leaf.values[i]) {
			leaf.values[i] = value
		}
	}
	return nil
}

func (self *BpTree) Find(key Hashable) (kvi KVIterator) {
	return self.Range(key, key)
}

func (self *BpTree) Range(from, to Hashable) (kvi KVIterator) {
	var li loc_iterator
	if !to.Less(from) {
		li = self.root.forward(from, to)
	} else {
		li = self.root.backward(from, to)
	}
	kvi = func() (key Hashable, value interface{}, next KVIterator) {
		var i int
		var leaf *BpNode
		i, leaf, li = li()
		if li == nil {
			return nil, nil, nil
		}
		return leaf.keys[i], leaf.values[i], kvi
	}
	return kvi
}

func (self *BpTree) RemoveWhere(key Hashable, where WhereFunc) (err error) {
	ns := self.root.NodeSize()
	new_root, err := self.root.remove(key, where)
	if err != nil {
		return err
	}
	if new_root == nil {
		self.root = NewLeaf(ns, false)
	} else {
		self.root = new_root
	}
	return nil
}

func (self *BpTree) Keys() (ki KIterator) {
	li := self.root.all()
	var prev Equatable
	ki = func() (key Hashable, next KIterator) {
		var i int
		var leaf *BpNode
		i, leaf, li = li()
		if li == nil {
			return nil, nil
		}
		if leaf.keys[i].Equals(prev) {
			return ki()
		}
		prev = leaf.keys[i]
		return leaf.keys[i], ki
	}
	return ki
}

func (self *BpTree) Values() (vi Iterator) {
	return MakeValuesIterator(self)
}

func (self *BpTree) Items() (vi KIterator) {
	return MakeItemsIterator(self)
}

func (self *BpTree) Iterate() (kvi KVIterator) {
	li := self.root.all()
	kvi = func() (key Hashable, value interface{}, next KVIterator) {
		var i int
		var leaf *BpNode
		i, leaf, li = li()
		if li == nil {
			return nil, nil, nil
		}
		return leaf.keys[i], leaf.values[i], kvi
	}
	return kvi
}

func (self *BpTree) Backward() (kvi KVIterator) {
	li := self.root.all_backward()
	kvi = func() (key Hashable, value interface{}, next KVIterator) {
		var i int
		var leaf *BpNode
		i, leaf, li = li()
		if li == nil {
			return nil, nil, nil
		}
		return leaf.keys[i], leaf.values[i], kvi
	}
	return kvi
}