Method removePeerFromTask

ethstorage/p2p/protocol/syncclient.go:1376–1386

(contractShards map[common.Address][]uint64)

}

func (s *SyncClient) removePeerFromTask(contractShards map[common.Address][]uint64) {
	for contract, shards := range contractShards {
		for _, shard := range shards {
			for _, t := range s.tasks {
				if t.Contract == contract && shard == t.ShardId {
					t.state.PeerCount--
				}
			}
		}
	}
}