Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Create block filters before poll interval #152

Merged
merged 13 commits into from
Sep 6, 2024
Merged

Create block filters before poll interval #152

Changes from 1 commit
Commits
Show all changes
13 commits
Select commit Hold shift + click to select a range
1343bbd
Create block filters before poll interval
rodion-lim-partior Aug 27, 2024
182eebe
Block listener should notify when block filter is established
rodion-lim-partior Aug 30, 2024
1031762
Correct failing tests
rodion-lim-partior Sep 3, 2024
676a441
Add tests for defering checkStartedLocked till block filters are created
rodion-lim-partior Sep 3, 2024
7ae9785
Lock block listener loop started flag
rodion-lim-partior Sep 4, 2024
6c43218
Fix PR review comments
rodion-lim-partior Sep 5, 2024
99c4a1c
refactor tests
Chengxuan Sep 5, 2024
837f0a8
downscoping the locking for get highest block
Chengxuan Sep 5, 2024
ed72634
more tidy up
Chengxuan Sep 5, 2024
7f002f4
fixing test coverage
Chengxuan Sep 5, 2024
57f1df0
Merge branch 'main' of github.com:kaleido-io/firefly-evmconnect into …
Chengxuan Sep 5, 2024
a8a5247
fixing tests
Chengxuan Sep 5, 2024
f9c618e
Fix lint failures
rodion-lim-partior Sep 6, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
16 changes: 10 additions & 6 deletions internal/ethereum/blocklistener.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -162,6 +162,7 @@ func (bl *blockListener) listenLoop() {
var filter string
failCount := 0
gapPotential := true
firstIteration := true
for {
if failCount > 0 {
if bl.c.doFailureDelay(bl.ctx, failCount) {
Expand All @@ -170,13 +171,16 @@ func (bl *blockListener) listenLoop() {
}
} else {
// Sleep for the polling interval, or until we're shoulder tapped by the newHeads listener
select {
case <-time.After(bl.blockPollingInterval):
case <-bl.newHeadsTap:
case <-bl.ctx.Done():
log.L(bl.ctx).Debugf("Block listener loop stopping")
return
if !firstIteration {
select {
case <-time.After(bl.blockPollingInterval):
case <-bl.newHeadsTap:
case <-bl.ctx.Done():
log.L(bl.ctx).Debugf("Block listener loop stopping")
return
}
}
firstIteration = false
}

if filter == "" {
Expand Down
Loading