Revert "Merge pull request #1299 from song-zhang/master"

This reverts commit 9016fa19ba4507bdf9ac0addc6d79f147c00302a, reversing
changes made to 47234760f40e4d2cea87b4a83d2178b8181598f5.

1 files changed, 0 insertions, 55 deletions

diff --git a/weed/storage/needle/async_request.go b/weed/storage/needle/async_request.go
deleted file mode 100644
index 259419115..000000000
--- a/weed/storage/needle/async_request.go
+++ /dev/null
@@ -1,55 +0,0 @@
-package needle
-
-type AsyncRequest struct {
-	N              *Needle
-	IsWriteRequest bool
-	ActualSize     int64
-	Fsync          bool
-	offset         uint64
-	size           uint64
-	doneChan       chan interface{}
-	isUnchanged    bool
-	err            error
-}
-
-func NewAsyncRequest(n *Needle, isWriteRequest bool, fsync bool) *AsyncRequest {
-	return &AsyncRequest{
-		offset:         0,
-		size:           0,
-		ActualSize:     0,
-		doneChan:       make(chan interface{}),
-		N:              n,
-		isUnchanged:    false,
-		IsWriteRequest: isWriteRequest,
-		Fsync:          fsync,
-		err:            nil,
-	}
-}
-
-func (r *AsyncRequest) WaitComplete() (uint64, uint64, bool, error) {
-	<-r.doneChan
-	return r.offset, r.size, r.isUnchanged, r.err
-}
-
-func (r *AsyncRequest) Complete(offset uint64, size uint64, isUnchanged bool, err error) {
-	r.offset = offset
-	r.size = size
-	r.isUnchanged = isUnchanged
-	r.err = err
-	close(r.doneChan)
-}
-
-func (r *AsyncRequest) UpdateResult(offset uint64, size uint64, isUnchanged bool, err error) {
-	r.offset = offset
-	r.size = size
-	r.isUnchanged = isUnchanged
-	r.err = err
-}
-
-func (r *AsyncRequest) Submit() {
-	close(r.doneChan)
-}
-
-func (r *AsyncRequest) IsSucceed() bool {
-	return r.err == nil
-}