Stop() stops the entire peer set
()
| 282 | |
| 283 | // Stop() stops the entire peer set |
| 284 | func (ps *PeerSet) Stop() { |
| 285 | defer lib.TimeTrack(ps.logger, time.Now(), time.Second) |
| 286 | unlock := rlockWithTrace("peerset", &ps.mux, ps.logger) |
| 287 | defer unlock() |
| 288 | for _, p := range ps.m { |
| 289 | p.conn.Stop() |
| 290 | } |
| 291 | } |
| 292 | |
| 293 | // send() sends a message to a specific peer object |
| 294 | func (ps *PeerSet) send(peer *Peer, topic lib.Topic, bz []byte) lib.ErrorI { |
nothing calls this directly
no test coverage detected