|
|
@ -6,7 +6,6 @@ import ( |
|
|
|
"errors" |
|
|
|
"errors" |
|
|
|
"io" |
|
|
|
"io" |
|
|
|
"io/ioutil" |
|
|
|
"io/ioutil" |
|
|
|
"log" |
|
|
|
|
|
|
|
"os" |
|
|
|
"os" |
|
|
|
"path" |
|
|
|
"path" |
|
|
|
"sort" |
|
|
|
"sort" |
|
|
@ -162,7 +161,6 @@ func erasureReader(readers []io.ReadCloser, donutMetadata map[string]string, wri |
|
|
|
if blockSize < totalLeft { |
|
|
|
if blockSize < totalLeft { |
|
|
|
curBlockSize = blockSize |
|
|
|
curBlockSize = blockSize |
|
|
|
} |
|
|
|
} |
|
|
|
log.Println("decoding block size", curBlockSize) |
|
|
|
|
|
|
|
decodedData, err := encoder.Decode(encodedBytes, curBlockSize) |
|
|
|
decodedData, err := encoder.Decode(encodedBytes, curBlockSize) |
|
|
|
if err != nil { |
|
|
|
if err != nil { |
|
|
|
writer.CloseWithError(err) |
|
|
|
writer.CloseWithError(err) |
|
|
|