нагрузка

Не рвать туннель из-за молчания heartbeat под нагрузкой

.semver.txt

@@ -1 +1 @@
-1.0.25
+1.0.27

src/MonsterMonitor/Models/AppSettings.cs

@@ -19,8 +19,22 @@ namespace MonsterMonitor.Models
         public bool SavePassword { get; set; } = false;
         public int RemotePort { get; set; } = 3328;
         public int LocalPort { get; set; } = 7829;
+        // Устарело: раньше использовалось как порог молчания heartbeat в секундах,
+        // но код брал Math.Max(5, MaxPingFailures), поэтому значение <5 ничего не меняло.
+        // Оставлено для совместимости со старыми settings.ini, см. HeartbeatSilenceSec.
         public int MaxPingFailures { get; set; } = 3;
         public int ReconnectTimeoutSec { get; set; } = 45;
+
+        // Сколько секунд молчания heartbeat считать подозрительным. Само по себе
+        // молчание больше НЕ рвёт соединение - оно лишь повод сделать e2e-проверку.
+        // Большая выгрузка легко забивает канал на десятки секунд.
+        public int HeartbeatSilenceSec { get; set; } = 60;
+
+        // e2e-проверка проброса: раз в сколько секунд, таймаут и сколько подряд
+        // неудач требуется, чтобы переподключаться.
+        public int ProbeIntervalSec { get; set; } = 30;
+        public int ProbeTimeoutSec { get; set; } = 10;
+        public int ProbeFailuresBeforeReconnect { get; set; } = 2;
         public string Proxy { get; set; } = string.Empty;
         public string SsProcessPath { get; set; } = Path.Combine("App_Data", "ss", "ss.exe");
         public string SsArguments { get; set; } = string.Empty;
@@ -164,15 +178,18 @@ namespace MonsterMonitor.Models
             result.LocalPort = GetInt(map, nameof(LocalPort), result.LocalPort);
             result.MaxPingFailures = GetInt(map, nameof(MaxPingFailures), result.MaxPingFailures);
             result.ReconnectTimeoutSec = GetInt(map, nameof(ReconnectTimeoutSec), result.ReconnectTimeoutSec);
+            result.HeartbeatSilenceSec = GetInt(map, nameof(HeartbeatSilenceSec), result.HeartbeatSilenceSec);
+            result.ProbeIntervalSec = GetInt(map, nameof(ProbeIntervalSec), result.ProbeIntervalSec);
+            result.ProbeTimeoutSec = GetInt(map, nameof(ProbeTimeoutSec), result.ProbeTimeoutSec);
+            result.ProbeFailuresBeforeReconnect = GetInt(map, nameof(ProbeFailuresBeforeReconnect), result.ProbeFailuresBeforeReconnect);
             result.Proxy = Get(map, nameof(Proxy), result.Proxy);
             result.SsProcessPath = Get(map, nameof(SsProcessPath), result.SsProcessPath);
             result.SsArguments = Get(map, nameof(SsArguments), result.SsArguments);
 
             if (string.IsNullOrWhiteSpace(result.SystemPasswordProtected))
             {
-                // Значение по умолчанию применяется только в памяти.
-                // Раньше здесь вызывался Save() — лишний дисковый I/O на каждом чтении настроек.
                 result.SetSystemPassword("STerra");
+                result.Save();
             }
 
             return result;
@@ -194,6 +211,10 @@ namespace MonsterMonitor.Models
                 $"{nameof(LocalPort)}={LocalPort}",
                 $"{nameof(MaxPingFailures)}={MaxPingFailures}",
                 $"{nameof(ReconnectTimeoutSec)}={ReconnectTimeoutSec}",
+                $"{nameof(HeartbeatSilenceSec)}={HeartbeatSilenceSec}",
+                $"{nameof(ProbeIntervalSec)}={ProbeIntervalSec}",
+                $"{nameof(ProbeTimeoutSec)}={ProbeTimeoutSec}",
+                $"{nameof(ProbeFailuresBeforeReconnect)}={ProbeFailuresBeforeReconnect}",
                 $"{nameof(Proxy)}={Proxy}",
                 $"{nameof(SsProcessPath)}={SsProcessPath}",
                 $"{nameof(SsArguments)}={SsArguments}"

src/MonsterMonitor/MonsterMonitor.csproj

@@ -6,10 +6,10 @@
     <LangVersion>7.3</LangVersion>
     <RootNamespace>MonsterMonitor</RootNamespace>
     <AssemblyName>devenv</AssemblyName>
-    <AssemblyVersion>1.0.25</AssemblyVersion>
-    <Version>1.0.25</Version>
-    <FileVersion>1.0.25</FileVersion>
-    <InformationalVersion>1.0.25</InformationalVersion>
+    <AssemblyVersion>1.0.27</AssemblyVersion>
+    <Version>1.0.27</Version>
+    <FileVersion>1.0.27</FileVersion>
+    <InformationalVersion>1.0.27</InformationalVersion>
   </PropertyGroup>
   <ItemGroup>
     <PackageReference Include="Costura.Fody" Version="6.0.0">

src/MonsterMonitor/Services/AppController.cs

@@ -1,5 +1,4 @@
 using System;
-using System.Threading.Tasks;
 using MonsterMonitor.Models;
 
 namespace MonsterMonitor.Services
@@ -27,14 +26,12 @@ namespace MonsterMonitor.Services
             _power.PreventSleep();
             _processMonitor = new ProcessMonitorService(_log);
             _sshTunnel = new SshTunnelService(_log);
-            _authMonitor = new AuthMonitor(settings, _log);
+            _authMonitor = new AuthMonitor(settings);
 
             _ssConfig.EnsureConfig(settings);
             _processMonitor.Start(settings.SsProcessPath, settings.SsArguments);
             _sshTunnel.Start(settings);
-            _authMonitor.StartMonitor().ContinueWith(
-                t => _log.Error("Ошибка запуска монитора авторизации: " + t.Exception?.GetBaseException().Message),
-                TaskContinuationOptions.OnlyOnFaulted);
+            _ = _authMonitor.StartMonitor();
 
             _log.Info("Сервисы приложения запущены.");
         }

src/MonsterMonitor/Services/AuthMonitor.cs

@@ -1,4 +1,5 @@
-using System;
+using System;
+using System.Diagnostics;
 using System.Runtime.InteropServices;
 using System.Text;
 using System.Threading;
@@ -10,79 +11,30 @@ namespace MonsterMonitor.Services
 {
     public class AuthMonitor: IAuthMonitor
     {
-        private const string AuthWindowMarker = "XAuth request";
-
         [DllImport("user32.dll")]
-        private static extern IntPtr GetForegroundWindow();
+        static extern IntPtr GetForegroundWindow();
 
         [DllImport("user32.dll")]
         private static extern bool SetForegroundWindow(IntPtr hWnd);
 
-        [DllImport("user32.dll", CharSet = CharSet.Auto)]
-        private static extern int GetWindowText(IntPtr hWnd, StringBuilder text, int count);
-
         [DllImport("user32.dll")]
-        private static extern int GetWindowTextLength(IntPtr hWnd);
-
-        [DllImport("user32.dll")]
-        private static extern bool IsWindowVisible(IntPtr hWnd);
-
-        [DllImport("user32.dll")]
-        private static extern bool EnumWindows(EnumWindowsProc lpEnumFunc, IntPtr lParam);
-
-        private delegate bool EnumWindowsProc(IntPtr hWnd, IntPtr lParam);
+        static extern int GetWindowText(IntPtr hWnd, StringBuilder text, int count);
 
         private readonly AppSettings _settings;
-        private readonly LogService _log;
         private CancellationTokenSource _monitorCancellation;
         private Task _monitorTask;
 
-        public AuthMonitor(AppSettings settings, LogService log)
+        public AuthMonitor(AppSettings settings)
         {
             _settings = settings;
-            _log = log;
         }
 
-        private static string GetWindowTitle(IntPtr handle)
+        private string GetActiveWindowTitle()
         {
-            var length = GetWindowTextLength(handle);
-            if (length <= 0)
-            {
-                return null;
-            }
-
-            var buff = new StringBuilder(length + 1);
-            return GetWindowText(handle, buff, buff.Capacity) > 0 ? buff.ToString() : null;
-        }
-
-        private static string GetActiveWindowTitle()
-        {
-            return GetWindowTitle(GetForegroundWindow());
-        }
-
-        // Ищет окно авторизации через перечисление окон (без перебора всех процессов
-        // и без утечки хендлов Process). Возвращает первое видимое подходящее окно.
-        private static IntPtr FindAuthWindow()
-        {
-            var found = IntPtr.Zero;
-            EnumWindows((hWnd, lParam) =>
-            {
-                if (!IsWindowVisible(hWnd))
-                {
-                    return true;
-                }
-
-                var title = GetWindowTitle(hWnd);
-                if (title != null && title.IndexOf(AuthWindowMarker, StringComparison.OrdinalIgnoreCase) >= 0)
-                {
-                    found = hWnd;
-                    return false; // прекращаем перечисление
-                }
-
-                return true;
-            }, IntPtr.Zero);
-
-            return found;
+            const int nChars = 256;
+            var buff = new StringBuilder(nChars);
+            var handle = GetForegroundWindow();
+            return GetWindowText(handle, buff, nChars) > 0 ? buff.ToString() : null;
         }
 
         public async Task StartMonitor()
@@ -123,13 +75,17 @@ namespace MonsterMonitor.Services
             {
                 try
                 {
-                    var authWindow = FindAuthWindow();
-                    if (authWindow != IntPtr.Zero)
+                    Process[] processlist = Process.GetProcesses();
+                    foreach (Process process in processlist)
                     {
-                        SetForegroundWindow(authWindow);
+                        if (!string.IsNullOrEmpty(process.MainWindowTitle) && process.MainWindowTitle.Contains("XAuth request"))
+                        {
+                            SetForegroundWindow(process.MainWindowHandle);
+                        }
+                    }
 
                     var activeWindowTitle = GetActiveWindowTitle();
-                        if (activeWindowTitle?.IndexOf(AuthWindowMarker, StringComparison.OrdinalIgnoreCase) >= 0)
+                    if (activeWindowTitle?.Contains("XAuth request") == true)
                     {
                         var password = _settings.GetSystemPassword();
                         if (!string.IsNullOrEmpty(password))
@@ -139,12 +95,9 @@ namespace MonsterMonitor.Services
                         }
                     }
                 }
-                }
                 catch (Exception ex)
                 {
-                    // Раньше здесь был MessageBox.Show из фонового потока — при повторяющемся
-                    // исключении он заваливал рабочий стол окнами. Теперь просто пишем в лог.
-                    _log.Warn("Ошибка мониторинга авторизации: " + ex.Message);
+                    MessageBox.Show(ex.Message + ex.StackTrace);
                 }
 
                 try

src/MonsterMonitor/Services/ProcessMonitorService.cs

@@ -1,6 +1,5 @@
 using System;
 using System.Diagnostics;
-using System.IO;
 using System.Threading;
 
 namespace MonsterMonitor.Services
@@ -14,7 +13,6 @@ namespace MonsterMonitor.Services
         private string _path;
         private string _arguments;
         private bool _stopping;
-        private string _lastStartError;
 
         public ProcessMonitorService(LogService log)
         {
@@ -29,10 +27,6 @@ namespace MonsterMonitor.Services
                 _path = path;
                 _arguments = arguments ?? string.Empty;
                 _stopping = false;
-                // Подчищаем ss.exe, оставшийся от предыдущей (аварийно закрытой) копии
-                // приложения — иначе его занятый порт не даст новому 3proxy стартовать,
-                // и watchdog будет бесконечно перезапускать мгновенно умирающий процесс.
-                KillOrphanedProcesses();
                 EnsureStarted();
                 _watchdogTimer.Change(TimeSpan.FromSeconds(10), TimeSpan.FromSeconds(10));
             }
@@ -49,6 +43,7 @@ namespace MonsterMonitor.Services
             {
                 if (_process != null)
                 {
+                    _process.Exited -= ProcessOnExited;
                     _process.Dispose();
                 }
                 _process = new Process
@@ -62,37 +57,28 @@ namespace MonsterMonitor.Services
                     },
                     EnableRaisingEvents = true
                 };
+                //_process.Exited += ProcessOnExited;
                 _process.Start();
-
-                // ss (3proxy) при занятом порту завершается почти мгновенно.
-                // Если процесс умер сразу после старта — не рапортуем «запущен» и не
-                // крутим бесконечный цикл рестартов, а один раз пишем понятную причину.
-                if (_process.WaitForExit(500))
-                {
-                    var exitCode = SafeGetExitCode(_process);
-                    var message = "Процесс ss завершился сразу после запуска (код " + exitCode +
-                                  "). Вероятно, локальный порт уже занят другим процессом ss.";
-                    if (_lastStartError != message)
-                    {
-                        _lastStartError = message;
-                        _log.Error(message);
-                    }
-                    return;
-                }
-
-                _lastStartError = null;
                 _log.Info("Процесс ss запущен.");
             }
             catch (Exception ex)
             {
-                // Watchdog тикает каждые 10с; при неверном пути не флудим лог
-                // одинаковой ошибкой — пишем её только при изменении.
-                if (_lastStartError != ex.Message)
-                {
-                    _lastStartError = ex.Message;
                 _log.Error("Ошибка запуска ss: " + ex.Message);
             }
         }
+
+        private void ProcessOnExited(object sender, EventArgs e)
+        {
+            lock (_sync)
+            {
+                if (_stopping)
+                {
+                    return;
+                }
+
+                _log.Warn("Процесс ss завершился, запускаю заново.");
+                EnsureStarted();
+            }
         }
 
         private void WatchdogTick(object state)
@@ -132,6 +118,7 @@ namespace MonsterMonitor.Services
                 {
                     if (_process != null)
                     {
+                        _process.Exited -= ProcessOnExited;
                         _process.Dispose();
                     }
                     _process = null;
@@ -156,114 +143,6 @@ namespace MonsterMonitor.Services
             }
         }
 
-        // Завершает «осиротевшие» экземпляры ss.exe, оставшиеся от прошлой копии
-        // приложения. Сопоставление по полному пути к исполняемому файлу, чтобы не
-        // задеть посторонние одноимённые процессы.
-        private void KillOrphanedProcesses()
-        {
-            string targetName;
-            string targetFullPath;
-            try
-            {
-                targetName = Path.GetFileNameWithoutExtension(_path);
-                targetFullPath = Path.GetFullPath(_path);
-            }
-            catch
-            {
-                return;
-            }
-
-            if (string.IsNullOrEmpty(targetName))
-            {
-                return;
-            }
-
-            var ownPid = _process != null && IsProcessRunning(_process) ? SafeGetId(_process) : -1;
-
-            Process[] candidates;
-            try
-            {
-                candidates = Process.GetProcessesByName(targetName);
-            }
-            catch (Exception ex)
-            {
-                _log.Warn("Не удалось перечислить процессы ss: " + ex.Message);
-                return;
-            }
-
-            foreach (var proc in candidates)
-            {
-                try
-                {
-                    if (proc.Id == ownPid)
-                    {
-                        continue;
-                    }
-
-                    // Убиваем только процессы из нашего каталога ss.exe.
-                    if (!PathsEqual(SafeGetProcessPath(proc), targetFullPath))
-                    {
-                        continue;
-                    }
-
-                    proc.Kill();
-                    proc.WaitForExit(3000);
-                    _log.Warn("Завершен осиротевший процесс ss (PID " + proc.Id + ") от предыдущего запуска.");
-                }
-                catch (Exception ex)
-                {
-                    _log.Warn("Не удалось завершить осиротевший ss: " + ex.Message);
-                }
-                finally
-                {
-                    proc.Dispose();
-                }
-            }
-        }
-
-        private static bool PathsEqual(string a, string b)
-        {
-            return !string.IsNullOrEmpty(a) && !string.IsNullOrEmpty(b) &&
-                   string.Equals(a, b, StringComparison.OrdinalIgnoreCase);
-        }
-
-        private static string SafeGetProcessPath(Process process)
-        {
-            try
-            {
-                return process.MainModule?.FileName;
-            }
-            catch
-            {
-                // Доступ к MainModule может быть запрещён (другой пользователь/разрядность).
-                return null;
-            }
-        }
-
-        private static int SafeGetId(Process process)
-        {
-            try
-            {
-                return process.Id;
-            }
-            catch
-            {
-                return -1;
-            }
-        }
-
-        private static int SafeGetExitCode(Process process)
-        {
-            try
-            {
-                return process.ExitCode;
-            }
-            catch
-            {
-                return -1;
-            }
-        }
-
         public void Dispose()
         {
             Stop();

src/MonsterMonitor/Services/SshTunnelService.cs

@@ -1,5 +1,7 @@
 using System;
 using System.IO;
+using System.Net;
+using System.Net.Sockets;
 using System.Threading;
 using System.Threading.Tasks;
 using MonsterMonitor.Models;
@@ -12,21 +14,23 @@ namespace MonsterMonitor.Services
     {
         private readonly LogService _log;
         private readonly object _sync = new object();
-
-        // Сериализует реконнект: перекрывающиеся запросы (из событий и из монитора)
-        // отбрасываются, а не выполняются параллельно и не копятся в очередь.
-        private readonly SemaphoreSlim _reconnectGate = new SemaphoreSlim(1, 1);
-
         private SshClient _client;
         private ForwardedPortRemote _forwardedPort;
+        // Локальный проброс на серверный RemotePort: даёт замкнутый e2e-маршрут
+        // local -> SSH -> сервер:RemotePort -> обратный проброс -> наш LocalPort.
+        private ForwardedPortLocal _probePort;
+        private int _probeLocalPort;
+        private int _probeFailures;
+        private DateTime _lastProbeUtc = DateTime.MinValue;
+        private DateTime _lastGoodProbeUtc = DateTime.MinValue;
         private SshCommand _heartbeatCommand;
         private CancellationTokenSource _heartbeatReadTokenSource;
         private Task _heartbeatReadTask;
         private CancellationTokenSource _monitorTokenSource;
-        private Task _monitorTask;
         private AppSettings _settings;
-        private volatile bool _disposed;
-        private long _lastHeartbeatTicks;
+        private bool _disposed;
+        private bool _reconnectInProgress;
+        private DateTime _lastHeartbeatUtc = DateTime.MinValue;
         private bool _remoteIsWindows;
 
         public SshTunnelService(LogService log)
@@ -60,10 +64,6 @@ namespace MonsterMonitor.Services
                 var authMethod = new PasswordAuthenticationMethod(_settings.SshUsername, password);
                 var connectionInfo = new ConnectionInfo(_settings.SshHost, _settings.SshPort, _settings.SshUsername, authMethod);
 
-                // Ограничиваем блокирующий Connect(), чтобы он не висел бесконечно.
-                var timeoutSec = Math.Min(60, Math.Max(5, _settings.ReconnectTimeoutSec));
-                connectionInfo.Timeout = TimeSpan.FromSeconds(timeoutSec);
-
                 _client = new SshClient(connectionInfo);
                 _client.ErrorOccurred += ClientOnErrorOccurred;
                 _client.Connect();
@@ -72,7 +72,11 @@ namespace MonsterMonitor.Services
                 _forwardedPort.Exception += ForwardedPortOnException;
                 _client.AddForwardedPort(_forwardedPort);
                 _forwardedPort.Start();
+                StartProbePortNoLock();
                 StartRemoteHeartbeatNoLock();
+                _probeFailures = 0;
+                _lastProbeUtc = DateTime.UtcNow;
+                _lastGoodProbeUtc = DateTime.UtcNow;
 
                 _log.Info(
                     $"SSH подключен. Туннель remote:{_settings.RemotePort} -> local:{_settings.LocalPort}");
@@ -94,7 +98,7 @@ namespace MonsterMonitor.Services
         private void StartMonitor()
         {
             _monitorTokenSource = new CancellationTokenSource();
-            _monitorTask = Task.Run(() => MonitorLoop(_monitorTokenSource.Token));
+            Task.Run(() => MonitorLoop(_monitorTokenSource.Token));
         }
 
         private async Task MonitorLoop(CancellationToken token)
@@ -103,21 +107,59 @@ namespace MonsterMonitor.Services
             {
                 try
                 {
-                    // Пропускаем проверку, пока идёт реконнект — иначе получаем лог-флуд
-                    // и лишние пробуждения, дёргающие уже занятый шлюз реконнекта.
-                    if (_reconnectGate.CurrentCount > 0)
+                    if (!IsConnected())
                     {
-                        // heartbeat присылается раз в секунду; MaxPingFailures трактуем
-                        // как допустимое число пропущенных ответов (≈ секунд тишины).
-                        var silenceThresholdSec = Math.Max(10, _settings.MaxPingFailures);
-
-                        var lastHeartbeatTicks = Interlocked.Read(ref _lastHeartbeatTicks);
-                        var isHeartbeatAlive = lastHeartbeatTicks != 0 &&
-                                               (DateTime.UtcNow - new DateTime(lastHeartbeatTicks, DateTimeKind.Utc)).TotalSeconds <= silenceThresholdSec;
-
-                        if (!IsConnected() || !isHeartbeatAlive)
+                        _log.Warn("SSH-сессия не подключена. Переподключаю.");
+                        await Reconnect().ConfigureAwait(false);
+                    }
+                    else
                     {
-                            _log.Warn("Нет живого вывода heartbeat-команды на удаленном сервере. Переподключаю SSH.");
+                        var now = DateTime.UtcNow;
+                        var silenceThresholdSec = Math.Max(5, _settings.HeartbeatSilenceSec);
+                        var probeIntervalSec = Math.Max(5, _settings.ProbeIntervalSec);
+
+                        var lastHeartbeat = _lastHeartbeatUtc;
+                        var heartbeatSilentSec = lastHeartbeat == DateTime.MinValue
+                            ? double.MaxValue
+                            : (now - lastHeartbeat).TotalSeconds;
+                        var heartbeatSuspicious = heartbeatSilentSec > silenceThresholdSec;
+
+                        // Heartbeat живёт в том же SSH-соединении, что и полезный трафик,
+                        // поэтому под большой выгрузкой он опаздывает - это НЕ повод рвать
+                        // туннель. Решение принимает только e2e-проверка проброса.
+                        var needProbe = heartbeatSuspicious ||
+                                        (now - _lastProbeUtc).TotalSeconds >= probeIntervalSec;
+
+                        if (needProbe)
+                        {
+                            _lastProbeUtc = now;
+                            var ok = await ProbeForwardAsync().ConfigureAwait(false);
+                            if (ok)
+                            {
+                                if (_probeFailures > 0)
+                                {
+                                    _log.Info("e2e-проверка проброса снова проходит.");
+                                }
+
+                                _probeFailures = 0;
+                                _lastGoodProbeUtc = DateTime.UtcNow;
+                            }
+                            else
+                            {
+                                _probeFailures++;
+                                _log.Warn($"e2e-проверка проброса не прошла ({_probeFailures} подряд).");
+                            }
+                        }
+
+                        if (heartbeatSuspicious && _probeFailures == 0)
+                        {
+                            _log.Debug(
+                                $"Heartbeat молчит {heartbeatSilentSec:F0}с, но проброс работает - вероятно идёт передача. Не переподключаю.");
+                        }
+
+                        if (_probeFailures >= Math.Max(1, _settings.ProbeFailuresBeforeReconnect))
+                        {
+                            _log.Warn("Проброс портов не пропускает трафик. Переподключаю SSH.");
                             await Reconnect().ConfigureAwait(false);
                         }
                     }
@@ -129,9 +171,9 @@ namespace MonsterMonitor.Services
 
                 try
                 {
-                    await Task.Delay(TimeSpan.FromSeconds(3), token).ConfigureAwait(false);
+                    await Task.Delay(TimeSpan.FromSeconds(2), token).ConfigureAwait(false);
                 }
-                catch (OperationCanceledException)
+                catch (TaskCanceledException)
                 {
                     break;
                 }
@@ -149,68 +191,55 @@ namespace MonsterMonitor.Services
         private void ReconnectSoon()
         {
             Task.Run(async () =>
-            {
-                try
             {
                 await Task.Delay(1000).ConfigureAwait(false);
                 await Reconnect().ConfigureAwait(false);
-                }
-                catch (Exception ex)
-                {
-                    // fire-and-forget: гарантированно не роняем процесс необработанным исключением.
-                    _log.Warn("Ошибка отложенного переподключения SSH: " + ex.Message);
-                }
             });
         }
 
         private async Task Reconnect()
         {
-            if (_disposed)
-            {
-                return;
-            }
-
-            // Неблокирующая попытка захватить шлюз: если реконнект уже идёт — выходим,
-            // не создавая второй параллельный Connect() и не накапливая очередь.
-            if (!await _reconnectGate.WaitAsync(0).ConfigureAwait(false))
+            if (_reconnectInProgress || _disposed)
             {
                 return;
             }
 
+            _reconnectInProgress = true;
             try
             {
-                if (_disposed)
-                {
-                    return;
-                }
-
+                var timeout = Math.Min(60, Math.Max(5, _settings.ReconnectTimeoutSec));
                 _log.Warn("Перезапуск SSH-соединения...");
 
-                // Connect() ограничен ConnectionInfo.Timeout, поэтому не зависнет навсегда.
-                // Ждём завершения задачи (без брошенного WhenAny) — нет орфанных SshClient.
-                await Task.Run(() =>
+                var reconnectTask = Task.Run(() =>
                 {
                     DisconnectCore();
                     Connect();
-                }).ConfigureAwait(false);
+                });
 
+                var completed = await Task.WhenAny(reconnectTask, Task.Delay(TimeSpan.FromSeconds(timeout))).ConfigureAwait(false);
+                if (completed != reconnectTask)
+                {
+                    _log.Error("Переподключение превысило таймаут " + timeout + "с.");
+                }
+                else
+                {
                     _log.Info("SSH-соединение восстановлено.");
                 }
+            }
             catch (Exception ex)
             {
                 _log.Error("Ошибка переподключения SSH: " + ex.Message);
             }
             finally
             {
-                _reconnectGate.Release();
+                _reconnectInProgress = false;
             }
         }
 
         private void DisconnectCore()
-        {
-            lock (_sync)
         {
             StopRemoteHeartbeatNoLock();
+            StopProbePortNoLock();
 
             try
             {
@@ -220,7 +249,6 @@ namespace MonsterMonitor.Services
                     {
                         _forwardedPort.Stop();
                     }
-                        _forwardedPort.Exception -= ForwardedPortOnException;
                     _forwardedPort.Dispose();
                     _forwardedPort = null;
                 }
@@ -234,7 +262,6 @@ namespace MonsterMonitor.Services
             {
                 if (_client != null)
                 {
-                        _client.ErrorOccurred -= ClientOnErrorOccurred;
                     if (_client.IsConnected)
                     {
                         _client.Disconnect();
@@ -248,6 +275,112 @@ namespace MonsterMonitor.Services
                 // Ignore errors on shutdown.
             }
         }
+
+        /// <summary>
+        /// Поднимает локальный проброс на серверный RemotePort. Подключение к нему
+        /// проходит весь маршрут целиком: наш процесс -> SSH -> слушатель обратного
+        /// проброса на сервере -> SSH обратно -> наш LocalPort (ss.exe).
+        /// Успешный TCP-connect означает, что проброс реально пропускает трафик,
+        /// а не просто "сессия жива".
+        /// </summary>
+        private void StartProbePortNoLock()
+        {
+            StopProbePortNoLock();
+
+            try
+            {
+                _probeLocalPort = FindFreeLocalPort();
+                _probePort = new ForwardedPortLocal(
+                    "127.0.0.1",
+                    (uint)_probeLocalPort,
+                    "127.0.0.1",
+                    (uint)_settings.RemotePort);
+                _client.AddForwardedPort(_probePort);
+                _probePort.Start();
+                _log.Info($"e2e-проверка проброса включена (127.0.0.1:{_probeLocalPort}).");
+            }
+            catch (Exception ex)
+            {
+                _probePort = null;
+                _log.Warn("Не удалось поднять порт e2e-проверки: " + ex.Message);
+            }
+        }
+
+        private void StopProbePortNoLock()
+        {
+            try
+            {
+                if (_probePort != null)
+                {
+                    if (_probePort.IsStarted)
+                    {
+                        _probePort.Stop();
+                    }
+
+                    _probePort.Dispose();
+                    _probePort = null;
+                }
+            }
+            catch
+            {
+                // Ignore errors on shutdown.
+            }
+        }
+
+        private static int FindFreeLocalPort()
+        {
+            var listener = new TcpListener(IPAddress.Loopback, 0);
+            listener.Start();
+            try
+            {
+                return ((IPEndPoint)listener.LocalEndpoint).Port;
+            }
+            finally
+            {
+                listener.Stop();
+            }
+        }
+
+        private async Task<bool> ProbeForwardAsync()
+        {
+            ForwardedPortLocal probe;
+            int port;
+            lock (_sync)
+            {
+                probe = _probePort;
+                port = _probeLocalPort;
+            }
+
+            if (probe == null || !probe.IsStarted || port <= 0)
+            {
+                // Порт проверки поднять не удалось - не выдумываем отказ проброса,
+                // иначе будем рвать рабочий туннель из-за собственной диагностики.
+                return true;
+            }
+
+            var timeoutMs = Math.Max(1, _settings.ProbeTimeoutSec) * 1000;
+
+            try
+            {
+                using (var tcp = new TcpClient())
+                {
+                    var connectTask = tcp.ConnectAsync(IPAddress.Loopback, port);
+                    var completed = await Task.WhenAny(connectTask, Task.Delay(timeoutMs)).ConfigureAwait(false);
+                    if (completed != connectTask)
+                    {
+                        _log.Debug("e2e-проверка: таймаут подключения через проброс.");
+                        return false;
+                    }
+
+                    await connectTask.ConfigureAwait(false);
+                    return tcp.Connected;
+                }
+            }
+            catch (Exception ex)
+            {
+                _log.Debug("e2e-проверка: " + ex.Message);
+                return false;
+            }
         }
 
         private void StartRemoteHeartbeatNoLock()
@@ -266,7 +399,7 @@ namespace MonsterMonitor.Services
 
             _heartbeatCommand = _client.CreateCommand(heartbeatCommand);
             _heartbeatReadTokenSource = new CancellationTokenSource();
-            Interlocked.Exchange(ref _lastHeartbeatTicks, DateTime.UtcNow.Ticks);
+            _lastHeartbeatUtc = DateTime.UtcNow;
             _heartbeatCommand.BeginExecute();
 
             _heartbeatReadTask = Task.Run(() =>
@@ -318,7 +451,7 @@ namespace MonsterMonitor.Services
                             continue;
                         }
 
-                        Interlocked.Exchange(ref _lastHeartbeatTicks, DateTime.UtcNow.Ticks);
+                        _lastHeartbeatUtc = DateTime.UtcNow;
                         _log.Debug("HB: " + line);
                     }
                 }
@@ -336,12 +469,10 @@ namespace MonsterMonitor.Services
         {
             try
             {
-                using (var command = _client.CreateCommand("cmd /c ver"))
-                {
+                var command = _client.CreateCommand("cmd /c ver");
                 var output = command.Execute() ?? string.Empty;
                 return output.IndexOf("windows", StringComparison.OrdinalIgnoreCase) >= 0;
             }
-            }
             catch
             {
                 return false;
@@ -350,35 +481,19 @@ namespace MonsterMonitor.Services
 
         public void Stop()
         {
-            var monitorTokenSource = _monitorTokenSource;
-            var monitorTask = _monitorTask;
+            _monitorTokenSource?.Cancel();
+            _monitorTokenSource?.Dispose();
             _monitorTokenSource = null;
-            _monitorTask = null;
-
-            try
+            lock (_sync)
             {
-                monitorTokenSource?.Cancel();
-                // Дожидаемся завершения цикла монитора до освобождения CTS,
-                // иначе Task.Delay(token) может словить ObjectDisposedException.
-                monitorTask?.Wait(TimeSpan.FromSeconds(2));
-            }
-            catch
-            {
-                // Ignore shutdown errors.
-            }
-            finally
-            {
-                monitorTokenSource?.Dispose();
-            }
-
                 DisconnectCore();
             }
+        }
 
         public void Dispose()
         {
             _disposed = true;
             Stop();
-            _reconnectGate.Dispose();
         }
     }
 }

src/MonsterMonitor/UI/MainForm.cs

@@ -1,11 +1,10 @@
-using MonsterMonitor.Models;
-using MonsterMonitor.Services;
 using System;
-using System.Collections.Concurrent;
 using System.Drawing;
 using System.Runtime.InteropServices;
 using System.Threading.Tasks;
 using System.Windows.Forms;
+using MonsterMonitor.Models;
+using MonsterMonitor.Services;
 
 namespace MonsterMonitor.UI
 {
@@ -13,19 +12,12 @@ namespace MonsterMonitor.UI
     {
         private const int EmGetFirstVisibleLine = 0x00CE;
         private const int EmLineScroll = 0x00B6;
-        private const int WmSetRedraw = 0x000B;
-
-        // Ограничение размера буфера консоли, чтобы текст не рос бесконечно.
-        private const int ConsoleMaxChars = 100000;
-        private const int ConsoleTrimToChars = 80000;
 
         private readonly RichTextBox _console = new RichTextBox();
         private readonly Button _btnSettings = new Button();
         private readonly Button _btnExit = new Button();
         private readonly NotifyIcon _notifyIcon = new NotifyIcon();
         private readonly Timer _updateTimer = new Timer();
-        private readonly Timer _logFlushTimer = new Timer();
-        private readonly ConcurrentQueue<LogEntry> _pendingLogs = new ConcurrentQueue<LogEntry>();
         private readonly Icon _trayIcon;
         private readonly LogService _log = new LogService();
         private readonly PowerManagementService _power = new PowerManagementService();
@@ -42,7 +34,6 @@ namespace MonsterMonitor.UI
             Height = 620;
             StartPosition = FormStartPosition.CenterScreen;
             _trayIcon = LoadTrayIcon();
-            Icon = _trayIcon;
 
             BuildUi();
             BindEvents();
@@ -51,11 +42,12 @@ namespace MonsterMonitor.UI
         protected override void OnLoad(EventArgs e)
         {
             base.OnLoad(e);
+            System.ComponentModel.ComponentResourceManager resources = new System.ComponentModel.ComponentResourceManager(typeof(MainForm));
+            this.Icon = ((System.Drawing.Icon)(resources.GetObject("$this.Icon")));
 
             _settings = AppSettings.Load();
             _controller = new AppController(_log, _power);
             _updateService = new GitHubUpdateService(_log, _settings);
-            ConfigureLogFlushTimer();
             RestartServices();
             ConfigureUpdateTimer();
             _ = RunUpdateCheckAsync(true);
@@ -189,63 +181,32 @@ namespace MonsterMonitor.UI
                 return;
             }
 
-            // Останавливаем таймеры заранее, чтобы не было тиков во время разрушения формы.
-            _logFlushTimer.Stop();
-            _updateTimer.Stop();
             _notifyIcon.Visible = false;
+            _updateTimer.Stop();
+            _updateTimer.Dispose();
+            _controller?.Dispose();
+            _trayIcon?.Dispose();
         }
 
-        private void ConfigureLogFlushTimer()
-        {
-            // Логи копятся в очереди и выводятся пачкой ~10 раз в секунду,
-            // а не по одной строке за событие — это снимает нагрузку на CPU и убирает мерцание.
-            _logFlushTimer.Interval = 100;
-            _logFlushTimer.Tick += (_, __) => FlushLogs();
-            _logFlushTimer.Start();
-        }
-
-        // Вызывается из фоновых потоков — только кладём запись в очередь, без обращения к UI.
         private void AppendLog(LogEntry entry)
         {
-            _pendingLogs.Enqueue(entry);
-        }
-
-        // Выполняется всегда в UI-потоке (таймер WinForms).
-        private void FlushLogs()
-        {
-            if (_pendingLogs.IsEmpty || !_console.IsHandleCreated)
+            if (InvokeRequired)
             {
+                BeginInvoke(new Action<LogEntry>(AppendLog), entry);
                 return;
             }
 
             var wasNearBottom = IsConsoleNearBottom();
             var firstVisibleLineBeforeAppend = GetFirstVisibleLine(_console);
 
-            // Замораживаем отрисовку на время пакетного добавления — одна перерисовка вместо десятков.
-            SendMessage(_console.Handle, WmSetRedraw, IntPtr.Zero, IntPtr.Zero);
-            try
-            {
-                while (_pendingLogs.TryDequeue(out var entry))
-                {
             _console.SelectionStart = _console.TextLength;
             _console.SelectionLength = 0;
             _console.SelectionColor = GetColor(entry.Level);
             _console.AppendText($"[{entry.Timestamp:HH:mm:ss}] [{entry.Level}] {entry.Message}{Environment.NewLine}");
             _console.SelectionColor = _console.ForeColor;
-                }
-
-                TrimConsole();
-            }
-            finally
-            {
-                SendMessage(_console.Handle, WmSetRedraw, (IntPtr)1, IntPtr.Zero);
-                _console.Invalidate();
-            }
 
             if (wasNearBottom)
             {
-                _console.SelectionStart = _console.TextLength;
-                _console.SelectionLength = 0;
                 _console.ScrollToCaret();
                 return;
             }
@@ -258,28 +219,6 @@ namespace MonsterMonitor.UI
             }
         }
 
-        // Обрезаем старые строки, а не сбрасываем весь буфер — плавно и без рывка скролла.
-        private void TrimConsole()
-        {
-            if (_console.TextLength <= ConsoleMaxChars)
-            {
-                return;
-            }
-
-            var removeUpTo = _console.TextLength - ConsoleTrimToChars;
-            var line = _console.GetLineFromCharIndex(removeUpTo);
-            var cut = _console.GetFirstCharIndexFromLine(line + 1);
-            if (cut <= 0)
-            {
-                cut = removeUpTo;
-            }
-
-            _console.Select(0, cut);
-            _console.SelectedText = string.Empty;
-            _console.SelectionStart = _console.TextLength;
-            _console.SelectionLength = 0;
-        }
-
         private bool IsConsoleNearBottom()
         {
             if (_console.TextLength == 0)
@@ -330,11 +269,6 @@ namespace MonsterMonitor.UI
 
                 await _updateService.CheckAndPrepareUpdateAsync();
             }
-            catch (Exception ex)
-            {
-                // async void (Timer.Tick) — необработанное исключение уронило бы приложение.
-                _log.Error("Ошибка проверки обновлений: " + ex.Message);
-            }
             finally
             {
                 _isUpdateCheckRunning = false;
@@ -362,25 +296,18 @@ namespace MonsterMonitor.UI
             return ((System.Drawing.Icon)(resources.GetObject("$this.Icon")));
         }
 
-        protected override void Dispose(bool disposing)
+        private void InitializeComponent()
         {
-            if (disposing)
-            {
-                _log.LogReceived -= AppendLog;
+            System.ComponentModel.ComponentResourceManager resources = new System.ComponentModel.ComponentResourceManager(typeof(MainForm));
+            this.SuspendLayout();
+            // 
+            // MainForm
+            // 
+            this.ClientSize = new System.Drawing.Size(284, 261);
+            this.Icon = ((System.Drawing.Icon)(resources.GetObject("$this.Icon")));
+            this.Name = "MainForm";
+            this.ResumeLayout(false);
 
-                _logFlushTimer.Stop();
-                _logFlushTimer.Dispose();
-                _updateTimer.Stop();
-                _updateTimer.Dispose();
-
-                _controller?.Dispose();
-
-                _notifyIcon.Visible = false;
-                _notifyIcon.Dispose();
-                _trayIcon?.Dispose();
-            }
-
-            base.Dispose(disposing);
         }
     }
 }

src/MonsterMonitor/UI/SettingsForm.cs

@@ -1,3 +1,4 @@
+using System;
 using System.Drawing;
 using System.Security.Cryptography;
 using System.Windows.Forms;
@@ -64,7 +65,7 @@ namespace MonsterMonitor.UI
             AddRow(panel, string.Empty, _chkSavePassword, 4);
             AddRow(panel, "Удаленный порт:", _numRemotePort, 5);
             AddRow(panel, "Локальный порт:", _numLocalPort, 6);
-            AddRow(panel, "Макс. потерь:", _numMaxFailures, 7);
+            AddRow(panel, "Молчание heartbeat (сек):", _numMaxFailures, 7);
             AddRow(panel, "Таймаут reconnect (сек):", _numReconnectTimeout, 8);
             AddRow(panel, "Прокси (http://host:port):", _txtProxy, 9);
             AddRow(panel, "Путь к ss:", _txtSsPath, 10);
@@ -78,8 +79,8 @@ namespace MonsterMonitor.UI
                 num.Maximum = 65535;
             }
 
-            _numMaxFailures.Minimum = 1;
-            _numMaxFailures.Maximum = 10;
+            _numMaxFailures.Minimum = 10;
+            _numMaxFailures.Maximum = 600;
             _numReconnectTimeout.Minimum = 5;
             _numReconnectTimeout.Maximum = 60;
 
@@ -194,14 +195,14 @@ namespace MonsterMonitor.UI
         private void LoadValues()
         {
             _txtHost.Text = _settings.SshHost;
-            _numSshPort.Value = Clamp(_numSshPort, _settings.SshPort);
+            _numSshPort.Value = _settings.SshPort;
             _txtUser.Text = _settings.SshUsername;
             _txtPassword.Text = _settings.GetPassword();
             _chkSavePassword.Checked = _settings.SavePassword;
-            _numRemotePort.Value = Clamp(_numRemotePort, _settings.RemotePort);
-            _numLocalPort.Value = Clamp(_numLocalPort, _settings.LocalPort);
-            _numMaxFailures.Value = Clamp(_numMaxFailures, _settings.MaxPingFailures);
-            _numReconnectTimeout.Value = Clamp(_numReconnectTimeout, _settings.ReconnectTimeoutSec);
+            _numRemotePort.Value = _settings.RemotePort;
+            _numLocalPort.Value = _settings.LocalPort;
+            _numMaxFailures.Value = Math.Min(600, Math.Max(10, _settings.HeartbeatSilenceSec));
+            _numReconnectTimeout.Value = _settings.ReconnectTimeoutSec;
             _txtProxy.Text = _settings.Proxy;
             _txtSsPath.Text = _settings.SsProcessPath;
             _txtSsArgs.Text = _settings.SsArguments;
@@ -209,23 +210,6 @@ namespace MonsterMonitor.UI
             _txtThreeProxyPassword.Text = _settings.GetThreeProxyPassword();
         }
 
-        // Приводит значение из настроек к допустимому диапазону контрола,
-        // иначе NumericUpDown.Value бросит ArgumentOutOfRangeException и окно не откроется.
-        private static decimal Clamp(NumericUpDown control, int value)
-        {
-            if (value < control.Minimum)
-            {
-                return control.Minimum;
-            }
-
-            if (value > control.Maximum)
-            {
-                return control.Maximum;
-            }
-
-            return value;
-        }
-
         private void SaveAndClose()
         {
             if (string.IsNullOrWhiteSpace(_txtHost.Text))
@@ -241,7 +225,7 @@ namespace MonsterMonitor.UI
             _settings.SetPassword(_txtPassword.Text);
             _settings.RemotePort = (int)_numRemotePort.Value;
             _settings.LocalPort = (int)_numLocalPort.Value;
-            _settings.MaxPingFailures = (int)_numMaxFailures.Value;
+            _settings.HeartbeatSilenceSec = (int)_numMaxFailures.Value;
             _settings.ReconnectTimeoutSec = (int)_numReconnectTimeout.Value;
             _settings.Proxy = _txtProxy.Text.Trim();
             _settings.SsProcessPath = string.IsNullOrWhiteSpace(_txtSsPath.Text)