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

check for existence of badger db in recover

Browse Source
This commit is contained in:
vyzo 2022-01-30 11:44:27 +02:00
parent d140909562
commit a4c1a34163
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
blockstore/splitstore/markset_badger.go
View File

@ -70,6 +70,10 @@ func (e *BadgerMarkSetEnv) New(name string, sizeHint int64) (MarkSet, error) {
func (e *BadgerMarkSetEnv) Recover(name string) (MarkSet, error) { func (e *BadgerMarkSetEnv) Recover(name string) (MarkSet, error) {
path := filepath.Join(e.path, name) path := filepath.Join(e.path, name)
if _, err := os.Stat(path); err != nil {
return nil, xerrors.Errorf("error stating badger db path: %w", err)
}
db, err := openBadgerDB(path, true) db, err := openBadgerDB(path, true)
if err != nil { if err != nil {
return nil, xerrors.Errorf("error creating badger db: %w", err) return nil, xerrors.Errorf("error creating badger db: %w", err)
@ -359,8 +363,6 @@ func (s *BadgerMarkSet) Close() error {
return closeBadgerDB(db, s.path, s.persist) return closeBadgerDB(db, s.path, s.persist)
} }
func (s *BadgerMarkSet) SetConcurrent() {}
func openBadgerDB(path string, recover bool) (*badger.DB, error) { func openBadgerDB(path string, recover bool) (*badger.DB, error) {
// if it is not a recovery, clean up first // if it is not a recovery, clean up first
if !recover { if !recover {