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

rename smallPath->smallWrite for consistency

Browse source
This commit is contained in:
Matt Jaffee 2019-02-27 12:47:23 -06:00
parent 088d618040
commit 7037ebf4b3
No known key found for this signature in database
GPG key ID: 08A3DFFF987B11BF
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
fragment.go
View file

@ -1729,9 +1729,9 @@ func (f *fragment) importValue(columnIDs, values []uint64, bitDepth uint, clear
}
var toSet, toClear []uint64
f.mu.RLock()
smallPath := false
smallWrite := false
if len(columnIDs)*int(bitDepth+1)+f.opN < f.MaxOpN {
smallPath = true
smallWrite = true
// TODO figure out how to avoid re-allocating these each time. Probably
// possible to store them on the fragment with a capacity based on
// MaxOpN.
@ -1740,7 +1740,7 @@ func (f *fragment) importValue(columnIDs, values []uint64, bitDepth uint, clear
}
f.mu.RUnlock()
if !smallPath {
if !smallWrite {
f.mu.Lock()
defer f.mu.Unlock()
f.storage.OpWriter = nil
@ -1751,7 +1751,7 @@ func (f *fragment) importValue(columnIDs, values []uint64, bitDepth uint, clear
for i := range columnIDs {
columnID, value := columnIDs[i], values[i]
var err error
if smallPath {
if smallWrite {
ts, tc, err := f.positionsForValue(columnID, bitDepth, value, clear)
if err != nil {
return errors.Wrap(err, "getting positions for value")
@ -1759,7 +1759,7 @@ func (f *fragment) importValue(columnIDs, values []uint64, bitDepth uint, clear
toSet = append(toSet, ts...)
toClear = append(toClear, tc...)
} else if _, err = f.importSetValue(columnID, bitDepth, value, clear); err != nil {
return errors.Wrapf(err, "setting value, smallPath:%v", smallPath)
return errors.Wrapf(err, "setting value, smallPath:%v", smallWrite)
}
}
return nil
@ -1769,7 +1769,7 @@ func (f *fragment) importValue(columnIDs, values []uint64, bitDepth uint, clear
return err
}
if smallPath {
if smallWrite {
rowSet := make(map[uint64]struct{}, bitDepth+1)
for i := uint(0); i < bitDepth+1; i++ {
rowSet[uint64(i)] = struct{}{}