leveldb recover error handling

weed/filer2/leveldb/leveldb_store.go

@@ -53,9 +53,11 @@ func (store *LevelDBStore) initialize(dir string) (err error) {
 		if errors.IsCorrupted(err) {
 			store.db, err = leveldb.RecoverFile(dir, opts)
 		}
+		if err != nil {
 			glog.Infof("filer store open dir %s: %v", dir, err)
 			return
 		}
+	}
 	return
 }
 

weed/storage/needle_map_leveldb.go

@@ -38,8 +38,10 @@ func NewLevelDbNeedleMap(dbFileName string, indexFile *os.File, opts *opt.Option
 		if errors.IsCorrupted(err) {
 			m.db, err = leveldb.RecoverFile(dbFileName, opts)
 		}
+		if err != nil {
 			return
 		}
+	}
 	glog.V(1).Infof("Loading %s...", indexFile.Name())
 	mm, indexLoadError := newNeedleMapMetricFromIndexFile(indexFile)
 	if indexLoadError != nil {