aboutsummaryrefslogtreecommitdiff
path: root/weed
diff options
context:
space:
mode:
Diffstat (limited to 'weed')
-rw-r--r--weed/storage/store_ec.go5
1 files changed, 3 insertions, 2 deletions
diff --git a/weed/storage/store_ec.go b/weed/storage/store_ec.go
index 014a870db..8caaafc4d 100644
--- a/weed/storage/store_ec.go
+++ b/weed/storage/store_ec.go
@@ -201,8 +201,9 @@ func (s *Store) readOneEcShardInterval(needleId types.NeedleId, ecVolume *erasur
shardId, actualOffset := interval.ToShardIdAndOffset(erasure_coding.ErasureCodingLargeBlockSize, erasure_coding.ErasureCodingSmallBlockSize)
data = make([]byte, interval.Size)
if shard, found := ecVolume.FindEcVolumeShard(shardId); found {
- if n, err = shard.ReadAt(data, actualOffset); err != nil {
- if n != interval.Size {
+ var readSize int
+ if readSize, err = shard.ReadAt(data, actualOffset); err != nil {
+ if readSize != int(interval.Size) {
glog.V(0).Infof("read local ec shard %d.%d offset %d: %v", ecVolume.VolumeId, shardId, actualOffset, err)
return
}