cascade/ipfs-cluster
5
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

allocate: shortcut when not enough candidates

Browse Source 
repinFromPeer: use helper function.

License: MIT
Signed-off-by: Hector Sanjuan <hector@protocol.ai>
This commit is contained in:
Hector Sanjuan 2017-07-05 16:28:52 +02:00
parent faa755f43a
commit b1b5bed544
1 changed files with 8 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
cluster.go
View File

@ -314,11 +314,9 @@ func (c *Cluster) repinFromPeer(p peer.ID) {
}
list := cState.List()
for _, pin := range list {
for _, alloc := range pin.Allocations {
if alloc == p { // found pin allocated to node
logger.Infof("repinning %s out of %s", pin.Cid, p.Pretty())
c.pin(pin, []peer.ID{p}) // pin blacklisting this peer
}
if containsPeer(pin.Allocations, p) {
logger.Infof("repinning %s out of %s", pin.Cid, p.Pretty())
c.pin(pin, []peer.ID{p}) // pin blacklisting this peer
}
}
}
@ -1112,6 +1110,11 @@ func (c *Cluster) allocate(hash *cid.Cid, repl int, blacklist []peer.ID) ([]peer
case needed <= 0: // set the allocations to the needed ones
return validAllocations[0 : len(validAllocations)+needed], nil
case candidatesValid < needed:
err = logError(
"not enough candidates to allocate %s. Needed: %d. Got: %s",
hash, needed, candidatesValid)
return nil, err
default:
// this will return candidate peers in order of
// preference according to the allocator.