vikarti.anatra/safing-portbase
1
0
Fork 0
mirror of https://github.com/safing/portbase synced 2025-09-01 10:09:50 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Add timeout and retrying to opening bbolt dbs

Browse source
This commit is contained in:
Daniel 2020-11-26 14:50:54 +01:00
parent 36068d8cac
commit 9c2b7d3059
1 changed files with 11 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
database/storage/bbolt/bbolt.go
View file

@ -32,8 +32,18 @@ func init() {
// NewBBolt opens/creates a bbolt database.
func NewBBolt(name, location string) (storage.Interface, error) {
// Create options for bbolt database.
dbFile := filepath.Join(location, "db.bbolt")
dbOptions := &bbolt.Options{
Timeout: 1 * time.Second,
}
db, err := bbolt.Open(filepath.Join(location, "db.bbolt"), 0600, nil)
// Open/Create database, retry if there is a timeout.
db, err := bbolt.Open(dbFile, 0600, dbOptions)
for i := 0; i < 5 && err != nil; i++ {
// Try again if there is an error.
db, err = bbolt.Open(dbFile, 0600, dbOptions)
}
if err != nil {
return nil, err
}