()
| 370 | } |
| 371 | |
| 372 | func (self *Server) heartbeat() { |
| 373 | // build heartbeat msg |
| 374 | msg, err := self.constructHeartbeatMsg() |
| 375 | if err != nil { |
| 376 | log.Errorf("failed to build heartbeat msg: %s", err) |
| 377 | return |
| 378 | } |
| 379 | |
| 380 | // send to peer |
| 381 | self.msgSendC <- &SendMsgEvent{ |
| 382 | ToPeer: math.MaxUint32, |
| 383 | Msg: msg, |
| 384 | } |
| 385 | } |
| 386 | |
| 387 | func (self *Server) receiveFromPeer(peerIdx uint32) (uint32, []byte, error) { |
| 388 | if C, present := self.msgRecvC[peerIdx]; present { |
no test coverage detected