Method Error

p2p/conn.go:321–336

Error() when an error occurs on the MultiConn execute a callback. Optionally pass a reputation delta to slash the peer

(err error, reputationDelta ...int32)

// Error() when an error occurs on the MultiConn execute a callback. Optionally pass a reputation delta to slash the peer
func (c *MultiConn) Error(err error, reputationDelta ...int32) {
	if len(reputationDelta) == 1 {
		c.p2p.ChangeReputation(c.Address.PublicKey, reputationDelta[0])
	}
	// call onError() for the peer
	c.error.Do(func() {
		// mark the connection as failed under lock, but avoid holding the lock during teardown
		unlock := lockWithTrace("p2p", &c.p2p.mux, c.p2p.log)
		c.hasError.Store(true)
		// run the callback after releasing the lock to prevent blocking other readers
		c.onError(err, c.Address.PublicKey, c.conn.RemoteAddr().String(), c.uuid)
		unlock()
		// stop the multi-conn
		c.Stop()
	})
}

// waitForAndHandleWireBytes() a rate limited handler of inbound bytes from the wire.
// Blocks until bytes are received converts bytes into a proto.Message using an Envelope