()
| 206 | } |
| 207 | |
| 208 | func (pool *PeerPool) getNeighbours() []*Peer { |
| 209 | pool.lock.RLock() |
| 210 | defer pool.lock.RUnlock() |
| 211 | |
| 212 | peers := make([]*Peer, 0) |
| 213 | for _, p := range pool.peers { |
| 214 | if p.connected { |
| 215 | peers = append(peers, p) |
| 216 | } |
| 217 | } |
| 218 | return peers |
| 219 | } |
| 220 | |
| 221 | func (pool *PeerPool) GetPeerIndex(nodeId string) (uint32, bool) { |
| 222 | pool.lock.RLock() |
no outgoing calls