aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2018-05-09 03:50:14 -0700
committerChris Lu <chris.lu@gmail.com>2018-05-09 03:50:14 -0700
commite2c7be3a2e91056a6402fc70a979aa273c15fcd2 (patch)
tree47b8ae7fd096c2fcee32d81bb61dd1a290423f71
parent43a69d20bf724cea371da88a02bfe0b2fa02a773 (diff)
downloadseaweedfs-e2c7be3a2e91056a6402fc70a979aa273c15fcd2.tar.xz
seaweedfs-e2c7be3a2e91056a6402fc70a979aa273c15fcd2.zip
adjust the needle mapper
as discussed on https://github.com/chrislusf/seaweedfs/pull/642#issuecomment-387606960
-rw-r--r--weed/storage/needle_map_boltdb.go2
-rw-r--r--weed/storage/needle_map_leveldb.go2
2 files changed, 2 insertions, 2 deletions
diff --git a/weed/storage/needle_map_boltdb.go b/weed/storage/needle_map_boltdb.go
index cbcc786af..4492aaeff 100644
--- a/weed/storage/needle_map_boltdb.go
+++ b/weed/storage/needle_map_boltdb.go
@@ -32,7 +32,7 @@ func NewBoltDbNeedleMap(dbFileName string, indexFile *os.File) (m *BoltDbNeedleM
return
}
glog.V(1).Infof("Loading %s...", indexFile.Name())
- nm, indexLoadError := LoadBtreeNeedleMap(indexFile)
+ nm, indexLoadError := NewBoltDbNeedleMap(dbFileName, indexFile)
if indexLoadError != nil {
return nil, indexLoadError
}
diff --git a/weed/storage/needle_map_leveldb.go b/weed/storage/needle_map_leveldb.go
index 78dffaf7d..b0a4735b5 100644
--- a/weed/storage/needle_map_leveldb.go
+++ b/weed/storage/needle_map_leveldb.go
@@ -30,7 +30,7 @@ func NewLevelDbNeedleMap(dbFileName string, indexFile *os.File) (m *LevelDbNeedl
return
}
glog.V(1).Infof("Loading %s...", indexFile.Name())
- nm, indexLoadError := LoadBtreeNeedleMap(indexFile)
+ nm, indexLoadError := NewLevelDbNeedleMap(dbFileName, indexFile)
if indexLoadError != nil {
return nil, indexLoadError
}