do not report smtp "connection reset by peer" error (use warn instead)
This commit is contained in:
@@ -3,7 +3,9 @@ package smtp
|
|||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"crypto/tls"
|
"crypto/tls"
|
||||||
|
"fmt"
|
||||||
"net"
|
"net"
|
||||||
|
"strings"
|
||||||
"sync"
|
"sync"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
@@ -90,7 +92,14 @@ func NewManager(cfg *Config) *Manager {
|
|||||||
}
|
}
|
||||||
|
|
||||||
s := smtp.NewServer(mailsrv)
|
s := smtp.NewServer(mailsrv)
|
||||||
s.ErrorLog = loggerWrapper{func(s string, i ...any) { cfg.Logger.Error().Msgf(s, i...) }}
|
s.ErrorLog = loggerWrapper{func(s string, i ...any) {
|
||||||
|
msg := fmt.Sprintf(s, i...)
|
||||||
|
if strings.Contains(msg, "connection reset by peer") {
|
||||||
|
cfg.Logger.Warn().Msg(msg)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
cfg.Logger.Error().Msg(msg)
|
||||||
|
}}
|
||||||
s.ReadTimeout = 10 * time.Second
|
s.ReadTimeout = 10 * time.Second
|
||||||
s.WriteTimeout = 10 * time.Second
|
s.WriteTimeout = 10 * time.Second
|
||||||
s.MaxMessageBytes = int64(cfg.MaxSize * 1024 * 1024)
|
s.MaxMessageBytes = int64(cfg.MaxSize * 1024 * 1024)
|
||||||
|
|||||||
Reference in New Issue
Block a user