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

Merge pull request #107 from safing/fix/retry-bbolt-opening

Browse source 
Add timeout and retrying to opening bbolt dbs
This commit is contained in:
Patrick Pacher 2020-11-26 15:34:30 +01:00 • committed by GitHub
commit 81a4f109e4
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
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
}