aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/erasure_coding/ec_decoder.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2020-11-27 03:17:10 -0800
committerChris Lu <chris.lu@gmail.com>2020-11-27 03:17:10 -0800
commit6d30b21b10260c8c0f2c9f665a3d907494566092 (patch)
treeb2509c87ee0cb5eb373d8c3fabc4fd1ac53c7af5 /weed/storage/erasure_coding/ec_decoder.go
parent3c229eb677a9aedd4e59f511f10aa4ba552f821b (diff)
downloadseaweedfs-6d30b21b10260c8c0f2c9f665a3d907494566092.tar.xz
seaweedfs-6d30b21b10260c8c0f2c9f665a3d907494566092.zip
volume: add "-dir.idx" option for separate index storage
fix https://github.com/chrislusf/seaweedfs/issues/1265
Diffstat (limited to 'weed/storage/erasure_coding/ec_decoder.go')
-rw-r--r--weed/storage/erasure_coding/ec_decoder.go8
1 files changed, 4 insertions, 4 deletions
diff --git a/weed/storage/erasure_coding/ec_decoder.go b/weed/storage/erasure_coding/ec_decoder.go
index 795a7d523..bc86d9c04 100644
--- a/weed/storage/erasure_coding/ec_decoder.go
+++ b/weed/storage/erasure_coding/ec_decoder.go
@@ -45,14 +45,14 @@ func WriteIdxFileFromEcIndex(baseFileName string) (err error) {
// FindDatFileSize calculate .dat file size from max offset entry
// there may be extra deletions after that entry
// but they are deletions anyway
-func FindDatFileSize(baseFileName string) (datSize int64, err error) {
+func FindDatFileSize(dataBaseFileName, indexBaseFileName string) (datSize int64, err error) {
- version, err := readEcVolumeVersion(baseFileName)
+ version, err := readEcVolumeVersion(dataBaseFileName)
if err != nil {
- return 0, fmt.Errorf("read ec volume %s version: %v", baseFileName, err)
+ return 0, fmt.Errorf("read ec volume %s version: %v", dataBaseFileName, err)
}
- err = iterateEcxFile(baseFileName, func(key types.NeedleId, offset types.Offset, size types.Size) error {
+ err = iterateEcxFile(indexBaseFileName, func(key types.NeedleId, offset types.Offset, size types.Size) error {
if size.IsDeleted() {
return nil