fix: utp send call to maintain nonce

optimism-java · Oct 11, 2024 · c6aa362 · c6aa362
1 parent c1ed669
commit c6aa362
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/p2p/discover/portal_protocol.go b/p2p/discover/portal_protocol.go
@@ -326,7 +326,7 @@ func (p *PortalProtocol) setupUDPListening() error {
 			if id, ok := p.cachedIds[addr.String()]; ok {
 				//_, err := p.DiscV5.TalkRequestToID(id, addr, string(portalwire.UTPNetwork), buf)
 				req := &v5wire.TalkRequest{Protocol: string(portalwire.Utp), Message: buf}
-				p.DiscV5.sendFromAnotherThread(id, netip.AddrPortFrom(netutil.IPToAddr(addr.IP), uint16(addr.Port)), req)
+				p.DiscV5.sendFromAnotherThreadWithCall(id, netip.AddrPortFrom(netutil.IPToAddr(addr.IP), uint16(addr.Port)), req)
 
 				return len(buf), err
 			} else {

diff --git a/p2p/discover/v5_udp.go b/p2p/discover/v5_udp.go
@@ -686,6 +686,11 @@ func (t *UDPv5) sendFromAnotherThread(toID enode.ID, toAddr netip.AddrPort, pack
 	}
 }
 
+func (t *UDPv5) sendFromAnotherThreadWithCall(toID enode.ID, toAddr netip.AddrPort, packet v5wire.Packet) {
+	resp := t.callToID(toID, toAddr, v5wire.TalkRequestMsg, packet)
+	defer t.callDone(resp)
+}
+
 // send sends a packet to the given node.
 func (t *UDPv5) send(toID enode.ID, toAddr netip.AddrPort, packet v5wire.Packet, c *v5wire.Whoareyou) (v5wire.Nonce, error) {
 	addr := toAddr.String()