cerc-io/lotus
10
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

fsrepo: check dsErr before returning datastore

Browse Source
This commit is contained in:
Łukasz Magiera 2019-07-11 13:48:21 +02:00
parent 1f97ad2c2e
commit ffafc056ee
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
node/repo/fsrepo.go
View File

@ -148,7 +148,10 @@ func (fsr *fsLockedRepo) Datastore(ns string) (datastore.Batching, error) {
fsr.dsOnce.Do(func() { fsr.dsOnce.Do(func() {
fsr.ds, fsr.dsErr = badger.NewDatastore(fsr.join(fsDatastore), nil) fsr.ds, fsr.dsErr = badger.NewDatastore(fsr.join(fsDatastore), nil)
}) })
return namespace.Wrap(fsr.ds, datastore.NewKey(ns)), fsr.dsErr if fsr.dsErr != nil {
return nil, fsr.dsErr
}
return namespace.Wrap(fsr.ds, datastore.NewKey(ns)), nil
} }
func (fsr *fsLockedRepo) Config() (*config.Root, error) { func (fsr *fsLockedRepo) Config() (*config.Root, error) {