MyFavMirrors/minio
1
0
Fork 0
mirror of https://github.com/minio/minio.git synced 2025-01-23 20:53:18 -05:00
Code Issues Packages Projects Releases Wiki Activity

get erros from buffered channel. Return error during object read only if we have readers < k

Browse Source
This commit is contained in:
Krishna Srinivas 2015-07-29 19:36:41 +05:30
parent e1280779ed
commit bdc00624fd
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/donut/bucket.go
View File

@ -544,23 +544,31 @@ func (b bucket) decodeEncodedData(totalLeft, blockSize int64, readers map[int]io
} }
encodedBytes := make([][]byte, encoder.k+encoder.m) encodedBytes := make([][]byte, encoder.k+encoder.m)
errCh := make(chan error) errCh := make(chan error, len(readers))
var errRet error var errRet error
readCnt := 0
for i, reader := range readers { for i, reader := range readers {
go func(i int, reader io.Reader) { i := i
reader := reader
go func() {
encodedBytes[i] = make([]byte, curChunkSize) encodedBytes[i] = make([]byte, curChunkSize)
_, err := io.ReadFull(reader, encodedBytes[i]) _, err := io.ReadFull(reader, encodedBytes[i])
if err != nil {
encodedBytes[i] = nil
}
errCh <- err errCh <- err
}(i, reader) }()
} }
for range readers { for range readers {
err := <-errCh err := <-errCh
if err != nil { if err != nil {
errRet = err errRet = err
} else {
readCnt++
} }
} }
if errRet != nil { if readCnt < int(encoder.k) {
return nil, iodine.New(errRet, nil) return nil, iodine.New(errRet, nil)
} }
decodedData, err := encoder.Decode(encodedBytes, int(curBlockSize)) decodedData, err := encoder.Decode(encodedBytes, int(curBlockSize))