提交 eea6921f 作者: Juan Batiz-Benet

Merge pull request #1242 from ipfs/perf/add

remove unnecessary flush, and buffer output channel
...@@ -91,7 +91,7 @@ remains to be implemented. ...@@ -91,7 +91,7 @@ remains to be implemented.
progress, _, _ := req.Option(progressOptionName).Bool() progress, _, _ := req.Option(progressOptionName).Bool()
wrap, _, _ := req.Option(wrapOptionName).Bool() wrap, _, _ := req.Option(wrapOptionName).Bool()
outChan := make(chan interface{}) outChan := make(chan interface{}, 8)
res.SetOutput((<-chan interface{})(outChan)) res.SetOutput((<-chan interface{})(outChan))
go func() { go func() {
...@@ -219,11 +219,6 @@ func add(n *core.IpfsNode, reader io.Reader) (*dag.Node, error) { ...@@ -219,11 +219,6 @@ func add(n *core.IpfsNode, reader io.Reader) (*dag.Node, error) {
return nil, err return nil, err
} }
err = n.Pinning.Flush()
if err != nil {
return nil, err
}
return node, nil return node, nil
} }
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论