diff options
| -rw-r--r-- | weed/storage/erasure_coding/ec_volume.go | 7 |
1 files changed, 3 insertions, 4 deletions
diff --git a/weed/storage/erasure_coding/ec_volume.go b/weed/storage/erasure_coding/ec_volume.go index ed3ce4e2f..f0b662752 100644 --- a/weed/storage/erasure_coding/ec_volume.go +++ b/weed/storage/erasure_coding/ec_volume.go @@ -3,14 +3,13 @@ package erasure_coding import ( "errors" "fmt" - "github.com/seaweedfs/seaweedfs/weed/glog" "math" "os" + "slices" "sync" "time" - "slices" - + "github.com/seaweedfs/seaweedfs/weed/glog" "github.com/seaweedfs/seaweedfs/weed/pb" "github.com/seaweedfs/seaweedfs/weed/pb/master_pb" "github.com/seaweedfs/seaweedfs/weed/pb/volume_server_pb" @@ -263,7 +262,7 @@ func SearchNeedleFromSortedIndex(ecxFile *os.File, ecxFileSize int64, needleId t key, offset, size = idx.IdxFileEntry(buf) if key == needleId { if processNeedleFn != nil { - err = processNeedleFn(ecxFile, m*types.NeedleHeaderSize) + err = processNeedleFn(ecxFile, m*types.NeedleMapEntrySize) } return } |