tornadocontrib/infra
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

nits

Browse Source
This commit is contained in:
Felipe Andrade 2023-09-15 12:33:28 -07:00
parent 3911deccbd
commit 86cf9547e7
1 changed files with 8 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
proxyd/proxyd/consensus_tracker.go
View File

@ -177,6 +177,7 @@ func (ct *RedisConsensusTracker) Init() {
select { select {
case <-timer.C: case <-timer.C:
continue
case <-ct.ctx.Done(): case <-ct.ctx.Done():
timer.Stop() timer.Stop()
return return
@ -246,6 +247,10 @@ func (ct *RedisConsensusTracker) stateHeartbeat() {
ct.remote.update(state) ct.remote.update(state)
log.Debug("updated state from remote", "state", val, "leader", leaderName) log.Debug("updated state from remote", "state", val, "leader", leaderName)
RecordGroupConsensusHALatestBlock(ct.backendGroup, leaderName, ct.remote.state.Latest)
RecordGroupConsensusHASafeBlock(ct.backendGroup, leaderName, ct.remote.state.Safe)
RecordGroupConsensusHAFinalizedBlock(ct.backendGroup, leaderName, ct.remote.state.Finalized)
} }
} else { } else {
if !ct.local.Valid() { if !ct.local.Valid() {
@ -308,9 +313,6 @@ func (ct *RedisConsensusTracker) SetFinalizedBlockNumber(blockNumber hexutil.Uin
} }
func (ct *RedisConsensusTracker) postPayload(mutexVal string) { func (ct *RedisConsensusTracker) postPayload(mutexVal string) {
ct.remote.mutex.Lock()
defer ct.remote.mutex.Unlock()
jsonState, err := json.Marshal(ct.local.state) jsonState, err := json.Marshal(ct.local.state)
if err != nil { if err != nil {
log.Error("failed to marshal local", "err", err) log.Error("failed to marshal local", "err", err)
@ -327,7 +329,7 @@ func (ct *RedisConsensusTracker) postPayload(mutexVal string) {
ct.leaderName = leader ct.leaderName = leader
ct.remote.update(ct.local.state) ct.remote.update(ct.local.state)
RecordGroupConsensusHALatestBlock(ct.backendGroup, leader, ct.local.state.Latest) RecordGroupConsensusHALatestBlock(ct.backendGroup, leader, ct.remote.state.Latest)
RecordGroupConsensusHASafeBlock(ct.backendGroup, leader, ct.local.state.Safe) RecordGroupConsensusHASafeBlock(ct.backendGroup, leader, ct.remote.state.Safe)
RecordGroupConsensusHAFinalizedBlock(ct.backendGroup, leader, ct.local.state.Finalized) RecordGroupConsensusHAFinalizedBlock(ct.backendGroup, leader, ct.remote.state.Finalized)
} }