sad/soju
1
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

downstream: use fresh context to send timeout errors

Browse Source 
Using an expired context will never actually send the error message
here.
This commit is contained in:
Simon Ser 2023-12-11 11:38:57 +01:00
parent 6729297159
commit e9678cee2f
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
downstream.go
View File

@ -1690,6 +1690,9 @@ func (dc *downstreamConn) runUntilRegistered() error {
go func() { go func() {
<-ctx.Done() <-ctx.Done()
if err := ctx.Err(); err == context.DeadlineExceeded { if err := ctx.Err(); err == context.DeadlineExceeded {
ctx, cancel := context.WithTimeout(context.Background(), 3*time.Second)
defer cancel()
dc.SendMessage(ctx, &irc.Message{ dc.SendMessage(ctx, &irc.Message{
Prefix: dc.srv.prefix(), Prefix: dc.srv.prefix(),
Command: "ERROR", Command: "ERROR",