Method Close

server/server.go:547–625

()

	// Check if there are active connections
	activeConns := atomic.LoadInt64(&s.activeConns)
	if activeConns > 0 {
		slog.Info("Waiting for active connections to finish.", "count", activeConns)
	}

	// If process isolation is enabled, signal children to terminate
	if s.cfg.ProcessIsolation && s.childTracker != nil {
		childCount := s.childTracker.Count()
		if childCount > 0 {
			slog.Info("Signaling child processes to terminate.", "count", childCount)
			s.childTracker.SignalAll(syscall.SIGTERM)
		}
	}

	// Wait for connections with timeout
	done := make(chan struct{})
	go func() {
		s.wg.Wait()
		// Also wait for child processes if isolation is enabled
		if s.cfg.ProcessIsolation && s.childTracker != nil {
			<-s.childTracker.WaitAll()
		}
		close(done)
	}()

	select {
	case <-done:
		slog.Info("All connections closed gracefully.")
	case <-time.After(s.cfg.ShutdownTimeout):
		slog.Warn("Shutdown timeout exceeded, force closing remaining connections.", "timeout", s.cfg.ShutdownTimeout)
		// Force kill remaining children
		if s.cfg.ProcessIsolation && s.childTracker != nil {
			s.childTracker.SignalAll(syscall.SIGKILL)
		}
	}

	// Shut down ACME managers if active
	if s.acmeManager != nil {
		if err := s.acmeManager.Close(); err != nil {
			slog.Warn("ACME manager shutdown error.", "error", err)
		}
	}
	if s.acmeDNSManager != nil {
		if err := s.acmeDNSManager.Close(); err != nil {
			slog.Warn("ACME DNS manager shutdown error.", "error", err)
		}
	}

	// Stop query logger (drains remaining entries)
	queryLogTimeout := s.cfg.ShutdownTimeout
	if queryLogTimeout <= 0 {
		queryLogTimeout = 30 * time.Second
	}
	queryLogCtx, queryLogCancel := context.WithTimeout(context.Background(), queryLogTimeout)
	if err := s.StopQueryLogging(queryLogCtx); err != nil {
		slog.Warn("Query log shutdown deadline exceeded.", "error", err)
	}
	queryLogCancel()