From 308ce6c10ce77835a9b4d2ca9a17d449260c6adb Mon Sep 17 00:00:00 2001
From: Runxi Yu <me@runxiyu.org>
Date: Sun, 17 Aug 2025 04:34:16 +0800
Subject: Add shutdown timeouts

---
 forged/internal/incoming/ssh/ssh.go | 39 +++++++++++++++++++++----------------
 1 file changed, 22 insertions(+), 17 deletions(-)

(limited to 'forged/internal/incoming/ssh')

diff --git a/forged/internal/incoming/ssh/ssh.go b/forged/internal/incoming/ssh/ssh.go
index 77812d1..9f9bdff 100644
--- a/forged/internal/incoming/ssh/ssh.go
+++ b/forged/internal/incoming/ssh/ssh.go
@@ -5,6 +5,7 @@ import (
 	"errors"
 	"fmt"
 	"os"
+	"time"
 
 	gliderssh "github.com/gliderlabs/ssh"
 	"go.lindenii.runxiyu.org/forge/forged/internal/common/misc"
@@ -12,27 +13,30 @@ import (
 )
 
 type Config struct {
-	Net  string `scfg:"net"`
-	Addr string `scfg:"addr"`
-	Key  string `scfg:"key"`
-	Root string `scfg:"root"`
+	Net             string `scfg:"net"`
+	Addr            string `scfg:"addr"`
+	Key             string `scfg:"key"`
+	Root            string `scfg:"root"`
+	ShutdownTimeout uint32 `scfg:"shutdown_timeout"`
 }
 
 type Server struct {
-	gliderServer *gliderssh.Server
-	privkey      gossh.Signer
-	pubkeyString string
-	pubkeyFP     string
-	net          string
-	addr         string
-	root         string
+	gliderServer    *gliderssh.Server
+	privkey         gossh.Signer
+	pubkeyString    string
+	pubkeyFP        string
+	net             string
+	addr            string
+	root            string
+	shutdownTimeout uint32
 }
 
 func New(config Config) (server *Server, err error) {
 	server = &Server{
-		net:  config.Net,
-		addr: config.Addr,
-		root: config.Root,
+		net:             config.Net,
+		addr:            config.Addr,
+		root:            config.Root,
+		shutdownTimeout: config.ShutdownTimeout,
 	}
 
 	var privkeyBytes []byte
@@ -63,9 +67,10 @@ func (server *Server) Run(ctx context.Context) (err error) {
 
 	go func() {
 		<-ctx.Done()
-		_ = server.gliderServer.Close()
-		_ = listener.Close() // unnecessary?
-		// TODO: Log the error
+		shCtx, cancel := context.WithTimeout(context.Background(), time.Duration(server.shutdownTimeout)*time.Second)
+		defer cancel()
+		_ = server.gliderServer.Shutdown(shCtx)
+		_ = listener.Close()
 	}()
 
 	if err = server.gliderServer.Serve(listener); err != nil {
-- 
cgit v1.2.3