fix(adder): because we now have VisConfig as a possible field in data…

…set, we need to make another channel available to the adder (from 8 to 9). Fixed in both ipfs and memfs
qri-io · Feb 2, 2018 · aef9d08 · aef9d08
1 parent 4055c2f
commit aef9d08
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 5 deletions.
diff --git a/ipfs/filestore.go b/ipfs/filestore.go
@@ -179,8 +179,8 @@ func (fs *Filestore) NewAdder(pin, wrap bool) (cafs.Adder, error) {
 		return nil, fmt.Errorf("error allocating adder: %s", err.Error())
 	}
 
-	outChan := make(chan interface{}, 8)
-	added := make(chan cafs.AddedFile, 8)
+	outChan := make(chan interface{}, 9)
+	added := make(chan cafs.AddedFile, 9)
 	a.Out = outChan
 	a.Pin = pin
 	a.Wrap = wrap
@@ -243,7 +243,7 @@ func (fs *Filestore) AddPath(path string, pin bool) (hash string, err error) {
 		return
 	}
 
-	outChan := make(chan interface{}, 8)
+	outChan := make(chan interface{}, 9)
 	defer close(outChan)
 
 	fileAdder.Out = outChan
@@ -303,7 +303,7 @@ func (fs *Filestore) AddFile(file cafs.File, pin bool) (hash string, err error)
 	}
 
 	errChan := make(chan error, 0)
-	outChan := make(chan interface{}, 8)
+	outChan := make(chan interface{}, 9)
 
 	fileAdder.Out = outChan
 

diff --git a/memfs/mem_filestore.go b/memfs/mem_filestore.go
@@ -118,7 +118,7 @@ func (m MapStore) Delete(key datastore.Key) error {
 }
 
 func (m MapStore) NewAdder(pin, wrap bool) (cafs.Adder, error) {
-	addedOut := make(chan cafs.AddedFile, 8)
+	addedOut := make(chan cafs.AddedFile, 9)
 	return &adder{
 		mapstore: m,
 		out:      addedOut,