diff options
| author | Chris Lu <chris.lu@gmail.com> | 2019-05-18 22:46:24 -0700 |
|---|---|---|
| committer | Chris Lu <chris.lu@gmail.com> | 2019-05-18 22:46:24 -0700 |
| commit | 87f63b9c08ba32e7c87553cf30f042d497f42a41 (patch) | |
| tree | 0d24cc74c37078ab1d2825408fc2ef8f2d2ccbff /weed/storage/erasure_coding/ec_encoder.go | |
| parent | 12dc6608f00811dd0a25e1d2563cc3f4b2c81c06 (diff) | |
| download | seaweedfs-87f63b9c08ba32e7c87553cf30f042d497f42a41.tar.xz seaweedfs-87f63b9c08ba32e7c87553cf30f042d497f42a41.zip | |
generate ec01~ec14, generate ecx file with sorted needle values
Diffstat (limited to 'weed/storage/erasure_coding/ec_encoder.go')
| -rw-r--r-- | weed/storage/erasure_coding/ec_encoder.go | 50 |
1 files changed, 49 insertions, 1 deletions
diff --git a/weed/storage/erasure_coding/ec_encoder.go b/weed/storage/erasure_coding/ec_encoder.go index a873b7ce5..f200297cf 100644 --- a/weed/storage/erasure_coding/ec_encoder.go +++ b/weed/storage/erasure_coding/ec_encoder.go @@ -1,9 +1,11 @@ package erasure_coding import ( + "fmt" "io" "os" + "github.com/chrislusf/seaweedfs/weed/glog" "github.com/klauspost/reedsolomon" ) @@ -14,7 +16,46 @@ const ( ErasureCodingSmallBlockSize = 1024 * 1024 // 1MB ) -func encodeData(file *os.File, enc reedsolomon.Encoder, startOffset, blockSize int64, buffers [][]byte) error { +func encodeData(file *os.File, enc reedsolomon.Encoder, startOffset, blockSize int64, buffers [][]byte, outputs []*os.File) error { + + bufferSize := int64(len(buffers[0])) + batchCount := blockSize/bufferSize + if blockSize%bufferSize!=0 { + glog.Fatalf("unexpected block size %d buffer size %d", blockSize, bufferSize) + } + + for b := int64(0); b < batchCount; b++ { + err := encodeDataOneBatch(file, enc, startOffset+b*bufferSize, blockSize, buffers, outputs) + if err != nil { + return err + } + } + + return nil +} + +func openEcFiles(baseFileName string) (files []*os.File, err error){ + for i := 0; i< DataShardsCount+ParityShardsCount; i++{ + fname := fmt.Sprintf("%s.ec%02d", baseFileName, i+1) + f, err := os.OpenFile(fname, os.O_TRUNC|os.O_CREATE|os.O_WRONLY, 0644) + if err != nil { + return files, fmt.Errorf("failed to open file %s: %v", fname, err) + } + files = append(files, f) + } + return +} + +func closeEcFiles(files []*os.File){ + for _, f := range files{ + if f != nil { + f.Close() + } + } +} + + +func encodeDataOneBatch(file *os.File, enc reedsolomon.Encoder, startOffset, blockSize int64, buffers [][]byte, outputs []*os.File) error { // read data into buffers for i := 0; i < DataShardsCount; i++ { @@ -36,5 +77,12 @@ func encodeData(file *os.File, enc reedsolomon.Encoder, startOffset, blockSize i return err } + for i := 0; i < DataShardsCount+ParityShardsCount; i++ { + _, err := outputs[i].Write(buffers[i]) + if err != nil { + return err + } + } + return nil } |
