From 0f16301bc4924b1e4a9066d8ed5c5f2b7b0b789c Mon Sep 17 00:00:00 2001
From: josh <josh@elixxir.io>
Date: Tue, 8 Jun 2021 12:45:34 -0700
Subject: [PATCH] Debug clearmessage stoppable
---
api/client.go | 5 +++--
storage/partition/store.go | 2 ++
2 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/api/client.go b/api/client.go
index ecd0cda74..fa635f2e2 100644
--- a/api/client.go
+++ b/api/client.go
@@ -187,8 +187,6 @@ func OpenClient(storageDir string, password []byte, parameters params.Network) (
parameters: parameters,
}
- c.runner.Add(c.storage.Partition().ClearMessages())
-
return c, nil
}
@@ -410,6 +408,9 @@ func (c *Client) StartNetworkFollower(timeout time.Duration) (<-chan interfaces.
c.runner = stoppable.NewMulti(followerStoppableName)
}
+ jww.INFO.Printf("Adding partition cleaner")
+ c.runner.Add(c.storage.Partition().ClearMessages())
+
err = c.status.toStarting()
if err != nil {
return nil, errors.WithMessage(err, "Failed to Start the Network Follower")
diff --git a/storage/partition/store.go b/storage/partition/store.go
index 30cf66f74..7dfaf405b 100644
--- a/storage/partition/store.go
+++ b/storage/partition/store.go
@@ -9,6 +9,7 @@ package partition
import (
"encoding/binary"
+ jww "github.com/spf13/jwalterweatherman"
"gitlab.com/elixxir/client/interfaces/message"
"gitlab.com/elixxir/client/stoppable"
"gitlab.com/elixxir/client/storage/versioned"
@@ -67,6 +68,7 @@ func (s *Store) ClearMessages() stoppable.Stoppable {
for {
select {
case <-stop.Quit():
+ jww.INFO.Printf("Received stop signal in clear messages")
stop.ToStopped()
t.Stop()
return
--
GitLab