certusone
/
wormhole
mirror of https://github.com/certusone/wormhole.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

node/pkg/processor: change threshold for Discord notifications 

Change-Id: I09060ad46a47b6293b18cffd717492098ad6dda0
This commit is contained in:
Leo 2021-10-29 22:26:33 +02:00 committed by Leopold Schabel
parent 4972be80c3
commit 16c9f9036b
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
node/pkg/processor/cleanup.go
View File

@ -101,6 +101,9 @@ func (p *Processor) handleCleanup(ctx context.Context) {
} }
} }
// Send notification for individual message when quorum has failed or
// more than one node is missing.
if !quorum || len(missing) > 1 {
go func(v *vaa.VAA, hasSigs, wantSigs int, quorum bool, missing []string) { go func(v *vaa.VAA, hasSigs, wantSigs int, quorum bool, missing []string) {
if err := p.notifier.MissingSignaturesOnTransaction(v, hasSigs, wantSigs, quorum, missing); err != nil { if err := p.notifier.MissingSignaturesOnTransaction(v, hasSigs, wantSigs, quorum, missing); err != nil {
p.logger.Error("failed to send notification", zap.Error(err)) p.logger.Error("failed to send notification", zap.Error(err))
@ -108,6 +111,7 @@ func (p *Processor) handleCleanup(ctx context.Context) {
}(s.ourVAA, hasSigs, wantSigs, quorum, missing) }(s.ourVAA, hasSigs, wantSigs, quorum, missing)
} }
} }
}
p.logger.Info("VAA considered settled", p.logger.Info("VAA considered settled",
zap.String("digest", hash), zap.String("digest", hash),