immediate buffer release instead of defering

libp2p · Feb 27, 2020 · fe2d21a · fe2d21a
1 parent 30ba05e
commit fe2d21a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dht_net.go b/dht_net.go
@@ -83,7 +83,7 @@ func (dht *IpfsDHT) handleNewMessage(s network.Stream) bool {
 		var req pb.Message
 		msgbytes, err := r.ReadMsg()
 		if err != nil {
-			defer r.ReleaseMsg(msgbytes)
+			r.ReleaseMsg(msgbytes)
 			if err == io.EOF {
 				return true
 			}