aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/erasure_coding
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-06-21 01:14:10 -0700
committerChris Lu <chris.lu@gmail.com>2019-06-21 01:14:10 -0700
commitf88a8bda7bbc58ce14fc45235085f71a7e1831ad (patch)
tree928f48aee4694af0b25ba4e07cdbf4ae6020d6e3 /weed/storage/erasure_coding
parent613a2e8060c41aab7e58623b8f22b8ed87493b41 (diff)
downloadseaweedfs-f88a8bda7bbc58ce14fc45235085f71a7e1831ad.tar.xz
seaweedfs-f88a8bda7bbc58ce14fc45235085f71a7e1831ad.zip
ec deletion works
Diffstat (limited to 'weed/storage/erasure_coding')
-rw-r--r--weed/storage/erasure_coding/ec_volume.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/storage/erasure_coding/ec_volume.go b/weed/storage/erasure_coding/ec_volume.go
index a83a44f27..bcae164ca 100644
--- a/weed/storage/erasure_coding/ec_volume.go
+++ b/weed/storage/erasure_coding/ec_volume.go
@@ -172,9 +172,9 @@ func (ev *EcVolume) ToVolumeEcShardInformationMessage() (messages []*master_pb.V
func (ev *EcVolume) LocateEcShardNeedle(needleId types.NeedleId, version needle.Version) (offset types.Offset, size uint32, intervals []Interval, err error) {
// find the needle from ecx file
- offset, size, err = ev.findNeedleFromEcx(needleId)
+ offset, size, err = ev.FindNeedleFromEcx(needleId)
if err != nil {
- return types.Offset{}, 0, nil, fmt.Errorf("findNeedleFromEcx: %v", err)
+ return types.Offset{}, 0, nil, fmt.Errorf("FindNeedleFromEcx: %v", err)
}
shard := ev.Shards[0]
@@ -185,7 +185,7 @@ func (ev *EcVolume) LocateEcShardNeedle(needleId types.NeedleId, version needle.
return
}
-func (ev *EcVolume) findNeedleFromEcx(needleId types.NeedleId) (offset types.Offset, size uint32, err error) {
+func (ev *EcVolume) FindNeedleFromEcx(needleId types.NeedleId) (offset types.Offset, size uint32, err error) {
return searchNeedleFromEcx(ev.ecxFile, ev.ecxFileSize, needleId, nil)
}