Skip to content

Commit

Permalink
Refactor.
Browse files Browse the repository at this point in the history
License: MIT
Signed-off-by: Kevin Atkinson <k@kevina.org>
  • Loading branch information
kevina authored and whyrusleeping committed Mar 2, 2017
1 parent 5087db5 commit 93ec38d
Showing 1 changed file with 15 additions and 6 deletions.
21 changes: 15 additions & 6 deletions filestore/fsrefstore.go
Original file line number Diff line number Diff line change
Expand Up @@ -84,6 +84,20 @@ func (f *FileManager) DeleteBlock(c *cid.Cid) error {
}

func (f *FileManager) Get(c *cid.Cid) (blocks.Block, error) {
dobj, err := f.getDataObj(c)
if err != nil {
return nil, err
}

out, err := f.readDataObj(c, dobj)
if err != nil {
return nil, err
}

return blocks.NewBlockWithCid(out, c)
}

func (f *FileManager) getDataObj(c *cid.Cid) (*pb.DataObj, error) {
o, err := f.ds.Get(dshelp.CidToDsKey(c))
switch err {
case ds.ErrNotFound:
Expand All @@ -104,12 +118,7 @@ func (f *FileManager) Get(c *cid.Cid) (blocks.Block, error) {
return nil, err
}

out, err := f.readDataObj(c, &dobj)
if err != nil {
return nil, err
}

return blocks.NewBlockWithCid(out, c)
return &dobj, nil
}

// reads and verifies the block
Expand Down

0 comments on commit 93ec38d

Please sign in to comment.