Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
57 commits
Select commit Hold shift + click to select a range
d4c7e7d
Add high availabiliy via raft
alpe Nov 12, 2025
820b9a3
Prefent duplicate peers
alpe Nov 12, 2025
35cf0c8
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 17, 2025
45a6e27
Go mod tidy
alpe Nov 17, 2025
3111158
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 17, 2025
4562ded
Minor updates
alpe Nov 17, 2025
4d47754
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 18, 2025
0804346
Fix test
alpe Nov 18, 2025
1c2e3f1
Leadership fix
alpe Nov 18, 2025
c320a7a
Fix test
alpe Nov 18, 2025
72ec5fe
Remove sleep
alpe Nov 19, 2025
b34d7a0
Increase buffer size for raft msgs
alpe Nov 19, 2025
7af5d1a
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 20, 2025
406377e
Review feedback
alpe Nov 20, 2025
0ff25b8
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 20, 2025
b92a67f
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 21, 2025
406ad8b
Add replace to go.mod
alpe Nov 21, 2025
1337bc6
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Nov 24, 2025
abfa8d3
Fix merge conflicts
alpe Nov 24, 2025
aebbdff
Linter fix
alpe Nov 24, 2025
50d7caf
Minor test update
alpe Nov 24, 2025
5de9f0e
Remove store.Sync
alpe Nov 25, 2025
30094b2
Merge branch 'main' into alex/adr023_ha-failover_raft7
alpe Dec 3, 2025
695324e
Merge
alpe Dec 3, 2025
2463919
Add last submitted da heights to raft
alpe Dec 3, 2025
3e1cbca
Make test compile again
alpe Dec 4, 2025
567092f
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 6, 2026
640924b
Complete merge
alpe Jan 6, 2026
11038cd
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 7, 2026
095f882
Fix integration test
alpe Jan 7, 2026
99afdad
Review feedback and linting
alpe Jan 7, 2026
3f7f431
Convert raft state into proto type
alpe Jan 7, 2026
25a6185
Fix import and e2e tests
alpe Jan 8, 2026
adc05ed
Cufigurable leader_lease_timeout
alpe Jan 8, 2026
9b0bff4
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 9, 2026
49ba50f
Log raft state height when passing leadership
alpe Jan 9, 2026
00ae050
Recover with raft state
alpe Jan 12, 2026
490b286
Ensure block hash in state check
alpe Jan 12, 2026
d7fbf79
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 12, 2026
dfa2204
Merge branch 'main' into alex/adr023_ha-failover_raft8
alpe Jan 15, 2026
7edca17
x
alpe Jan 14, 2026
6502a47
More safety features, including db.sync
alpe Jan 14, 2026
a52d538
Ensure safe restart
alpe Jan 15, 2026
3203ce6
x
alpe Jan 15, 2026
1cf1167
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 16, 2026
e4e94f2
Resolve conflicts
alpe Jan 16, 2026
e444215
Fix test setup
alpe Jan 18, 2026
3b4fe3f
Fix dummyDA
alpe Jan 19, 2026
9b80c74
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 19, 2026
67d1ce7
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 26, 2026
51edca8
Review feedback
alpe Jan 26, 2026
5fc0b6b
Add grace period for test
alpe Jan 26, 2026
e8f9db0
Add raft doc
alpe Jan 27, 2026
c9b8166
Available ports for e2e tests
alpe Jan 27, 2026
acce8e4
Review feedback
alpe Jan 27, 2026
c1ef1d5
Merge branch 'main' into alex/adr023_ha-failover_raft11
alpe Jan 27, 2026
938f908
Fix integration test
alpe Jan 27, 2026
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
Prev Previous commit
Next Next commit
Merge branch 'main' into alex/adr023_ha-failover_raft7
* main:
  chore: fix some comments (#2874)
  chore: bump node in evm-single (#2875)
  refactor(syncer,cache): use compare and swap loop and add comments (#2873)
  refactor: use state da height as well (#2872)
  refactor: retrieve highest da height in cache (#2870)
  chore: change from event count to start and end height (#2871)
  • Loading branch information
alpe committed Nov 21, 2025
commit b92a67fb96f790bf71fcbe701a42a88e366a2958
6 changes: 6 additions & 0 deletions block/internal/cache/generic_cache.go
Original file line number Diff line number Diff line change
Expand Up @@ -10,6 +10,7 @@ import (
"sync"

"golang.org/x/sync/errgroup"
"sync/atomic"
)

// Cache is a generic cache that maintains items that are seen and hard confirmed
Expand Down Expand Up @@ -275,6 +276,11 @@ func (c *Cache[T]) LoadFromDisk(folderPath string) error {
}
for k, v := range daIncludedMap {
c.daIncluded.Store(k, v)
// Update max DA height during load
current := c.maxDAHeight.Load()
if v > current {
c.maxDAHeight.Store(v)
}
}

return nil
Expand Down
6 changes: 5 additions & 1 deletion block/internal/syncing/syncer.go
Original file line number Diff line number Diff line change
Expand Up @@ -109,7 +109,7 @@ func NewSyncer(
headerStore: headerStore,
dataStore: dataStore,
lastState: &atomic.Pointer[types.State]{},
daHeight: &atomic.Uint64{},
daRetrieverHeight: &atomic.Uint64{},
heightInCh: make(chan common.DAHeightEvent, 1_000),
errorCh: errorCh,
logger: logger.With().Str("component", "syncer").Logger(),
Expand Down Expand Up @@ -143,6 +143,10 @@ func (s *Syncer) Start(ctx context.Context) error {
}
}

if !s.waitForGenesis() {
return nil
}

// Start main processing loop
go s.processLoop()

Expand Down
You are viewing a condensed version of this merge commit. You can view the full changes here.