From 215618be1f2de60eba11259568c43921b0e6e58e Mon Sep 17 00:00:00 2001
From: capossele <angelocapossele@gmail.com>
Date: Tue, 9 Jun 2020 10:52:19 +0100
Subject: [PATCH] =?UTF-8?q?=E2=99=BB=EF=B8=8F=20Fix=20event=20closure?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
plugins/analysis/client/plugin.go | 10 ++++++----
1 file changed, 6 insertions(+), 4 deletions(-)
diff --git a/plugins/analysis/client/plugin.go b/plugins/analysis/client/plugin.go
index 15fdec67..ad94d101 100644
--- a/plugins/analysis/client/plugin.go
+++ b/plugins/analysis/client/plugin.go
@@ -62,11 +62,13 @@ func run(_ *node.Plugin) {
if err := daemon.BackgroundWorker(PluginName, func(shutdownSignal <-chan struct{}) {
- fpctest.Voter().Events().Finalized.Attach(events.NewClosure(onFinalized))
- defer fpctest.Voter().Events().Finalized.Detach(events.NewClosure(onFinalized))
+ onFinalizedClosure := events.NewClosure(onFinalized)
+ fpctest.Voter().Events().Finalized.Attach(onFinalizedClosure)
+ defer fpctest.Voter().Events().Finalized.Detach(onFinalizedClosure)
- fpctest.Voter().Events().RoundExecuted.Attach(events.NewClosure(onRoundExecuted))
- defer fpctest.Voter().Events().RoundExecuted.Detach(events.NewClosure(onRoundExecuted))
+ onRoundExecutedClosure := events.NewClosure(onRoundExecuted)
+ fpctest.Voter().Events().RoundExecuted.Attach(onRoundExecutedClosure)
+ defer fpctest.Voter().Events().RoundExecuted.Detach(onRoundExecutedClosure)
ticker := time.NewTicker(reportIntervalSec * time.Second)
defer ticker.Stop()
--
GitLab