Skip to content
Snippets Groups Projects
Commit 0f16301b authored by Josh Brooks's avatar Josh Brooks
Browse files

Debug clearmessage stoppable

parent 08ebb97d
No related branches found
No related tags found
1 merge request!23Release
......@@ -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")
......
......@@ -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
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment