opensource/kubo
1
0
Fork 0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-03 21:08:17 +08:00
Code Issues Projects Releases Wiki Activity

//hash -> // hash

Browse Source 
License: MIT
Signed-off-by: Jakub Sztandera <kubuxu@protonmail.ch>
This commit is contained in:
Jakub Sztandera
2018-03-01 23:41:17 +01:00
parent 578cb240d4
commit bcedd38c9a
3 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
blockservice/blockservice.go
View File

@ -155,7 +155,7 @@ func (s *blockService) AddBlock(o blocks.Block) error {
} }
func (s *blockService) AddBlocks(bs []blocks.Block) error { func (s *blockService) AddBlocks(bs []blocks.Block) error {
//hash security // hash security
for _, b := range bs { for _, b := range bs {
err := verifcid.ValidateCid(b.Cid()) err := verifcid.ValidateCid(b.Cid())
if err != nil { if err != nil {
@ -202,7 +202,7 @@ func (s *blockService) GetBlock(ctx context.Context, c *cid.Cid) (blocks.Block,
f = s.exchange f = s.exchange
} }
return getBlock(ctx, c, s.blockstore, f) //hash security return getBlock(ctx, c, s.blockstore, f) // hash security
} }
func getBlock(ctx context.Context, c *cid.Cid, bs blockstore.Blockstore, f exchange.Fetcher) (blocks.Block, error) { func getBlock(ctx context.Context, c *cid.Cid, bs blockstore.Blockstore, f exchange.Fetcher) (blocks.Block, error) {
@ -242,7 +242,7 @@ func getBlock(ctx context.Context, c *cid.Cid, bs blockstore.Blockstore, f excha
// the returned channel. // the returned channel.
// NB: No guarantees are made about order. // NB: No guarantees are made about order.
func (s *blockService) GetBlocks(ctx context.Context, ks []*cid.Cid) <-chan blocks.Block { func (s *blockService) GetBlocks(ctx context.Context, ks []*cid.Cid) <-chan blocks.Block {
return getBlocks(ctx, ks, s.blockstore, s.exchange) //hash security return getBlocks(ctx, ks, s.blockstore, s.exchange) // hash security
} }
func getBlocks(ctx context.Context, ks []*cid.Cid, bs blockstore.Blockstore, f exchange.Fetcher) <-chan blocks.Block { func getBlocks(ctx context.Context, ks []*cid.Cid, bs blockstore.Blockstore, f exchange.Fetcher) <-chan blocks.Block {

4
core/builder.go
View File

@ -15,9 +15,9 @@ import (
dag "github.com/ipfs/go-ipfs/merkledag" dag "github.com/ipfs/go-ipfs/merkledag"
resolver "github.com/ipfs/go-ipfs/path/resolver" resolver "github.com/ipfs/go-ipfs/path/resolver"
pin "github.com/ipfs/go-ipfs/pin" pin "github.com/ipfs/go-ipfs/pin"
"github.com/ipfs/go-ipfs/thirdparty/verifbs"
repo "github.com/ipfs/go-ipfs/repo" repo "github.com/ipfs/go-ipfs/repo"
cfg "github.com/ipfs/go-ipfs/repo/config" cfg "github.com/ipfs/go-ipfs/repo/config"
"github.com/ipfs/go-ipfs/thirdparty/verifbs"
uio "github.com/ipfs/go-ipfs/unixfs/io" uio "github.com/ipfs/go-ipfs/unixfs/io"
ds "gx/ipfs/QmPpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore" ds "gx/ipfs/QmPpegoMqhAEqjncrzArm7KVWAkCm78rqL2DPuNjhPrshg/go-datastore"
@ -171,7 +171,7 @@ func setupNode(ctx context.Context, n *IpfsNode, cfg *BuildCfg) error {
TempErrFunc: isTooManyFDError, TempErrFunc: isTooManyFDError,
} }
//hash security // hash security
bs := bstore.NewBlockstore(rds) bs := bstore.NewBlockstore(rds)
bs = &verifbs.VerifBS{bs} bs = &verifbs.VerifBS{bs}

2
core/commands/add.go
View File

@ -258,7 +258,7 @@ You can now check what blocks have been created by:
exch = offline.Exchange(addblockstore) exch = offline.Exchange(addblockstore)
} }
bserv := blockservice.New(addblockstore, exch) //hash security 001 bserv := blockservice.New(addblockstore, exch) // hash security 001
dserv := dag.NewDAGService(bserv) dserv := dag.NewDAGService(bserv)
outChan := make(chan interface{}, adderOutChanSize) outChan := make(chan interface{}, adderOutChanSize)