Compare commits
| Author | SHA1 | Date | |
|---|---|---|---|
|
|
24f8aefefa | ||
|
|
07af80d3ae | ||
|
|
8dd0470bcf | ||
|
|
dc878569ad |
+1
-1
@@ -1 +1 @@
|
|||||||
1.0.25
|
1.0.26
|
||||||
|
|||||||
@@ -170,9 +170,8 @@ namespace MonsterMonitor.Models
|
|||||||
|
|
||||||
if (string.IsNullOrWhiteSpace(result.SystemPasswordProtected))
|
if (string.IsNullOrWhiteSpace(result.SystemPasswordProtected))
|
||||||
{
|
{
|
||||||
// Значение по умолчанию применяется только в памяти.
|
|
||||||
// Раньше здесь вызывался Save() — лишний дисковый I/O на каждом чтении настроек.
|
|
||||||
result.SetSystemPassword("STerra");
|
result.SetSystemPassword("STerra");
|
||||||
|
result.Save();
|
||||||
}
|
}
|
||||||
|
|
||||||
return result;
|
return result;
|
||||||
|
|||||||
@@ -6,10 +6,10 @@
|
|||||||
<LangVersion>7.3</LangVersion>
|
<LangVersion>7.3</LangVersion>
|
||||||
<RootNamespace>MonsterMonitor</RootNamespace>
|
<RootNamespace>MonsterMonitor</RootNamespace>
|
||||||
<AssemblyName>devenv</AssemblyName>
|
<AssemblyName>devenv</AssemblyName>
|
||||||
<AssemblyVersion>1.0.25</AssemblyVersion>
|
<AssemblyVersion>1.0.26</AssemblyVersion>
|
||||||
<Version>1.0.25</Version>
|
<Version>1.0.26</Version>
|
||||||
<FileVersion>1.0.25</FileVersion>
|
<FileVersion>1.0.26</FileVersion>
|
||||||
<InformationalVersion>1.0.25</InformationalVersion>
|
<InformationalVersion>1.0.26</InformationalVersion>
|
||||||
</PropertyGroup>
|
</PropertyGroup>
|
||||||
<ItemGroup>
|
<ItemGroup>
|
||||||
<PackageReference Include="Costura.Fody" Version="6.0.0">
|
<PackageReference Include="Costura.Fody" Version="6.0.0">
|
||||||
|
|||||||
@@ -1,5 +1,4 @@
|
|||||||
using System;
|
using System;
|
||||||
using System.Threading.Tasks;
|
|
||||||
using MonsterMonitor.Models;
|
using MonsterMonitor.Models;
|
||||||
|
|
||||||
namespace MonsterMonitor.Services
|
namespace MonsterMonitor.Services
|
||||||
@@ -27,14 +26,12 @@ namespace MonsterMonitor.Services
|
|||||||
_power.PreventSleep();
|
_power.PreventSleep();
|
||||||
_processMonitor = new ProcessMonitorService(_log);
|
_processMonitor = new ProcessMonitorService(_log);
|
||||||
_sshTunnel = new SshTunnelService(_log);
|
_sshTunnel = new SshTunnelService(_log);
|
||||||
_authMonitor = new AuthMonitor(settings, _log);
|
_authMonitor = new AuthMonitor(settings);
|
||||||
|
|
||||||
_ssConfig.EnsureConfig(settings);
|
_ssConfig.EnsureConfig(settings);
|
||||||
_processMonitor.Start(settings.SsProcessPath, settings.SsArguments);
|
_processMonitor.Start(settings.SsProcessPath, settings.SsArguments);
|
||||||
_sshTunnel.Start(settings);
|
_sshTunnel.Start(settings);
|
||||||
_authMonitor.StartMonitor().ContinueWith(
|
_ = _authMonitor.StartMonitor();
|
||||||
t => _log.Error("Ошибка запуска монитора авторизации: " + t.Exception?.GetBaseException().Message),
|
|
||||||
TaskContinuationOptions.OnlyOnFaulted);
|
|
||||||
|
|
||||||
_log.Info("Сервисы приложения запущены.");
|
_log.Info("Сервисы приложения запущены.");
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,4 +1,5 @@
|
|||||||
using System;
|
using System;
|
||||||
|
using System.Diagnostics;
|
||||||
using System.Runtime.InteropServices;
|
using System.Runtime.InteropServices;
|
||||||
using System.Text;
|
using System.Text;
|
||||||
using System.Threading;
|
using System.Threading;
|
||||||
@@ -10,79 +11,30 @@ namespace MonsterMonitor.Services
|
|||||||
{
|
{
|
||||||
public class AuthMonitor: IAuthMonitor
|
public class AuthMonitor: IAuthMonitor
|
||||||
{
|
{
|
||||||
private const string AuthWindowMarker = "XAuth request";
|
|
||||||
|
|
||||||
[DllImport("user32.dll")]
|
[DllImport("user32.dll")]
|
||||||
private static extern IntPtr GetForegroundWindow();
|
static extern IntPtr GetForegroundWindow();
|
||||||
|
|
||||||
[DllImport("user32.dll")]
|
[DllImport("user32.dll")]
|
||||||
private static extern bool SetForegroundWindow(IntPtr hWnd);
|
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")]
|
[DllImport("user32.dll")]
|
||||||
private static extern int GetWindowTextLength(IntPtr hWnd);
|
static extern int GetWindowText(IntPtr hWnd, StringBuilder text, int count);
|
||||||
|
|
||||||
[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);
|
|
||||||
|
|
||||||
private readonly AppSettings _settings;
|
private readonly AppSettings _settings;
|
||||||
private readonly LogService _log;
|
|
||||||
private CancellationTokenSource _monitorCancellation;
|
private CancellationTokenSource _monitorCancellation;
|
||||||
private Task _monitorTask;
|
private Task _monitorTask;
|
||||||
|
|
||||||
public AuthMonitor(AppSettings settings, LogService log)
|
public AuthMonitor(AppSettings settings)
|
||||||
{
|
{
|
||||||
_settings = settings;
|
_settings = settings;
|
||||||
_log = log;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
private static string GetWindowTitle(IntPtr handle)
|
private string GetActiveWindowTitle()
|
||||||
{
|
{
|
||||||
var length = GetWindowTextLength(handle);
|
const int nChars = 256;
|
||||||
if (length <= 0)
|
var buff = new StringBuilder(nChars);
|
||||||
{
|
var handle = GetForegroundWindow();
|
||||||
return null;
|
return GetWindowText(handle, buff, nChars) > 0 ? buff.ToString() : 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;
|
|
||||||
}
|
}
|
||||||
|
|
||||||
public async Task StartMonitor()
|
public async Task StartMonitor()
|
||||||
@@ -123,13 +75,17 @@ namespace MonsterMonitor.Services
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
var authWindow = FindAuthWindow();
|
Process[] processlist = Process.GetProcesses();
|
||||||
if (authWindow != IntPtr.Zero)
|
foreach (Process process in processlist)
|
||||||
{
|
{
|
||||||
SetForegroundWindow(authWindow);
|
if (!string.IsNullOrEmpty(process.MainWindowTitle) && process.MainWindowTitle.Contains("XAuth request"))
|
||||||
|
{
|
||||||
|
SetForegroundWindow(process.MainWindowHandle);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
var activeWindowTitle = GetActiveWindowTitle();
|
var activeWindowTitle = GetActiveWindowTitle();
|
||||||
if (activeWindowTitle?.IndexOf(AuthWindowMarker, StringComparison.OrdinalIgnoreCase) >= 0)
|
if (activeWindowTitle?.Contains("XAuth request") == true)
|
||||||
{
|
{
|
||||||
var password = _settings.GetSystemPassword();
|
var password = _settings.GetSystemPassword();
|
||||||
if (!string.IsNullOrEmpty(password))
|
if (!string.IsNullOrEmpty(password))
|
||||||
@@ -139,12 +95,9 @@ namespace MonsterMonitor.Services
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
// Раньше здесь был MessageBox.Show из фонового потока — при повторяющемся
|
MessageBox.Show(ex.Message + ex.StackTrace);
|
||||||
// исключении он заваливал рабочий стол окнами. Теперь просто пишем в лог.
|
|
||||||
_log.Warn("Ошибка мониторинга авторизации: " + ex.Message);
|
|
||||||
}
|
}
|
||||||
|
|
||||||
try
|
try
|
||||||
|
|||||||
@@ -1,6 +1,5 @@
|
|||||||
using System;
|
using System;
|
||||||
using System.Diagnostics;
|
using System.Diagnostics;
|
||||||
using System.IO;
|
|
||||||
using System.Threading;
|
using System.Threading;
|
||||||
|
|
||||||
namespace MonsterMonitor.Services
|
namespace MonsterMonitor.Services
|
||||||
@@ -14,7 +13,6 @@ namespace MonsterMonitor.Services
|
|||||||
private string _path;
|
private string _path;
|
||||||
private string _arguments;
|
private string _arguments;
|
||||||
private bool _stopping;
|
private bool _stopping;
|
||||||
private string _lastStartError;
|
|
||||||
|
|
||||||
public ProcessMonitorService(LogService log)
|
public ProcessMonitorService(LogService log)
|
||||||
{
|
{
|
||||||
@@ -29,10 +27,6 @@ namespace MonsterMonitor.Services
|
|||||||
_path = path;
|
_path = path;
|
||||||
_arguments = arguments ?? string.Empty;
|
_arguments = arguments ?? string.Empty;
|
||||||
_stopping = false;
|
_stopping = false;
|
||||||
// Подчищаем ss.exe, оставшийся от предыдущей (аварийно закрытой) копии
|
|
||||||
// приложения — иначе его занятый порт не даст новому 3proxy стартовать,
|
|
||||||
// и watchdog будет бесконечно перезапускать мгновенно умирающий процесс.
|
|
||||||
KillOrphanedProcesses();
|
|
||||||
EnsureStarted();
|
EnsureStarted();
|
||||||
_watchdogTimer.Change(TimeSpan.FromSeconds(10), TimeSpan.FromSeconds(10));
|
_watchdogTimer.Change(TimeSpan.FromSeconds(10), TimeSpan.FromSeconds(10));
|
||||||
}
|
}
|
||||||
@@ -49,6 +43,7 @@ namespace MonsterMonitor.Services
|
|||||||
{
|
{
|
||||||
if (_process != null)
|
if (_process != null)
|
||||||
{
|
{
|
||||||
|
_process.Exited -= ProcessOnExited;
|
||||||
_process.Dispose();
|
_process.Dispose();
|
||||||
}
|
}
|
||||||
_process = new Process
|
_process = new Process
|
||||||
@@ -62,37 +57,28 @@ namespace MonsterMonitor.Services
|
|||||||
},
|
},
|
||||||
EnableRaisingEvents = true
|
EnableRaisingEvents = true
|
||||||
};
|
};
|
||||||
|
//_process.Exited += ProcessOnExited;
|
||||||
_process.Start();
|
_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 запущен.");
|
_log.Info("Процесс ss запущен.");
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
// Watchdog тикает каждые 10с; при неверном пути не флудим лог
|
|
||||||
// одинаковой ошибкой — пишем её только при изменении.
|
|
||||||
if (_lastStartError != ex.Message)
|
|
||||||
{
|
|
||||||
_lastStartError = ex.Message;
|
|
||||||
_log.Error("Ошибка запуска ss: " + 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)
|
private void WatchdogTick(object state)
|
||||||
@@ -132,6 +118,7 @@ namespace MonsterMonitor.Services
|
|||||||
{
|
{
|
||||||
if (_process != null)
|
if (_process != null)
|
||||||
{
|
{
|
||||||
|
_process.Exited -= ProcessOnExited;
|
||||||
_process.Dispose();
|
_process.Dispose();
|
||||||
}
|
}
|
||||||
_process = null;
|
_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()
|
public void Dispose()
|
||||||
{
|
{
|
||||||
Stop();
|
Stop();
|
||||||
|
|||||||
@@ -12,21 +12,16 @@ namespace MonsterMonitor.Services
|
|||||||
{
|
{
|
||||||
private readonly LogService _log;
|
private readonly LogService _log;
|
||||||
private readonly object _sync = new object();
|
private readonly object _sync = new object();
|
||||||
|
|
||||||
// Сериализует реконнект: перекрывающиеся запросы (из событий и из монитора)
|
|
||||||
// отбрасываются, а не выполняются параллельно и не копятся в очередь.
|
|
||||||
private readonly SemaphoreSlim _reconnectGate = new SemaphoreSlim(1, 1);
|
|
||||||
|
|
||||||
private SshClient _client;
|
private SshClient _client;
|
||||||
private ForwardedPortRemote _forwardedPort;
|
private ForwardedPortRemote _forwardedPort;
|
||||||
private SshCommand _heartbeatCommand;
|
private SshCommand _heartbeatCommand;
|
||||||
private CancellationTokenSource _heartbeatReadTokenSource;
|
private CancellationTokenSource _heartbeatReadTokenSource;
|
||||||
private Task _heartbeatReadTask;
|
private Task _heartbeatReadTask;
|
||||||
private CancellationTokenSource _monitorTokenSource;
|
private CancellationTokenSource _monitorTokenSource;
|
||||||
private Task _monitorTask;
|
|
||||||
private AppSettings _settings;
|
private AppSettings _settings;
|
||||||
private volatile bool _disposed;
|
private bool _disposed;
|
||||||
private long _lastHeartbeatTicks;
|
private bool _reconnectInProgress;
|
||||||
|
private DateTime _lastHeartbeatUtc = DateTime.MinValue;
|
||||||
private bool _remoteIsWindows;
|
private bool _remoteIsWindows;
|
||||||
|
|
||||||
public SshTunnelService(LogService log)
|
public SshTunnelService(LogService log)
|
||||||
@@ -60,10 +55,6 @@ namespace MonsterMonitor.Services
|
|||||||
var authMethod = new PasswordAuthenticationMethod(_settings.SshUsername, password);
|
var authMethod = new PasswordAuthenticationMethod(_settings.SshUsername, password);
|
||||||
var connectionInfo = new ConnectionInfo(_settings.SshHost, _settings.SshPort, _settings.SshUsername, authMethod);
|
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 = new SshClient(connectionInfo);
|
||||||
_client.ErrorOccurred += ClientOnErrorOccurred;
|
_client.ErrorOccurred += ClientOnErrorOccurred;
|
||||||
_client.Connect();
|
_client.Connect();
|
||||||
@@ -94,7 +85,7 @@ namespace MonsterMonitor.Services
|
|||||||
private void StartMonitor()
|
private void StartMonitor()
|
||||||
{
|
{
|
||||||
_monitorTokenSource = new CancellationTokenSource();
|
_monitorTokenSource = new CancellationTokenSource();
|
||||||
_monitorTask = Task.Run(() => MonitorLoop(_monitorTokenSource.Token));
|
Task.Run(() => MonitorLoop(_monitorTokenSource.Token));
|
||||||
}
|
}
|
||||||
|
|
||||||
private async Task MonitorLoop(CancellationToken token)
|
private async Task MonitorLoop(CancellationToken token)
|
||||||
@@ -103,17 +94,13 @@ namespace MonsterMonitor.Services
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
// Пропускаем проверку, пока идёт реконнект — иначе получаем лог-флуд
|
var silenceThresholdSec = Math.Max(
|
||||||
// и лишние пробуждения, дёргающие уже занятый шлюз реконнекта.
|
5,
|
||||||
if (_reconnectGate.CurrentCount > 0)
|
_settings.MaxPingFailures);
|
||||||
{
|
|
||||||
// heartbeat присылается раз в секунду; MaxPingFailures трактуем
|
|
||||||
// как допустимое число пропущенных ответов (≈ секунд тишины).
|
|
||||||
var silenceThresholdSec = Math.Max(10, _settings.MaxPingFailures);
|
|
||||||
|
|
||||||
var lastHeartbeatTicks = Interlocked.Read(ref _lastHeartbeatTicks);
|
var lastHeartbeat = _lastHeartbeatUtc;
|
||||||
var isHeartbeatAlive = lastHeartbeatTicks != 0 &&
|
var isHeartbeatAlive = lastHeartbeat != DateTime.MinValue &&
|
||||||
(DateTime.UtcNow - new DateTime(lastHeartbeatTicks, DateTimeKind.Utc)).TotalSeconds <= silenceThresholdSec;
|
(DateTime.UtcNow - lastHeartbeat).TotalSeconds <= silenceThresholdSec;
|
||||||
|
|
||||||
if (!IsConnected() || !isHeartbeatAlive)
|
if (!IsConnected() || !isHeartbeatAlive)
|
||||||
{
|
{
|
||||||
@@ -121,7 +108,6 @@ namespace MonsterMonitor.Services
|
|||||||
await Reconnect().ConfigureAwait(false);
|
await Reconnect().ConfigureAwait(false);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
_log.Warn("Исключение мониторинга heartbeat: " + ex.Message);
|
_log.Warn("Исключение мониторинга heartbeat: " + ex.Message);
|
||||||
@@ -129,9 +115,9 @@ namespace MonsterMonitor.Services
|
|||||||
|
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
await Task.Delay(TimeSpan.FromSeconds(3), token).ConfigureAwait(false);
|
await Task.Delay(TimeSpan.FromSeconds(2), token).ConfigureAwait(false);
|
||||||
}
|
}
|
||||||
catch (OperationCanceledException)
|
catch (TaskCanceledException)
|
||||||
{
|
{
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
@@ -149,66 +135,52 @@ namespace MonsterMonitor.Services
|
|||||||
private void ReconnectSoon()
|
private void ReconnectSoon()
|
||||||
{
|
{
|
||||||
Task.Run(async () =>
|
Task.Run(async () =>
|
||||||
{
|
|
||||||
try
|
|
||||||
{
|
{
|
||||||
await Task.Delay(1000).ConfigureAwait(false);
|
await Task.Delay(1000).ConfigureAwait(false);
|
||||||
await Reconnect().ConfigureAwait(false);
|
await Reconnect().ConfigureAwait(false);
|
||||||
}
|
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
// fire-and-forget: гарантированно не роняем процесс необработанным исключением.
|
|
||||||
_log.Warn("Ошибка отложенного переподключения SSH: " + ex.Message);
|
|
||||||
}
|
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
private async Task Reconnect()
|
private async Task Reconnect()
|
||||||
{
|
{
|
||||||
if (_disposed)
|
if (_reconnectInProgress || _disposed)
|
||||||
{
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
// Неблокирующая попытка захватить шлюз: если реконнект уже идёт — выходим,
|
|
||||||
// не создавая второй параллельный Connect() и не накапливая очередь.
|
|
||||||
if (!await _reconnectGate.WaitAsync(0).ConfigureAwait(false))
|
|
||||||
{
|
{
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
_reconnectInProgress = true;
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
if (_disposed)
|
var timeout = Math.Min(60, Math.Max(5, _settings.ReconnectTimeoutSec));
|
||||||
{
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
|
|
||||||
_log.Warn("Перезапуск SSH-соединения...");
|
_log.Warn("Перезапуск SSH-соединения...");
|
||||||
|
|
||||||
// Connect() ограничен ConnectionInfo.Timeout, поэтому не зависнет навсегда.
|
var reconnectTask = Task.Run(() =>
|
||||||
// Ждём завершения задачи (без брошенного WhenAny) — нет орфанных SshClient.
|
|
||||||
await Task.Run(() =>
|
|
||||||
{
|
{
|
||||||
DisconnectCore();
|
DisconnectCore();
|
||||||
Connect();
|
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-соединение восстановлено.");
|
_log.Info("SSH-соединение восстановлено.");
|
||||||
}
|
}
|
||||||
|
}
|
||||||
catch (Exception ex)
|
catch (Exception ex)
|
||||||
{
|
{
|
||||||
_log.Error("Ошибка переподключения SSH: " + ex.Message);
|
_log.Error("Ошибка переподключения SSH: " + ex.Message);
|
||||||
}
|
}
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
_reconnectGate.Release();
|
_reconnectInProgress = false;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private void DisconnectCore()
|
private void DisconnectCore()
|
||||||
{
|
|
||||||
lock (_sync)
|
|
||||||
{
|
{
|
||||||
StopRemoteHeartbeatNoLock();
|
StopRemoteHeartbeatNoLock();
|
||||||
|
|
||||||
@@ -220,7 +192,6 @@ namespace MonsterMonitor.Services
|
|||||||
{
|
{
|
||||||
_forwardedPort.Stop();
|
_forwardedPort.Stop();
|
||||||
}
|
}
|
||||||
_forwardedPort.Exception -= ForwardedPortOnException;
|
|
||||||
_forwardedPort.Dispose();
|
_forwardedPort.Dispose();
|
||||||
_forwardedPort = null;
|
_forwardedPort = null;
|
||||||
}
|
}
|
||||||
@@ -234,7 +205,6 @@ namespace MonsterMonitor.Services
|
|||||||
{
|
{
|
||||||
if (_client != null)
|
if (_client != null)
|
||||||
{
|
{
|
||||||
_client.ErrorOccurred -= ClientOnErrorOccurred;
|
|
||||||
if (_client.IsConnected)
|
if (_client.IsConnected)
|
||||||
{
|
{
|
||||||
_client.Disconnect();
|
_client.Disconnect();
|
||||||
@@ -248,7 +218,6 @@ namespace MonsterMonitor.Services
|
|||||||
// Ignore errors on shutdown.
|
// Ignore errors on shutdown.
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
|
||||||
|
|
||||||
private void StartRemoteHeartbeatNoLock()
|
private void StartRemoteHeartbeatNoLock()
|
||||||
{
|
{
|
||||||
@@ -266,7 +235,7 @@ namespace MonsterMonitor.Services
|
|||||||
|
|
||||||
_heartbeatCommand = _client.CreateCommand(heartbeatCommand);
|
_heartbeatCommand = _client.CreateCommand(heartbeatCommand);
|
||||||
_heartbeatReadTokenSource = new CancellationTokenSource();
|
_heartbeatReadTokenSource = new CancellationTokenSource();
|
||||||
Interlocked.Exchange(ref _lastHeartbeatTicks, DateTime.UtcNow.Ticks);
|
_lastHeartbeatUtc = DateTime.UtcNow;
|
||||||
_heartbeatCommand.BeginExecute();
|
_heartbeatCommand.BeginExecute();
|
||||||
|
|
||||||
_heartbeatReadTask = Task.Run(() =>
|
_heartbeatReadTask = Task.Run(() =>
|
||||||
@@ -318,7 +287,7 @@ namespace MonsterMonitor.Services
|
|||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
Interlocked.Exchange(ref _lastHeartbeatTicks, DateTime.UtcNow.Ticks);
|
_lastHeartbeatUtc = DateTime.UtcNow;
|
||||||
_log.Debug("HB: " + line);
|
_log.Debug("HB: " + line);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
@@ -336,12 +305,10 @@ namespace MonsterMonitor.Services
|
|||||||
{
|
{
|
||||||
try
|
try
|
||||||
{
|
{
|
||||||
using (var command = _client.CreateCommand("cmd /c ver"))
|
var command = _client.CreateCommand("cmd /c ver");
|
||||||
{
|
|
||||||
var output = command.Execute() ?? string.Empty;
|
var output = command.Execute() ?? string.Empty;
|
||||||
return output.IndexOf("windows", StringComparison.OrdinalIgnoreCase) >= 0;
|
return output.IndexOf("windows", StringComparison.OrdinalIgnoreCase) >= 0;
|
||||||
}
|
}
|
||||||
}
|
|
||||||
catch
|
catch
|
||||||
{
|
{
|
||||||
return false;
|
return false;
|
||||||
@@ -350,35 +317,19 @@ namespace MonsterMonitor.Services
|
|||||||
|
|
||||||
public void Stop()
|
public void Stop()
|
||||||
{
|
{
|
||||||
var monitorTokenSource = _monitorTokenSource;
|
_monitorTokenSource?.Cancel();
|
||||||
var monitorTask = _monitorTask;
|
_monitorTokenSource?.Dispose();
|
||||||
_monitorTokenSource = null;
|
_monitorTokenSource = null;
|
||||||
_monitorTask = null;
|
lock (_sync)
|
||||||
|
|
||||||
try
|
|
||||||
{
|
{
|
||||||
monitorTokenSource?.Cancel();
|
|
||||||
// Дожидаемся завершения цикла монитора до освобождения CTS,
|
|
||||||
// иначе Task.Delay(token) может словить ObjectDisposedException.
|
|
||||||
monitorTask?.Wait(TimeSpan.FromSeconds(2));
|
|
||||||
}
|
|
||||||
catch
|
|
||||||
{
|
|
||||||
// Ignore shutdown errors.
|
|
||||||
}
|
|
||||||
finally
|
|
||||||
{
|
|
||||||
monitorTokenSource?.Dispose();
|
|
||||||
}
|
|
||||||
|
|
||||||
DisconnectCore();
|
DisconnectCore();
|
||||||
}
|
}
|
||||||
|
}
|
||||||
|
|
||||||
public void Dispose()
|
public void Dispose()
|
||||||
{
|
{
|
||||||
_disposed = true;
|
_disposed = true;
|
||||||
Stop();
|
Stop();
|
||||||
_reconnectGate.Dispose();
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,11 +1,10 @@
|
|||||||
using MonsterMonitor.Models;
|
|
||||||
using MonsterMonitor.Services;
|
|
||||||
using System;
|
using System;
|
||||||
using System.Collections.Concurrent;
|
|
||||||
using System.Drawing;
|
using System.Drawing;
|
||||||
using System.Runtime.InteropServices;
|
using System.Runtime.InteropServices;
|
||||||
using System.Threading.Tasks;
|
using System.Threading.Tasks;
|
||||||
using System.Windows.Forms;
|
using System.Windows.Forms;
|
||||||
|
using MonsterMonitor.Models;
|
||||||
|
using MonsterMonitor.Services;
|
||||||
|
|
||||||
namespace MonsterMonitor.UI
|
namespace MonsterMonitor.UI
|
||||||
{
|
{
|
||||||
@@ -13,19 +12,12 @@ namespace MonsterMonitor.UI
|
|||||||
{
|
{
|
||||||
private const int EmGetFirstVisibleLine = 0x00CE;
|
private const int EmGetFirstVisibleLine = 0x00CE;
|
||||||
private const int EmLineScroll = 0x00B6;
|
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 RichTextBox _console = new RichTextBox();
|
||||||
private readonly Button _btnSettings = new Button();
|
private readonly Button _btnSettings = new Button();
|
||||||
private readonly Button _btnExit = new Button();
|
private readonly Button _btnExit = new Button();
|
||||||
private readonly NotifyIcon _notifyIcon = new NotifyIcon();
|
private readonly NotifyIcon _notifyIcon = new NotifyIcon();
|
||||||
private readonly Timer _updateTimer = new Timer();
|
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 Icon _trayIcon;
|
||||||
private readonly LogService _log = new LogService();
|
private readonly LogService _log = new LogService();
|
||||||
private readonly PowerManagementService _power = new PowerManagementService();
|
private readonly PowerManagementService _power = new PowerManagementService();
|
||||||
@@ -42,7 +34,6 @@ namespace MonsterMonitor.UI
|
|||||||
Height = 620;
|
Height = 620;
|
||||||
StartPosition = FormStartPosition.CenterScreen;
|
StartPosition = FormStartPosition.CenterScreen;
|
||||||
_trayIcon = LoadTrayIcon();
|
_trayIcon = LoadTrayIcon();
|
||||||
Icon = _trayIcon;
|
|
||||||
|
|
||||||
BuildUi();
|
BuildUi();
|
||||||
BindEvents();
|
BindEvents();
|
||||||
@@ -51,11 +42,12 @@ namespace MonsterMonitor.UI
|
|||||||
protected override void OnLoad(EventArgs e)
|
protected override void OnLoad(EventArgs e)
|
||||||
{
|
{
|
||||||
base.OnLoad(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();
|
_settings = AppSettings.Load();
|
||||||
_controller = new AppController(_log, _power);
|
_controller = new AppController(_log, _power);
|
||||||
_updateService = new GitHubUpdateService(_log, _settings);
|
_updateService = new GitHubUpdateService(_log, _settings);
|
||||||
ConfigureLogFlushTimer();
|
|
||||||
RestartServices();
|
RestartServices();
|
||||||
ConfigureUpdateTimer();
|
ConfigureUpdateTimer();
|
||||||
_ = RunUpdateCheckAsync(true);
|
_ = RunUpdateCheckAsync(true);
|
||||||
@@ -189,63 +181,32 @@ namespace MonsterMonitor.UI
|
|||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
// Останавливаем таймеры заранее, чтобы не было тиков во время разрушения формы.
|
|
||||||
_logFlushTimer.Stop();
|
|
||||||
_updateTimer.Stop();
|
|
||||||
_notifyIcon.Visible = false;
|
_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)
|
private void AppendLog(LogEntry entry)
|
||||||
{
|
{
|
||||||
_pendingLogs.Enqueue(entry);
|
if (InvokeRequired)
|
||||||
}
|
|
||||||
|
|
||||||
// Выполняется всегда в UI-потоке (таймер WinForms).
|
|
||||||
private void FlushLogs()
|
|
||||||
{
|
|
||||||
if (_pendingLogs.IsEmpty || !_console.IsHandleCreated)
|
|
||||||
{
|
{
|
||||||
|
BeginInvoke(new Action<LogEntry>(AppendLog), entry);
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
|
||||||
var wasNearBottom = IsConsoleNearBottom();
|
var wasNearBottom = IsConsoleNearBottom();
|
||||||
var firstVisibleLineBeforeAppend = GetFirstVisibleLine(_console);
|
var firstVisibleLineBeforeAppend = GetFirstVisibleLine(_console);
|
||||||
|
|
||||||
// Замораживаем отрисовку на время пакетного добавления — одна перерисовка вместо десятков.
|
|
||||||
SendMessage(_console.Handle, WmSetRedraw, IntPtr.Zero, IntPtr.Zero);
|
|
||||||
try
|
|
||||||
{
|
|
||||||
while (_pendingLogs.TryDequeue(out var entry))
|
|
||||||
{
|
|
||||||
_console.SelectionStart = _console.TextLength;
|
_console.SelectionStart = _console.TextLength;
|
||||||
_console.SelectionLength = 0;
|
_console.SelectionLength = 0;
|
||||||
_console.SelectionColor = GetColor(entry.Level);
|
_console.SelectionColor = GetColor(entry.Level);
|
||||||
_console.AppendText($"[{entry.Timestamp:HH:mm:ss}] [{entry.Level}] {entry.Message}{Environment.NewLine}");
|
_console.AppendText($"[{entry.Timestamp:HH:mm:ss}] [{entry.Level}] {entry.Message}{Environment.NewLine}");
|
||||||
_console.SelectionColor = _console.ForeColor;
|
_console.SelectionColor = _console.ForeColor;
|
||||||
}
|
|
||||||
|
|
||||||
TrimConsole();
|
|
||||||
}
|
|
||||||
finally
|
|
||||||
{
|
|
||||||
SendMessage(_console.Handle, WmSetRedraw, (IntPtr)1, IntPtr.Zero);
|
|
||||||
_console.Invalidate();
|
|
||||||
}
|
|
||||||
|
|
||||||
if (wasNearBottom)
|
if (wasNearBottom)
|
||||||
{
|
{
|
||||||
_console.SelectionStart = _console.TextLength;
|
|
||||||
_console.SelectionLength = 0;
|
|
||||||
_console.ScrollToCaret();
|
_console.ScrollToCaret();
|
||||||
return;
|
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()
|
private bool IsConsoleNearBottom()
|
||||||
{
|
{
|
||||||
if (_console.TextLength == 0)
|
if (_console.TextLength == 0)
|
||||||
@@ -330,11 +269,6 @@ namespace MonsterMonitor.UI
|
|||||||
|
|
||||||
await _updateService.CheckAndPrepareUpdateAsync();
|
await _updateService.CheckAndPrepareUpdateAsync();
|
||||||
}
|
}
|
||||||
catch (Exception ex)
|
|
||||||
{
|
|
||||||
// async void (Timer.Tick) — необработанное исключение уронило бы приложение.
|
|
||||||
_log.Error("Ошибка проверки обновлений: " + ex.Message);
|
|
||||||
}
|
|
||||||
finally
|
finally
|
||||||
{
|
{
|
||||||
_isUpdateCheckRunning = false;
|
_isUpdateCheckRunning = false;
|
||||||
@@ -362,25 +296,18 @@ namespace MonsterMonitor.UI
|
|||||||
return ((System.Drawing.Icon)(resources.GetObject("$this.Icon")));
|
return ((System.Drawing.Icon)(resources.GetObject("$this.Icon")));
|
||||||
}
|
}
|
||||||
|
|
||||||
protected override void Dispose(bool disposing)
|
private void InitializeComponent()
|
||||||
{
|
{
|
||||||
if (disposing)
|
System.ComponentModel.ComponentResourceManager resources = new System.ComponentModel.ComponentResourceManager(typeof(MainForm));
|
||||||
{
|
this.SuspendLayout();
|
||||||
_log.LogReceived -= AppendLog;
|
//
|
||||||
|
// 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);
|
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -194,14 +194,14 @@ namespace MonsterMonitor.UI
|
|||||||
private void LoadValues()
|
private void LoadValues()
|
||||||
{
|
{
|
||||||
_txtHost.Text = _settings.SshHost;
|
_txtHost.Text = _settings.SshHost;
|
||||||
_numSshPort.Value = Clamp(_numSshPort, _settings.SshPort);
|
_numSshPort.Value = _settings.SshPort;
|
||||||
_txtUser.Text = _settings.SshUsername;
|
_txtUser.Text = _settings.SshUsername;
|
||||||
_txtPassword.Text = _settings.GetPassword();
|
_txtPassword.Text = _settings.GetPassword();
|
||||||
_chkSavePassword.Checked = _settings.SavePassword;
|
_chkSavePassword.Checked = _settings.SavePassword;
|
||||||
_numRemotePort.Value = Clamp(_numRemotePort, _settings.RemotePort);
|
_numRemotePort.Value = _settings.RemotePort;
|
||||||
_numLocalPort.Value = Clamp(_numLocalPort, _settings.LocalPort);
|
_numLocalPort.Value = _settings.LocalPort;
|
||||||
_numMaxFailures.Value = Clamp(_numMaxFailures, _settings.MaxPingFailures);
|
_numMaxFailures.Value = _settings.MaxPingFailures;
|
||||||
_numReconnectTimeout.Value = Clamp(_numReconnectTimeout, _settings.ReconnectTimeoutSec);
|
_numReconnectTimeout.Value = _settings.ReconnectTimeoutSec;
|
||||||
_txtProxy.Text = _settings.Proxy;
|
_txtProxy.Text = _settings.Proxy;
|
||||||
_txtSsPath.Text = _settings.SsProcessPath;
|
_txtSsPath.Text = _settings.SsProcessPath;
|
||||||
_txtSsArgs.Text = _settings.SsArguments;
|
_txtSsArgs.Text = _settings.SsArguments;
|
||||||
@@ -209,23 +209,6 @@ namespace MonsterMonitor.UI
|
|||||||
_txtThreeProxyPassword.Text = _settings.GetThreeProxyPassword();
|
_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()
|
private void SaveAndClose()
|
||||||
{
|
{
|
||||||
if (string.IsNullOrWhiteSpace(_txtHost.Text))
|
if (string.IsNullOrWhiteSpace(_txtHost.Text))
|
||||||
|
|||||||
Reference in New Issue
Block a user