From 83d12c1affeb52446d1526e8063a41d1de90eb35 Mon Sep 17 00:00:00 2001
From: capossele <angelocapossele@gmail.com>
Date: Fri, 24 Jan 2020 15:14:44 +0000
Subject: [PATCH] :bug: fix nodes data race
---
.../analysis/webinterface/recordedevents/recorded_events.go | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
diff --git a/plugins/analysis/webinterface/recordedevents/recorded_events.go b/plugins/analysis/webinterface/recordedevents/recorded_events.go
index 80ff952f..fa700388 100644
--- a/plugins/analysis/webinterface/recordedevents/recorded_events.go
+++ b/plugins/analysis/webinterface/recordedevents/recorded_events.go
@@ -76,6 +76,9 @@ func Configure(plugin *node.Plugin) {
}
func Replay(handlers *types.EventHandlers) {
+ lock.Lock()
+ defer lock.Unlock()
+
for nodeId, online := range nodes {
handlers.AddNode(nodeId)
if online {
@@ -84,8 +87,7 @@ func Replay(handlers *types.EventHandlers) {
handlers.NodeOffline(nodeId)
}
}
- lock.Lock()
- defer lock.Unlock()
+
for sourceId, targetMap := range links {
for targetId := range targetMap {
handlers.ConnectNodes(sourceId, targetId)
--
GitLab