Skip to content

fix: restore closing SMTP message on method exit #14496

New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Merged
merged 2 commits into from
Aug 30, 2024
Merged

fix: restore closing SMTP message on method exit #14496

Changes from 1 commit
Commits
Show all changes
2 commits
Select commit Hold shift + click to select a range
f7df1fd
fix: keep defer, but conditionalize
dannykopping Aug 30, 2024
8d8cd98
Use sync.OnceValue
dannykopping Aug 30, 2024
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Use sync.OnceValue 
Signed-off-by: Danny Kopping <danny@coder.com>
  • Loading branch information
@dannykopping
dannykopping committed Aug 30, 2024
commit 8d8cd98b51f75f4ca66287c1305218eb794ad342
11 changes: 5 additions & 6 deletions coderd/notifications/dispatch/smtp.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -183,14 +183,14 @@ func (s *SMTPHandler) dispatch(subject, htmlBody, plainBody, to string) Delivery
if err != nil {
return true, xerrors.Errorf("message transmission: %w", err)
}
closed := false
closeOnce := sync.OnceValue(func() error {
return message.Close()
})
// Close the message when this method exits in order to not leak resources. Even though we're calling this explicitly
// further down, the method may exit before then.
defer func() {
// If we try close an already-closed writer, it'll send a subsequent request to the server which is invalid.
if !closed {
_ = message.Close()
}
_ = closeOnce()
}()

// Create message headers.
Expand Down Expand Up @@ -259,8 +259,7 @@ func (s *SMTPHandler) dispatch(subject, htmlBody, plainBody, to string) Delivery
return false, xerrors.Errorf("write body buffer: %w", err)
}

closed = true
if err = message.Close(); err != nil {
if err = closeOnce(); err != nil {
return true, xerrors.Errorf("delivery failure: %w", err)
}

Expand Down
Loading