aboutsummaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorChris Lu <chris.lu@gmail.com>2019-10-29 00:37:15 -0700
committerChris Lu <chris.lu@gmail.com>2019-10-29 00:37:15 -0700
commitcd7ce720c779d7bc5b8e43726e2e5ca68756774a (patch)
treea1b49c7af84b1d1b929a97d5c934639f518ff7c7
parent19b6a16003325ec93bb0e261d5a9c08cd3e03cad (diff)
downloadseaweedfs-cd7ce720c779d7bc5b8e43726e2e5ca68756774a.tar.xz
seaweedfs-cd7ce720c779d7bc5b8e43726e2e5ca68756774a.zip
fix test
-rw-r--r--weed/storage/needle/needle_read_write_test.go6
1 files changed, 5 insertions, 1 deletions
diff --git a/weed/storage/needle/needle_read_write_test.go b/weed/storage/needle/needle_read_write_test.go
index 4c507f9e6..7b05d5d10 100644
--- a/weed/storage/needle/needle_read_write_test.go
+++ b/weed/storage/needle/needle_read_write_test.go
@@ -5,6 +5,7 @@ import (
"os"
"testing"
+ "github.com/chrislusf/seaweedfs/weed/storage/backend"
"github.com/chrislusf/seaweedfs/weed/storage/types"
)
@@ -54,7 +55,10 @@ func TestAppend(t *testing.T) {
os.Remove(tempFile.Name())
}()
- offset, _, _, _ := n.Append(tempFile, CurrentVersion)
+ datBackend := backend.NewDiskFile(tempFile.Name(), tempFile)
+ defer datBackend.Close()
+
+ offset, _, _, _ := n.Append(datBackend, CurrentVersion)
if offset != uint64(fileSize) {
t.Errorf("Fail to Append Needle.")
}