diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-06-19 22:57:14 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-06-19 22:57:14 -0700 |
| commit | 856da7aae2adefe7c25f68c792f9ed03977a4a0e (patch) | |
| tree | 6a9b8dafc533d4e8f2243fb80427aee807ca6b86 /weed/storage/erasure_coding/ec_encoder.go | |
| parent | 115558e5f529f119ca4ba60a45a28fc7bb8d25ae (diff) | |
| download | seaweedfs-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.go | 6 |
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 { |
