From d01bb650b375e40e16237e70c304cb8b12c7bd47 Mon Sep 17 00:00:00 2001 From: Jeromy Date: Thu, 15 Feb 2018 16:44:18 -0800 Subject: [PATCH] dont use bitswap session for cat just yet License: MIT Signed-off-by: Jeromy --- core/coreapi/unixfs.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/core/coreapi/unixfs.go b/core/coreapi/unixfs.go index 435fff309..2138fa299 100644 --- a/core/coreapi/unixfs.go +++ b/core/coreapi/unixfs.go @@ -6,7 +6,6 @@ import ( coreiface "github.com/ipfs/go-ipfs/core/coreapi/interface" coreunix "github.com/ipfs/go-ipfs/core/coreunix" - dag "github.com/ipfs/go-ipfs/merkledag" uio "github.com/ipfs/go-ipfs/unixfs/io" cid "gx/ipfs/QmcZfnkapfECQGcLZaf9B79NRg7cRa9EnZh4LSbkCzwNvY/go-cid" @@ -31,14 +30,14 @@ func (api *UnixfsAPI) Add(ctx context.Context, r io.Reader) (coreiface.Path, err // Cat returns the data contained by an IPFS or IPNS object(s) at path `p`. func (api *UnixfsAPI) Cat(ctx context.Context, p coreiface.Path) (coreiface.Reader, error) { - ses := dag.NewSession(ctx, api.node.DAG) + dget := api.node.DAG // TODO: use a session here once routing perf issues are resolved - dagnode, err := resolveNode(ctx, ses, api.node.Namesys, p) + dagnode, err := resolveNode(ctx, dget, api.node.Namesys, p) if err != nil { return nil, err } - r, err := uio.NewDagReader(ctx, dagnode, ses) + r, err := uio.NewDagReader(ctx, dagnode, dget) if err == uio.ErrIsDir { return nil, coreiface.ErrIsDir } else if err != nil {