scriptoriumadmin/featurebase
1
0
Fork 0
mirror of https://github.com/featurebasedb/featurebase.git synced 2026-09-15 08:41:02 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

comment cleanup and removed long test

Browse source
This commit is contained in:
Todd Gruben 2022-02-25 16:40:04 -06:00
parent d85ac1dca7
commit 0ed85d6d69
2 changed files with 1 additions and 66 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
boltdb/translate.go
View file

@ -450,7 +450,7 @@ func (r *TranslateEntryReader) Close() error {
return nil
}
// ReadEntry reads th next entry from the underlying translate store.
// ReadEntry reads the next entry from the underlying translate store.
func (r *TranslateEntryReader) ReadEntry(entry *pilosa.TranslateEntry) error {
// Ensure reader has not been closed before read.
select {

65
dbshard_internal_test.go
View file

@ -3,7 +3,6 @@ package pilosa
import (
"fmt"
"math/rand"
"os"
"path/filepath"
"strings"
@ -297,67 +296,3 @@ func Test_DBPerShard_GetFieldView2Shards_map_from_RBF(t *testing.T) {
panic(fmt.Sprintf("expected '%v' but got view2shard '%v'", exp, view2shard))
}
}
func TestTXBigDelete(t *testing.T) {
if _, ok := os.LookupEnv("GAUNTLET"); !ok {
t.Skip("only running this test if GAUNTLET is set")
}
f, idx, tx := mustOpenFragment(t, "i", "f", viewStandard, 0, "")
_ = idx
defer f.Clean(t)
result := make(map[uint64]struct{})
var set, none []uint64
accum := uint64(0)
N := 1000000
fmt.Println("build big set")
rand.Seed(0)
for i := 0; i < N; i++ {
bd := rand.Intn(15)
accum += uint64(bd)
for row := uint64(0); row < uint64(rand.Intn(10)); row++ {
pos, _ := f.pos(row, accum)
set = append(set, pos)
}
}
fmt.Println("set")
err := f.importPositions(tx, set, none, result)
PanicOn(err)
PanicOn(tx.Commit())
// Close and reopen the fragment & verify the data.
fmt.Println("repopen")
err = f.Reopen() // roaring data not being flushed? red on roaring
if err != nil {
t.Fatal(err)
}
fmt.Println("clear")
tx = idx.holder.txf.NewTx(Txo{Write: writable, Index: idx, Fragment: f, Shard: f.shard})
row, er := f.row(tx, 5)
PanicOn(er)
fmt.Println(row.Count())
cols := row.Columns()
subset := make([]uint64, len(cols))
for i := range cols {
pos, e := f.pos(5, cols[i])
PanicOn(e)
subset[i] = pos
}
PanicOn(f.importPositions(tx, none, subset, result))
row, er = f.row(tx, 5)
PanicOn(er)
fmt.Println(row.Count())
PanicOn(tx.Commit())
fmt.Println("reopen")
err = f.Reopen() // roaring data not being flushed? red on roaring
if err != nil {
t.Fatal(err)
}
tx = idx.holder.txf.NewTx(Txo{Write: !writable, Index: idx, Fragment: f, Shard: f.shard})
row, er = f.row(tx, 5)
PanicOn(er)
fmt.Println("delete count should be 0", row.Count())
row, er = f.row(tx, 2)
PanicOn(er)
fmt.Println(row.Count())
}