From 7105524e4bb607366c47ae2b627b4a4407063138 Mon Sep 17 00:00:00 2001
From: "Richard T. Carback III" <rick.carback@gmail.com>
Date: Tue, 23 Aug 2022 16:15:02 +0000
Subject: [PATCH] Make sure critical messaging processing thead is started
---
cmix/client.go | 3 +++
cmix/critical.go | 9 ++++++++-
2 files changed, 11 insertions(+), 1 deletion(-)
diff --git a/cmix/client.go b/cmix/client.go
index 996cacdb4..fb326f72a 100644
--- a/cmix/client.go
+++ b/cmix/client.go
@@ -246,6 +246,9 @@ func (c *client) Follow(report ClientErrorReport) (stoppable.Stoppable, error) {
// Start the processes for the identity handler
multi.Add(c.Tracker.StartProcesses())
+ //Start the critical processing thread
+ multi.Add(c.crit.startProcessies())
+
return multi, nil
}
diff --git a/cmix/critical.go b/cmix/critical.go
index 03ebfc7b5..719e6d9f0 100644
--- a/cmix/critical.go
+++ b/cmix/critical.go
@@ -1,6 +1,8 @@
package cmix
import (
+ "time"
+
jww "github.com/spf13/jwalterweatherman"
"gitlab.com/elixxir/client/cmix/health"
"gitlab.com/elixxir/client/stoppable"
@@ -10,7 +12,6 @@ import (
"gitlab.com/elixxir/primitives/states"
"gitlab.com/xx_network/primitives/id"
"gitlab.com/xx_network/primitives/id/ephemeral"
- "time"
)
const criticalRawMessagesKey = "RawCriticalMessages"
@@ -58,6 +59,12 @@ func newCritical(kv *versioned.KV, hm health.Monitor,
return c
}
+func (c *critical) startProcessies() *stoppable.Single {
+ stop := stoppable.NewSingle("criticalStopper")
+ go c.runCriticalMessages(stop)
+ return stop
+}
+
func (c *critical) runCriticalMessages(stop *stoppable.Single) {
for {
select {
--
GitLab