forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-06-18 21:01:38 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

remove tracker.fulfil from test

Browse source
This commit is contained in:
healthykim 2026-03-19 02:45:09 +09:00
parent 9ba076e0b1
commit 65924d6884
1 changed files with 0 additions and 28 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

28
eth/protocols/eth/peer_test.go
View file

@ -30,7 +30,6 @@ import (
"github.com/ethereum/go-ethereum/core/types" "github.com/ethereum/go-ethereum/core/types"
"github.com/ethereum/go-ethereum/p2p" "github.com/ethereum/go-ethereum/p2p"
"github.com/ethereum/go-ethereum/p2p/enode" "github.com/ethereum/go-ethereum/p2p/enode"
"github.com/ethereum/go-ethereum/p2p/tracker"
"github.com/ethereum/go-ethereum/params" "github.com/ethereum/go-ethereum/params"
"github.com/ethereum/go-ethereum/rlp" "github.com/ethereum/go-ethereum/rlp"
) )
@ -188,11 +187,6 @@ func TestPartialReceipt(t *testing.T) {
}), }),
} }
tresp := tracker.Response{ID: delivery.RequestId, MsgCode: ReceiptsMsg, Size: delivery.List.Len()}
if err := peer.tracker.Fulfil(tresp); err != nil {
t.Fatalf("Tracker failed: %v", err)
}
receiptList, _ := delivery.List.Items() receiptList, _ := delivery.List.Items()
if err := peer.bufferReceipts(delivery.RequestId, receiptList, delivery.LastBlockIncomplete, backend); err != nil { if err := peer.bufferReceipts(delivery.RequestId, receiptList, delivery.LastBlockIncomplete, backend); err != nil {
t.Fatalf("first bufferReceipts failed: %v", err) t.Fatalf("first bufferReceipts failed: %v", err)
@ -226,10 +220,6 @@ func TestPartialReceipt(t *testing.T) {
}, },
}), }),
} }
tresp = tracker.Response{ID: delivery.RequestId, MsgCode: ReceiptsMsg, Size: delivery.List.Len()}
if err := peer.tracker.Fulfil(tresp); err != nil {
t.Fatalf("Tracker failed: %v", err)
}
receiptLists, _ := delivery.List.Items() receiptLists, _ := delivery.List.Items()
if err := peer.bufferReceipts(delivery.RequestId, receiptLists, delivery.LastBlockIncomplete, backend); err != nil { if err := peer.bufferReceipts(delivery.RequestId, receiptLists, delivery.LastBlockIncomplete, backend); err != nil {
t.Fatalf("second bufferReceipts failed: %v", err) t.Fatalf("second bufferReceipts failed: %v", err)
@ -271,11 +261,6 @@ func TestPartialReceipt(t *testing.T) {
}, },
}), }),
} }
tresp = tracker.Response{ID: delivery.RequestId, MsgCode: ReceiptsMsg, Size: delivery.List.Len()}
if err := peer.tracker.Fulfil(tresp); err != nil {
t.Fatalf("Tracker failed: %v", err)
}
receiptList, _ = delivery.List.Items() receiptList, _ = delivery.List.Items()
if err := peer.bufferReceipts(delivery.RequestId, receiptList, delivery.LastBlockIncomplete, backend); err != nil { if err := peer.bufferReceipts(delivery.RequestId, receiptList, delivery.LastBlockIncomplete, backend); err != nil {
t.Fatalf("third bufferReceipts failed: %v", err) t.Fatalf("third bufferReceipts failed: %v", err)
@ -358,11 +343,6 @@ func TestPartialReceiptFailure(t *testing.T) {
}, },
}), }),
} }
tresp := tracker.Response{ID: delivery.RequestId, MsgCode: ReceiptsMsg, Size: delivery.List.Len()}
if err := peer.tracker.Fulfil(tresp); err == nil {
t.Fatal("Unknown response should be rejected by tracker")
}
// If a peer deliverse excessive amount of receipts, it should also fail the validation // If a peer deliverse excessive amount of receipts, it should also fail the validation
hashes := []common.Hash{ hashes := []common.Hash{
backend.chain.GetBlockByNumber(1).Hash(), backend.chain.GetBlockByNumber(1).Hash(),
@ -407,10 +387,6 @@ func TestPartialReceiptFailure(t *testing.T) {
items: encodeRL(excessiveReceipts), items: encodeRL(excessiveReceipts),
}}), }}),
} }
tresp = tracker.Response{ID: delivery.RequestId, MsgCode: ReceiptsMsg, Size: delivery.List.Len()}
if err = peer.tracker.Fulfil(tresp); err != nil {
t.Fatalf("tracker.Fulfil failed: %v", err)
}
receiptList, _ := delivery.List.Items() receiptList, _ := delivery.List.Items()
err = peer.bufferReceipts(delivery.RequestId, receiptList, delivery.LastBlockIncomplete, backend) err = peer.bufferReceipts(delivery.RequestId, receiptList, delivery.LastBlockIncomplete, backend)
if err == nil { if err == nil {
@ -437,10 +413,6 @@ func TestPartialReceiptFailure(t *testing.T) {
}), }),
}}), }}),
} }
tresp = tracker.Response{ID: delivery.RequestId, MsgCode: ReceiptsMsg, Size: delivery.List.Len()}
if err = peer.tracker.Fulfil(tresp); err != nil {
t.Fatalf("tracker.Fulfil failed: %v", err)
}
receiptList, _ = delivery.List.Items() receiptList, _ = delivery.List.Items()
err = peer.bufferReceipts(delivery.RequestId, receiptList, delivery.LastBlockIncomplete, backend) err = peer.bufferReceipts(delivery.RequestId, receiptList, delivery.LastBlockIncomplete, backend)
if err == nil { if err == nil {