From afb6a1dbb46a2a8793c8faa0450a2609f8e01af3 Mon Sep 17 00:00:00 2001
From: Chris Lu <chris.lu@gmail.com>
Date: Mon, 4 May 2020 20:34:26 -0700
Subject: Revert "Merge pull request #1299 from song-zhang/master"

This reverts commit 9016fa19ba4507bdf9ac0addc6d79f147c00302a, reversing
changes made to 47234760f40e4d2cea87b4a83d2178b8181598f5.
---
 weed/storage/needle/async_request.go | 55 ------------------------------------
 1 file changed, 55 deletions(-)
 delete mode 100644 weed/storage/needle/async_request.go

(limited to 'weed/storage/needle/async_request.go')

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
-}
-- 
cgit v1.2.3