From dc66b699b0dfc7dfa5d032bee7d5b681c318221c Mon Sep 17 00:00:00 2001
From: Jeromy <jeromyj@gmail.com>
Date: Fri, 3 Oct 2014 21:36:29 +0000
Subject: [PATCH] fix writes zeroing files

---
 fuse/ipns/ipns_unix.go    | 9 +++++----
 importer/importer_test.go | 8 +++++++-
 2 files changed, 12 insertions(+), 5 deletions(-)

diff --git a/fuse/ipns/ipns_unix.go b/fuse/ipns/ipns_unix.go
index 22d344e44..4a9db2bce 100644
--- a/fuse/ipns/ipns_unix.go
+++ b/fuse/ipns/ipns_unix.go
@@ -206,7 +206,6 @@ type Node struct {
 
 	// For writing
 	dataBuf *bytes.Buffer
-	changed bool
 }
 
 func (s *Node) loadData() error {
@@ -302,18 +301,18 @@ func (n *Node) Write(req *fuse.WriteRequest, resp *fuse.WriteResponse, intr fs.I
 	if req.Offset == 0 {
 		n.dataBuf.Reset()
 		n.dataBuf.Write(req.Data)
-		n.changed = true
 		resp.Size = len(req.Data)
 	} else {
 		log.Error("Unhandled write to offset!")
+		n.dataBuf = nil
 	}
 	return nil
 }
 
 func (n *Node) Flush(req *fuse.FlushRequest, intr fs.Intr) fuse.Error {
-	log.Debug("Got flush request!")
+	log.Debug("Got flush request [%s]!", n.name)
 
-	if n.changed {
+	if n.dataBuf != nil {
 		//TODO:
 		// This operation holds everything in memory,
 		// should be changed to stream the block creation/storage
@@ -351,6 +350,8 @@ func (n *Node) Flush(req *fuse.FlushRequest, intr fs.Intr) fuse.Error {
 		fmt.Println(string(b))
 		//
 
+		n.dataBuf = nil
+
 		n.wasChanged()
 	}
 	return nil
diff --git a/importer/importer_test.go b/importer/importer_test.go
index 9fb1afa08..0a0bf3257 100644
--- a/importer/importer_test.go
+++ b/importer/importer_test.go
@@ -43,10 +43,16 @@ func TestSizeBasedSplit(t *testing.T) {
 	testFileConsistency(t, bs, 31*4095)
 }
 
+func dup(b []byte) []byte {
+	o := make([]byte, len(b))
+	copy(o, b)
+	return o
+}
+
 func testFileConsistency(t *testing.T, bs BlockSplitter, nbytes int) {
 	buf := new(bytes.Buffer)
 	io.CopyN(buf, rand.Reader, int64(nbytes))
-	should := buf.Bytes()
+	should := dup(buf.Bytes())
 	nd, err := NewDagFromReaderWithSplitter(buf, bs)
 	if err != nil {
 		t.Fatal(err)