forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-26 06:36:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

FIX: Local buffers

Browse source
This commit is contained in:
David Zhou 2025-05-13 10:06:37 -04:00
parent 6a3c000a4d
commit 9ba4611433
1 changed files with 3 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

4
eth/tracers/firehose_concurrency_test.go
View file

@ -15,6 +15,7 @@ import (
func TestFirehose_BlockPrintsToFirehose_SingleBlock(t *testing.T) { func TestFirehose_BlockPrintsToFirehose_SingleBlock(t *testing.T) {
f := NewFirehose(&FirehoseConfig{ f := NewFirehose(&FirehoseConfig{
ConcurrentBlockFlushing: true,
ApplyBackwardCompatibility: ptr(false), ApplyBackwardCompatibility: ptr(false),
private: &privateFirehoseConfig{ private: &privateFirehoseConfig{
FlushToTestBuffer: true, FlushToTestBuffer: true,
@ -61,10 +62,11 @@ func TestFirehose_BlockPrintsToFirehose_SingleBlock(t *testing.T) {
func TestFirehose_BlocksPrintToFirehose_MultipleBlocksInOrder(t *testing.T) { func TestFirehose_BlocksPrintToFirehose_MultipleBlocksInOrder(t *testing.T) {
const blockCount = 100 const blockCount = 10
const baseBlockNum = 1000 const baseBlockNum = 1000
f := NewFirehose(&FirehoseConfig{ f := NewFirehose(&FirehoseConfig{
ConcurrentBlockFlushing: true,
ApplyBackwardCompatibility: ptr(false), ApplyBackwardCompatibility: ptr(false),
private: &privateFirehoseConfig{ private: &privateFirehoseConfig{
FlushToTestBuffer: true, FlushToTestBuffer: true,