diff --git a/channels/sendTracker.go b/channels/sendTracker.go index 4de21d4221f2ef3be1bedec5105d6f537f4a2e12..55084422083f0ba51f5a84e55417c56d4f18042a 100644 --- a/channels/sendTracker.go +++ b/channels/sendTracker.go @@ -426,10 +426,16 @@ func (rr *roundResults) callback(allRoundsSucceeded, timedOut bool, _ map[id.Rou delete(rr.st.byMessageID, registered[i].MsgID) } + if err := rr.st.store(); err != nil { + jww.FATAL.Panicf("failed to store update after "+ + "finalizing delivery of sent messages: %+v", err) + } + rr.st.mux.Unlock() for i := range registered { go rr.st.updateStatus(registered[i].UUID, registered[i].MsgID, time.Time{}, rounds.Round{}, status) } + }