(logger slog.Logger, ssig ssh.Signal, signaler interface{ Signal(os.Signal) error }, metrics *sshServerMetrics, magicTypeLabel string)
| 845 | } |
| 846 | |
| 847 | func handleSignal(logger slog.Logger, ssig ssh.Signal, signaler interface{ Signal(os.Signal) error }, metrics *sshServerMetrics, magicTypeLabel string) { |
| 848 | ctx := context.Background() |
| 849 | sig := osSignalFrom(ssig) |
| 850 | logger = logger.With(slog.F("ssh_signal", ssig), slog.F("signal", sig.String())) |
| 851 | logger.Info(ctx, "received signal from client") |
| 852 | err := signaler.Signal(sig) |
| 853 | if err != nil { |
| 854 | logger.Warn(ctx, "signaling the process failed", slog.Error(err)) |
| 855 | metrics.sessionErrors.WithLabelValues(magicTypeLabel, "yes", "signal").Add(1) |
| 856 | } |
| 857 | } |
| 858 | |
| 859 | func (s *Server) sftpHandler(logger slog.Logger, session ssh.Session) error { |
| 860 | s.metrics.sftpConnectionsTotal.Add(1) |
no test coverage detected