aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/erasure_coding
diff options
context:
space:
mode:
authorguol-fnst <guol-fnst@fujitsu.com>2022-07-20 09:26:06 +0800
committerguol-fnst <guol-fnst@fujitsu.com>2022-07-20 17:00:40 +0800
commitac694f0c8f2b5456bd175e1288023f0bdb5b7a14 (patch)
treecfe997c93e69b35fe892fec44777b8c342ec405f /weed/storage/erasure_coding
parent91285bb51d3b95befb5aba0104f6ac83e5b07572 (diff)
downloadseaweedfs-ac694f0c8f2b5456bd175e1288023f0bdb5b7a14.tar.xz
seaweedfs-ac694f0c8f2b5456bd175e1288023f0bdb5b7a14.zip
rename parameter and reuse functions
rename milestone to watermark
Diffstat (limited to 'weed/storage/erasure_coding')
-rw-r--r--weed/storage/erasure_coding/ec_encoder.go2
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/storage/erasure_coding/ec_encoder.go b/weed/storage/erasure_coding/ec_encoder.go
index 157149865..ea331ca39 100644
--- a/weed/storage/erasure_coding/ec_encoder.go
+++ b/weed/storage/erasure_coding/ec_encoder.go
@@ -294,7 +294,7 @@ func readNeedleMap(baseFileName string) (*needle_map.MemDb, error) {
defer indexFile.Close()
cm := needle_map.NewMemDb()
- err = idx.WalkIndexFile(indexFile, func(key types.NeedleId, offset types.Offset, size types.Size) error {
+ err = idx.WalkIndexFile(indexFile, 0, func(key types.NeedleId, offset types.Offset, size types.Size) error {
if !offset.IsZero() && size != types.TombstoneFileSize {
cm.Set(key, offset, size)
} else {