Commit 9093b83c authored by Steven Allen's avatar Steven Allen

avoid allocating for a simple debug message

Wantlist/Blocks *copy*.
parent 243a6c53
...@@ -222,7 +222,7 @@ func (e *Engine) Peers() []peer.ID { ...@@ -222,7 +222,7 @@ func (e *Engine) Peers() []peer.ID {
// MessageReceived performs book-keeping. Returns error if passed invalid // MessageReceived performs book-keeping. Returns error if passed invalid
// arguments. // arguments.
func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error { func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error {
if len(m.Wantlist()) == 0 && len(m.Blocks()) == 0 { if m.Empty() {
log.Debugf("received empty message from %s", p) log.Debugf("received empty message from %s", p)
} }
...@@ -257,9 +257,9 @@ func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error { ...@@ -257,9 +257,9 @@ func (e *Engine) MessageReceived(p peer.ID, m bsmsg.BitSwapMessage) error {
} }
log.Error(err) log.Error(err)
} else { } else {
// we have the block // we have the block
newWorkExists = true newWorkExists = true
if msgSize + blockSize > maxMessageSize { if msgSize+blockSize > maxMessageSize {
e.peerRequestQueue.Push(p, activeEntries...) e.peerRequestQueue.Push(p, activeEntries...)
activeEntries = []*wl.Entry{} activeEntries = []*wl.Entry{}
msgSize = 0 msgSize = 0
......
Markdown is supported
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment