aboutsummaryrefslogtreecommitdiff
path: root/forged/internal/incoming
diff options
context:
space:
mode:
Diffstat (limited to 'forged/internal/incoming')
-rw-r--r--forged/internal/incoming/hooks/hooks.go2
-rw-r--r--forged/internal/incoming/lmtp/lmtp.go2
-rw-r--r--forged/internal/incoming/ssh/ssh.go2
-rw-r--r--forged/internal/incoming/web/web.go2
4 files changed, 4 insertions, 4 deletions
diff --git a/forged/internal/incoming/hooks/hooks.go b/forged/internal/incoming/hooks/hooks.go
index 65277d4..4400b61 100644
--- a/forged/internal/incoming/hooks/hooks.go
+++ b/forged/internal/incoming/hooks/hooks.go
@@ -45,7 +45,7 @@ func New(config Config) (server *Server) {
}
func (server *Server) Run(ctx context.Context) error {
- listener, _, err := misc.ListenUnixSocket(server.socketPath)
+ listener, _, err := misc.ListenUnixSocket(ctx, server.socketPath)
if err != nil {
return fmt.Errorf("listen unix socket for hooks: %w", err)
}
diff --git a/forged/internal/incoming/lmtp/lmtp.go b/forged/internal/incoming/lmtp/lmtp.go
index cf5618c..429ff20 100644
--- a/forged/internal/incoming/lmtp/lmtp.go
+++ b/forged/internal/incoming/lmtp/lmtp.go
@@ -37,7 +37,7 @@ func New(config Config) (server *Server) {
}
func (server *Server) Run(ctx context.Context) error {
- listener, _, err := misc.ListenUnixSocket(server.socket)
+ listener, _, err := misc.ListenUnixSocket(ctx, server.socket)
if err != nil {
return fmt.Errorf("listen unix socket for LMTP: %w", err)
}
diff --git a/forged/internal/incoming/ssh/ssh.go b/forged/internal/incoming/ssh/ssh.go
index e551863..a0cce5e 100644
--- a/forged/internal/incoming/ssh/ssh.go
+++ b/forged/internal/incoming/ssh/ssh.go
@@ -65,7 +65,7 @@ func New(config Config) (server *Server, err error) {
}
func (server *Server) Run(ctx context.Context) (err error) {
- listener, err := misc.Listen(server.net, server.addr)
+ listener, err := misc.Listen(ctx, server.net, server.addr)
if err != nil {
return fmt.Errorf("listen for SSH: %w", err)
}
diff --git a/forged/internal/incoming/web/web.go b/forged/internal/incoming/web/web.go
index fb5bedc..5c95013 100644
--- a/forged/internal/incoming/web/web.go
+++ b/forged/internal/incoming/web/web.go
@@ -57,7 +57,7 @@ func New(config Config) (server *Server) {
func (server *Server) Run(ctx context.Context) (err error) {
server.httpServer.BaseContext = func(_ net.Listener) context.Context { return ctx }
- listener, err := misc.Listen(server.net, server.addr)
+ listener, err := misc.Listen(ctx, server.net, server.addr)
if err != nil {
return fmt.Errorf("listen for web: %w", err)
}