(contractShards map[common.Address][]uint64)
| 1362 | } |
| 1363 | |
| 1364 | func (s *SyncClient) addPeerToTask(contractShards map[common.Address][]uint64) { |
| 1365 | for contract, shards := range contractShards { |
| 1366 | for _, shard := range shards { |
| 1367 | for _, t := range s.tasks { |
| 1368 | if t.Contract == contract && shard == t.ShardId { |
| 1369 | t.state.PeerCount++ |
| 1370 | } |
| 1371 | } |
| 1372 | } |
| 1373 | } |
| 1374 | } |
| 1375 | |
| 1376 | func (s *SyncClient) removePeerFromTask(contractShards map[common.Address][]uint64) { |
| 1377 | for contract, shards := range contractShards { |