From 23a5028df8d7517f55e06e1a6ced2889f27a5837 Mon Sep 17 00:00:00 2001 From: arkiver Date: Fri, 1 Sep 2023 00:35:31 +0200 Subject: [PATCH] Make maps in maps before use. --- projectbackfeedmanager.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/projectbackfeedmanager.go b/projectbackfeedmanager.go index d08c8ff..90b9607 100644 --- a/projectbackfeedmanager.go +++ b/projectbackfeedmanager.go @@ -101,8 +101,14 @@ func (that *ProjectBackfeedManager) Do() { sAddQueueItems[item.Queue] = append(sAddQueueItems[item.Queue], item.Item) } else { key := fmt.Sprintf("%s:%02x:%s", that.Name, item.PrimaryShard, item.SecondaryShard) + if _, exists := queueKeyMap[item.Queue]; !exists { + queueKeyMap[item.Queue] = make(map[string][][]byte) + } queueKeyMap[item.Queue][key] = append(queueKeyMap[item.Queue][key], item.Item) if item.SkipFeed { + if _, exists := skipFeedQueueItems[item.Queue]; !exists { + skipFeedQueueItems[item.Queue] = make(map[string]struct{}) + } skipFeedQueueItems[item.Queue][string(item.Item)] = Tag } }