coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-23 03:17:25 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

fix: nil ref on consensus halts for non-archive nodes

Browse Source
This commit is contained in:
Cassandra Heart 2025-10-09 22:45:07 -05:00
parent 3eb7477ff8
commit 30a76203d3
No known key found for this signature in database
GPG Key ID: 371083BFA6C240AA
1 changed files with 14 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
node/consensus/global/event_distributor.go
View File

@ -202,11 +202,13 @@ func (e *GlobalConsensusEngine) eventDistributorLoop() {
if ok && data.Message != "" {
e.logger.Error(data.Message)
e.halt()
if err := e.stateMachine.Stop(); err != nil {
e.logger.Error(
"error occurred while halting consensus",
zap.Error(err),
)
if e.stateMachine != nil {
if err := e.stateMachine.Stop(); err != nil {
e.logger.Error(
"error occurred while halting consensus",
zap.Error(err),
)
}
}
go func() {
for {
@ -230,11 +232,13 @@ func (e *GlobalConsensusEngine) eventDistributorLoop() {
zap.Error(data.Error),
)
e.halt()
if err := e.stateMachine.Stop(); err != nil {
e.logger.Error(
"error occurred while halting consensus",
zap.Error(err),
)
if e.stateMachine != nil {
if err := e.stateMachine.Stop(); err != nil {
e.logger.Error(
"error occurred while halting consensus",
zap.Error(err),
)
}
}
go func() {
for {