From 2eb6fa3fce6f94111647e0e5135d57e91e1e3d07 Mon Sep 17 00:00:00 2001
From: "Bala.FA" <bala.gluster@gmail.com>
Date: Tue, 7 Jun 2016 07:28:43 +0530
Subject: [PATCH] cleanup: remove unused waitCloser.

---
 erasure-utils.go      |  2 +-
 erasure-waitcloser.go | 74 -------------------------------------------
 2 files changed, 1 insertion(+), 75 deletions(-)
 delete mode 100644 erasure-waitcloser.go

diff --git a/erasure-utils.go b/erasure-utils.go
index c97195351..da98a0ef6 100644
--- a/erasure-utils.go
+++ b/erasure-utils.go
@@ -53,7 +53,7 @@ func hashSum(disk StorageAPI, volume, path string, writer hash.Hash) ([]byte, er
 		if err == io.EOF {
 			break
 		}
-		if err != nil && err != io.EOF {
+		if err != nil {
 			return nil, err
 		}
 		writer.Write(buf[:n])
diff --git a/erasure-waitcloser.go b/erasure-waitcloser.go
deleted file mode 100644
index f8b1d8bba..000000000
--- a/erasure-waitcloser.go
+++ /dev/null
@@ -1,74 +0,0 @@
-/*
- * Minio Cloud Storage, (C) 2016 Minio, Inc.
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package main
-
-import (
-	"io"
-	"sync"
-)
-
-// waitCloser implements a Closer that blocks until released, this
-// prevents the writer closing one end of a pipe while making sure
-// that all data is written and committed to disk on the end.
-// Additionally this also implements Write().
-type waitCloser struct {
-	wg     *sync.WaitGroup // Waitgroup for atomicity.
-	writer io.WriteCloser  // Embedded writer.
-}
-
-// Write to the underlying writer.
-func (b *waitCloser) Write(data []byte) (int, error) {
-	return b.writer.Write(data)
-}
-
-// Close blocks until another goroutine calls Release(error). Returns
-// error code if either writer fails or Release is called with an error.
-func (b *waitCloser) Close() error {
-	err := b.writer.Close()
-	b.wg.Wait()
-	return err
-}
-
-// CloseWithError closes the writer; subsequent read to the read
-// half of the pipe will return the error err.
-func (b *waitCloser) CloseWithError(err error) error {
-	w, ok := b.writer.(*io.PipeWriter)
-	if ok {
-		return w.CloseWithError(err)
-	}
-	return err
-}
-
-// release the Close, causing it to unblock. Only call this
-// once. Calling it multiple times results in a panic.
-func (b *waitCloser) release() {
-	b.wg.Done()
-	return
-}
-
-// newWaitCloser creates a new write closer that must be
-// released by the read consumer.
-func newWaitCloser(writer io.WriteCloser) *waitCloser {
-	// Wait group for the go-routine.
-	wg := &sync.WaitGroup{}
-	// Add to the wait group to wait for.
-	wg.Add(1)
-	return &waitCloser{
-		wg:     wg,
-		writer: writer,
-	}
-}