opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-06-30 01:52:26 +08:00
Code Issues Projects Releases Wiki Activity

dagmodifer: refactor appendData method

Browse Source 
License: MIT
Signed-off-by: Kevin Atkinson <k@kevina.org>
This commit is contained in:
Kevin Atkinson
2017-06-21 00:49:30 -04:00
parent 47001548e1
commit 3f6a7b7b81
1 changed files with 6 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

18
unixfs/mod/dagmodifier.go
View File

@ -151,6 +151,7 @@ func (dm *DagModifier) Write(b []byte) (int, error) {
var ErrNoRawYet = fmt.Errorf("currently only fully support protonodes in the dagmodifier") var ErrNoRawYet = fmt.Errorf("currently only fully support protonodes in the dagmodifier")
// Size returns the Filesize of the node
func (dm *DagModifier) Size() (int64, error) { func (dm *DagModifier) Size() (int64, error) {
switch nd := dm.curNode.(type) { switch nd := dm.curNode.(type) {
case *mdag.ProtoNode: case *mdag.ProtoNode:
@ -321,25 +322,18 @@ func (dm *DagModifier) modifyDag(n node.Node, offset uint64, data io.Reader) (*c
// appendData appends the blocks from the given chan to the end of this dag // appendData appends the blocks from the given chan to the end of this dag
func (dm *DagModifier) appendData(nd node.Node, spl chunk.Splitter) (node.Node, error) { func (dm *DagModifier) appendData(nd node.Node, spl chunk.Splitter) (node.Node, error) {
var root *mdag.ProtoNode
switch nd := nd.(type) { switch nd := nd.(type) {
case *mdag.ProtoNode: case *mdag.ProtoNode:
root = nd dbp := &help.DagBuilderParams{
Dagserv: dm.dagserv,
Maxlinks: help.DefaultLinksPerBlock,
}
return trickle.TrickleAppend(dm.ctx, nd, dbp.New(spl))
case *mdag.RawNode: case *mdag.RawNode:
// TODO: be able to append to rawnodes. Probably requires making this
// node a child of a unxifs intermediate node and passing it down
return nil, fmt.Errorf("appending to raw node types not yet supported") return nil, fmt.Errorf("appending to raw node types not yet supported")
default: default:
return nil, ErrNotUnixfs return nil, ErrNotUnixfs
} }
dbp := &help.DagBuilderParams{
Dagserv: dm.dagserv,
Maxlinks: help.DefaultLinksPerBlock,
}
return trickle.TrickleAppend(dm.ctx, root, dbp.New(spl))
} }
// Read data from this dag starting at the current offset // Read data from this dag starting at the current offset