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

move comment with variables

Browse Source
This commit is contained in:
Kishan Mohanbhai Sagathiya 2019-11-08 20:49:06 +05:30
parent 0e7ed97e59
commit d42c0fd651
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
cluster.go
View File

@ -1698,12 +1698,13 @@ func (c *Cluster) globalPinInfoCid(ctx context.Context, comp, method string, h c
Cid: h, Cid: h,
PeerMap: make(map[string]*api.PinInfo), PeerMap: make(map[string]*api.PinInfo),
} }
// allocated peers, we will contact them through rpc
var dests []peer.ID var dests []peer.ID
// un-allocated peers, we will set remote status
var remote []peer.ID var remote []peer.ID
timeNow := time.Now() timeNow := time.Now()
// set dests (allocated peers, we will contact them through rpc) and remote (un-allocated peers, // set dests and remote
// we will set remote status)
if c.config.FollowerMode { if c.config.FollowerMode {
// during follower mode return status only on self peer // during follower mode return status only on self peer
dests = []peer.ID{c.host.ID()} dests = []peer.ID{c.host.ID()}