diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-06-21 01:14:10 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-06-21 01:14:10 -0700 |
| commit | f88a8bda7bbc58ce14fc45235085f71a7e1831ad (patch) | |
| tree | 928f48aee4694af0b25ba4e07cdbf4ae6020d6e3 /weed/storage/erasure_coding | |
| parent | 613a2e8060c41aab7e58623b8f22b8ed87493b41 (diff) | |
| download | seaweedfs-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.go | 6 |
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) } |
