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

Merge pull request #1379 from nagamocha3000/fix-core-26

Browse source 
Close process on fragment.openStorage error
This commit is contained in:
nagamocha3000 2021-02-03 19:18:58 +03:00 • committed by GitHub
commit 52ab7e5a99
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 14 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
fragment.go
View file

@ -2651,7 +2651,13 @@ func (f *fragment) importValueSmallWrite(tx Tx, columnIDs []uint64, values []int
}
return nil
}(); err != nil {
_ = f.openStorage(true)
errOpenStorage := f.openStorage(true)
if errOpenStorage != nil {
f.Logger.Printf("failed to import data into fragment: %v", err)
f.Logger.Printf("recovery with openStorage failed for fragment: %v", errOpenStorage)
f.Logger.Debugf("%s", debug.Stack())
os.Exit(1)
}
return err
}
rowSet := make(map[uint64]struct{}, bitDepth+1)
@ -2705,7 +2711,13 @@ func (f *fragment) importValue(tx Tx, columnIDs []uint64, values []int64, bitDep
// Flush changes in bulk back to the transaction.
return txb.Flush()
}(); err != nil {
_ = f.openStorage(true)
errOpenStorage := f.openStorage(true)
if errOpenStorage != nil {
f.Logger.Printf("failed to import data into fragment: %v", err)
f.Logger.Printf("recovery with openStorage failed for fragment: %v", errOpenStorage)
f.Logger.Debugf("%s", debug.Stack())
os.Exit(1)
}
return err
}
// Keep stats accurate. We don't call incrementOpN here because it may