aboutsummaryrefslogtreecommitdiff
path: root/weed/storage/erasure_coding/ec_encoder.go
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-06-19 22:57:14 -0700
committerChris Lu <chris.lu@gmail.com>2019-06-19 22:57:14 -0700
commit856da7aae2adefe7c25f68c792f9ed03977a4a0e (patch)
tree6a9b8dafc533d4e8f2243fb80427aee807ca6b86 /weed/storage/erasure_coding/ec_encoder.go
parent115558e5f529f119ca4ba60a45a28fc7bb8d25ae (diff)
downloadseaweedfs-856da7aae2adefe7c25f68c792f9ed03977a4a0e.tar.xz
seaweedfs-856da7aae2adefe7c25f68c792f9ed03977a4a0e.zip
ec volume support deletes
Diffstat (limited to 'weed/storage/erasure_coding/ec_encoder.go')
-rw-r--r--weed/storage/erasure_coding/ec_encoder.go6
1 files changed, 3 insertions, 3 deletions
diff --git a/weed/storage/erasure_coding/ec_encoder.go b/weed/storage/erasure_coding/ec_encoder.go
index 26130b4ba..97010a1ed 100644
--- a/weed/storage/erasure_coding/ec_encoder.go
+++ b/weed/storage/erasure_coding/ec_encoder.go
@@ -32,7 +32,7 @@ func WriteSortedEcxFile(baseFileName string) (e error) {
ecxFile, err := os.OpenFile(baseFileName+".ecx", os.O_TRUNC|os.O_CREATE|os.O_WRONLY, 0644)
if err != nil {
- return fmt.Errorf("failed to open dat file: %v", err)
+ return fmt.Errorf("failed to open ecx file: %v", err)
}
defer ecxFile.Close()
@@ -43,7 +43,7 @@ func WriteSortedEcxFile(baseFileName string) (e error) {
})
if err != nil {
- return fmt.Errorf("failed to open dat file: %v", err)
+ return fmt.Errorf("failed to visit ecx file: %v", err)
}
return nil
@@ -202,7 +202,7 @@ func encodeDatFile(remainingSize int64, err error, baseFileName string, bufferSi
outputs, err := openEcFiles(baseFileName, false)
defer closeEcFiles(outputs)
if err != nil {
- return fmt.Errorf("failed to open dat file: %v", err)
+ return fmt.Errorf("failed to open ec files %s: %v", baseFileName, err)
}
for remainingSize > largeBlockSize*DataShardsCount {