aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2022-03-27 22:26:12 -0700
committerGitHub <noreply@github.com>2022-03-27 22:26:12 -0700
commit0edbc8785762b018cc1011a0cc0a93858c74d841 (patch)
treeffb9a3f9322118f1150dd957b3797da506941a95
parent0490ee87efa25ecb77b71d5f7b08d539195db8c4 (diff)
parentd51a724101e9259eaa95e0dda91d2cdc3899e414 (diff)
downloadseaweedfs-0edbc8785762b018cc1011a0cc0a93858c74d841.tar.xz
seaweedfs-0edbc8785762b018cc1011a0cc0a93858c74d841.zip
Merge pull request #2827 from leyou240/master
fix: encode small chunk return error maybe have some bug.
-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 34b639407..157149865 100644
--- a/weed/storage/erasure_coding/ec_encoder.go
+++ b/weed/storage/erasure_coding/ec_encoder.go
@@ -220,7 +220,7 @@ func encodeDatFile(remainingSize int64, err error, baseFileName string, bufferSi
processedSize += largeBlockSize * DataShardsCount
}
for remainingSize > 0 {
- encodeData(file, enc, processedSize, smallBlockSize, buffers, outputs)
+ err = encodeData(file, enc, processedSize, smallBlockSize, buffers, outputs)
if err != nil {
return fmt.Errorf("failed to encode small chunk data: %v", err)
}