Skip to content

Commit

Permalink
don't send messages with the work queue
Browse files Browse the repository at this point in the history
if sends are delayed, these may be sent after the stage deadline has
already occurred
  • Loading branch information
jrick committed Dec 31, 2024
1 parent fabbbad commit 365c907
Showing 1 changed file with 8 additions and 14 deletions.
22 changes: 8 additions & 14 deletions mixing/mixclient/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -570,21 +570,15 @@ func (c *Client) sendLocalPeerMsgs(ctx context.Context, deadline time.Time, s *s
res <- errSendTimeout
continue
}
qsend := &queueWork{
p: m.p,
f: func(p *peer) error {
if err := ctx.Err(); err != nil {
return err
}
err := p.signAndSubmit(m.m)
if err != nil {
nilPeerMsg(p, m.m)
}
return err
},
res: res,
if err := ctx.Err(); err != nil {
res <- err
continue
}
err := m.p.signAndSubmit(m.m)
if err != nil {
nilPeerMsg(m.p)
}
c.workQueue <- qsend
res <- err
}
var errs = make([]error, len(resChans))
for i := range errs {
Expand Down

0 comments on commit 365c907

Please sign in to comment.