0
0

fix errcheck issues

This commit is contained in:
Marty Schoch 2017-12-05 13:32:57 -05:00
parent ece27ef215
commit 898a6b1e85
2 changed files with 25 additions and 7 deletions

View File

@ -438,18 +438,36 @@ func persistStored(memSegment *mem.Segment, tx *bolt.Tx) error {
// process each value // process each value
for i := 0; i < num; i++ { for i := 0; i < num; i++ {
// encode field // encode field
metaEncoder.PutU64(uint64(fieldID)) _, err2 := metaEncoder.PutU64(uint64(fieldID))
if err2 != nil {
return err2
}
// encode type // encode type
metaEncoder.PutU64(uint64(memSegment.StoredTypes[docNum][uint16(fieldID)][i])) _, err2 = metaEncoder.PutU64(uint64(memSegment.StoredTypes[docNum][uint16(fieldID)][i]))
if err2 != nil {
return err2
}
// encode start offset // encode start offset
metaEncoder.PutU64(uint64(curr)) _, err2 = metaEncoder.PutU64(uint64(curr))
if err2 != nil {
return err2
}
// end len // end len
metaEncoder.PutU64(uint64(len(storedFieldValues[i]))) _, err2 = metaEncoder.PutU64(uint64(len(storedFieldValues[i])))
if err2 != nil {
return err2
}
// encode number of array pos // encode number of array pos
metaEncoder.PutU64(uint64(len(memSegment.StoredPos[docNum][uint16(fieldID)][i]))) _, err2 = metaEncoder.PutU64(uint64(len(memSegment.StoredPos[docNum][uint16(fieldID)][i])))
if err2 != nil {
return err2
}
// encode all array positions // encode all array positions
for j := 0; j < len(memSegment.StoredPos[docNum][uint16(fieldID)][i]); j++ { for j := 0; j < len(memSegment.StoredPos[docNum][uint16(fieldID)][i]); j++ {
metaEncoder.PutU64(memSegment.StoredPos[docNum][uint16(fieldID)][i][j]) _, err2 = metaEncoder.PutU64(memSegment.StoredPos[docNum][uint16(fieldID)][i][j])
if err2 != nil {
return err2
}
} }
// append data // append data
data = append(data, storedFieldValues[i]...) data = append(data, storedFieldValues[i]...)

View File

@ -25,7 +25,7 @@ import (
) )
func TestBuild(t *testing.T) { func TestBuild(t *testing.T) {
os.RemoveAll("/tmp/scorch.bolt") _ = os.RemoveAll("/tmp/scorch.bolt")
memSegment := buildMemSegment() memSegment := buildMemSegment()
err := persistSegment(memSegment, "/tmp/scorch.bolt", 1024) err := persistSegment(memSegment, "/tmp/scorch.bolt", 1024)