Skip to content

Commit 2826476

Browse files
committed
Revert "fix: test case and upgrade utp-go version"
This reverts commit 02b87d9.
1 parent 3e8973d commit 2826476

File tree

4 files changed

+1
-18
lines changed

4 files changed

+1
-18
lines changed

go.mod

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -55,7 +55,7 @@ require (
5555
github.com/mattn/go-sqlite3 v1.14.18
5656
github.com/naoina/toml v0.1.2-0.20170918210437-9fafd6967416
5757
github.com/olekukonko/tablewriter v0.0.5
58-
github.com/optimism-java/utp-go v0.0.0-20240531024756-00da67044c50
58+
github.com/optimism-java/utp-go v0.0.0-20240530085325-d8dd9d262631
5959
github.com/peterh/liner v1.1.1-0.20190123174540-a2c9a5303de7
6060
github.com/protolambda/bls12-381-util v0.1.0
6161
github.com/protolambda/zrnt v0.32.2

go.sum

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -433,10 +433,6 @@ github.com/optimism-java/utp-go v0.0.0-20240309041853-b6b3a0dea581 h1:ZxgrtI0xIw
433433
github.com/optimism-java/utp-go v0.0.0-20240309041853-b6b3a0dea581/go.mod h1:DZ0jYzLzt4ZsCmhI/iqYgGFoNx45OfpEoKzXB8HVALQ=
434434
github.com/optimism-java/utp-go v0.0.0-20240530085325-d8dd9d262631 h1:01AecSuOSS6fsIU/oTVG/C70hIl3xPen99qy2hGr57w=
435435
github.com/optimism-java/utp-go v0.0.0-20240530085325-d8dd9d262631/go.mod h1:DZ0jYzLzt4ZsCmhI/iqYgGFoNx45OfpEoKzXB8HVALQ=
436-
github.com/optimism-java/utp-go v0.0.0-20240531021243-e12d25b6be38 h1:t0gRqfM7wUrFyryagUpw4TmYY0DLt+rjPaBd92i+W2M=
437-
github.com/optimism-java/utp-go v0.0.0-20240531021243-e12d25b6be38/go.mod h1:DZ0jYzLzt4ZsCmhI/iqYgGFoNx45OfpEoKzXB8HVALQ=
438-
github.com/optimism-java/utp-go v0.0.0-20240531024756-00da67044c50 h1:I1jGQkNEWq7BTFZkCJKLDrqFLC1jR3EC7jz3to4kpLg=
439-
github.com/optimism-java/utp-go v0.0.0-20240531024756-00da67044c50/go.mod h1:DZ0jYzLzt4ZsCmhI/iqYgGFoNx45OfpEoKzXB8HVALQ=
440436
github.com/optimism-java/zrnt v0.32.4-0.20240415084906-d9dbf06b32f7 h1:ZTQWXQ8xblCRUXhZs3h5qrBMSAHe8iNH7BG7a7IVFlI=
441437
github.com/optimism-java/zrnt v0.32.4-0.20240415084906-d9dbf06b32f7/go.mod h1:A0fezkp9Tt3GBLATSPIbuY4ywYESyAuc/FFmPKg8Lqs=
442438
github.com/peterh/liner v1.1.1-0.20190123174540-a2c9a5303de7 h1:oYW+YCJ1pachXTQmzR3rNLYGGz4g/UgFcjb28p/viDM=

p2p/discover/portal_protocol.go

Lines changed: 0 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1044,7 +1044,6 @@ func (p *PortalProtocol) handleFindContent(id enode.ID, addr *net.UDPAddr, reque
10441044
connIdSend := connId.SendId()
10451045

10461046
go func(bctx context.Context) {
1047-
defer p.connIdGen.Remove(connId)
10481047
for {
10491048
select {
10501049
case <-bctx.Done():
@@ -1167,7 +1166,6 @@ func (p *PortalProtocol) handleOffer(id enode.ID, addr *net.UDPAddr, request *po
11671166
connIdSend := connId.SendId()
11681167

11691168
go func(bctx context.Context) {
1170-
defer p.connIdGen.Remove(connId)
11711169
for {
11721170
select {
11731171
case <-bctx.Done():

p2p/discover/portal_protocol_test.go

Lines changed: 0 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -10,7 +10,6 @@ import (
1010
"testing"
1111
"time"
1212

13-
"github.com/ethereum/go-ethereum/p2p/enr"
1413
"github.com/ethereum/go-ethereum/portalnetwork/storage"
1514
"github.com/prysmaticlabs/go-bitfield"
1615
"golang.org/x/exp/slices"
@@ -79,7 +78,6 @@ func setupLocalPortalNode(addr string, bootNodes []*enode.Node) (*PortalProtocol
7978
}
8079
}
8180
}
82-
localNode.Set(enr.UDP(addr1.Port))
8381

8482
discV5, err := ListenV5(conn, localNode, discCfg)
8583
if err != nil {
@@ -115,15 +113,6 @@ func TestPortalWireProtocolUdp(t *testing.T) {
115113
assert.NoError(t, err)
116114
time.Sleep(10 * time.Second)
117115

118-
node1.putCacheNodeId(node2.localNode.Node())
119-
node1.putCacheNodeId(node3.localNode.Node())
120-
121-
node2.putCacheNodeId(node1.localNode.Node())
122-
node2.putCacheNodeId(node3.localNode.Node())
123-
124-
node3.putCacheNodeId(node1.localNode.Node())
125-
node3.putCacheNodeId(node2.localNode.Node())
126-
127116
udpAddrStr1 := fmt.Sprintf("%s:%d", node1.localNode.Node().IP(), node1.localNode.Node().UDP())
128117
udpAddrStr2 := fmt.Sprintf("%s:%d", node2.localNode.Node().IP(), node2.localNode.Node().UDP())
129118

0 commit comments

Comments
 (0)