scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-08-28 10:54:59 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Move repair logic to helpers

Browse source
This commit is contained in:
Richard Artoul 2018-11-29 11:31:54 -05:00
parent 50f119df4e
commit d78e2fc87c
2 changed files with 20 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
roaring/containers.go
View file

@ -156,6 +156,14 @@ func (sc *sliceContainers) Iterator(key uint64) (citer ContainerIterator, found
return &sliceIterator{e: sc, i: i}, found
}
func (sc *sliceContainers) Repair() {
for _, c := range sc.containers {
if c.isBitmap() {
c.bitmapRepair()
}
}
}
type sliceIterator struct {
e *sliceContainers
i int

23
roaring/roaring.go
View file

@ -100,6 +100,9 @@ type Containers interface {
Count() uint64
// Repair will n values after in-place operations.
Repair()
//Reset will clear the containers collection to allow for recycling during snapshot
Reset()
}
@ -567,17 +570,7 @@ func (b *Bitmap) unionIntoTarget(target *Bitmap, others ...*Bitmap) {
}
// Repair bitmaps after the fact
iter, _ := target.Containers.Iterator(0)
for iter.Next() {
_, container := iter.Value()
if container.isBitmap() {
n := int32(0)
for i := 0; i < bitmapN; i++ {
n += int32(popcount(container.bitmap[i]))
}
container.n = n
}
}
target.Containers.Repair()
}
// Difference returns the difference of b and other.
@ -1981,6 +1974,14 @@ func (c *Container) check() error {
return a
}
func (c *Container) bitmapRepair() {
n := int32(0)
for i := 0; i < bitmapN; i++ {
n += int32(popcount(c.bitmap[i]))
}
c.n = n
}
// containerInfo represents a point-in-time snapshot of container stats.
type containerInfo struct {
Key uint64 // container key