Skip to content
Snippets Groups Projects
Commit e17d5dd1 authored by benjamin's avatar benjamin
Browse files

fixed a bug where round updates would come with bad data

parent 770f8114
No related branches found
No related tags found
4 merge requests!510Release,!419rewrote the health tracker to both consider if there are waiting rounds and...,!397Fully Decentralized channels,!340Project/channels
Hide whitespace changes
Inline Side-by-side
Showing
with 5 additions and 3 deletions
channels/sendTracker.go
+ 5
− 3
View file @ e17d5dd1
...@@ -386,7 +386,7 @@ type roundResults struct { ...@@ -386,7 +386,7 @@ type roundResults struct {
// callback is called when results are known about a round. it will re-trigger // callback is called when results are known about a round. it will re-trigger
// the wait if it fails up to 'maxChecks' times. // the wait if it fails up to 'maxChecks' times.
func (rr *roundResults) callback(allRoundsSucceeded, timedOut bool, _ map[id.Round]cmix.RoundResult) { func (rr *roundResults) callback(allRoundsSucceeded, timedOut bool, results map[id.Round]cmix.RoundResult) {
rr.st.mux.Lock() rr.st.mux.Lock()
...@@ -434,8 +434,10 @@ func (rr *roundResults) callback(allRoundsSucceeded, timedOut bool, _ map[id.Rou ...@@ -434,8 +434,10 @@ func (rr *roundResults) callback(allRoundsSucceeded, timedOut bool, _ map[id.Rou
rr.st.mux.Unlock() rr.st.mux.Unlock()
for i := range registered { for i := range registered {
go rr.st.updateStatus(registered[i].UUID, registered[i].MsgID, time.Time{}, round := results[rr.round].Round
rounds.Round{}, status) ts := mutateTimestamp(round.Timestamps[states.QUEUED], registered[i].MsgID)
go rr.st.updateStatus(registered[i].UUID, registered[i].MsgID, ts,
round, status)
} }
} }
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment