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

Refactoring method variable names for erasureWriter struct

Browse Source
This commit is contained in:
Frederick F. Kautz IV 2015-03-23 12:25:15 -07:00
parent 742a186d10
commit 56a298fd6a
1 changed files with 13 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
pkg/storage/donut/erasure.go
View File

@ -121,19 +121,19 @@ func erasureGoroutine(r *io.PipeReader, eWriter erasureWriter, isClosed chan<- b
isClosed <- true isClosed <- true
} }
func (d erasureWriter) Write(data []byte) (int, error) { func (eWriter erasureWriter) Write(data []byte) (int, error) {
io.Copy(d.erasureWriter, bytes.NewBuffer(data)) io.Copy(eWriter.erasureWriter, bytes.NewBuffer(data))
return len(data), nil return len(data), nil
} }
func (d erasureWriter) Close() error { func (eWriter erasureWriter) Close() error {
d.erasureWriter.Close() eWriter.erasureWriter.Close()
<-d.isClosed <-eWriter.isClosed
return nil return nil
} }
func (d erasureWriter) CloseWithError(err error) error { func (eWriter erasureWriter) CloseWithError(err error) error {
for _, writer := range d.writers { for _, writer := range eWriter.writers {
if writer != nil { if writer != nil {
writer.CloseWithError(err) writer.CloseWithError(err)
} }
@ -141,24 +141,24 @@ func (d erasureWriter) CloseWithError(err error) error {
return nil return nil
} }
func (d erasureWriter) SetMetadata(metadata map[string]string) error { func (eWriter erasureWriter) SetMetadata(metadata map[string]string) error {
for k, _ := range metadata { for k, _ := range metadata {
if strings.HasPrefix(k, "sys.") { if strings.HasPrefix(k, "sys.") {
return errors.New("Invalid key '" + k + "', cannot start with sys.'") return errors.New("Invalid key '" + k + "', cannot start with sys.'")
} }
} }
for k := range d.metadata { for k := range eWriter.metadata {
delete(d.metadata, k) delete(eWriter.metadata, k)
} }
for k, v := range metadata { for k, v := range metadata {
d.metadata[k] = v eWriter.metadata[k] = v
} }
return nil return nil
} }
func (d erasureWriter) GetMetadata() (map[string]string, error) { func (eWriter erasureWriter) GetMetadata() (map[string]string, error) {
metadata := make(map[string]string) metadata := make(map[string]string)
for k, v := range d.metadata { for k, v := range eWriter.metadata {
metadata[k] = v metadata[k] = v
} }
return metadata, nil return metadata, nil