wiz0u/WTelegramClient
1
0
Fork 0
mirror of https://github.com/wiz0u/WTelegramClient.git synced 2025-12-06 06:52:01 +01:00
Code Issues Actions Packages Projects Releases Wiki Activity

DC disconnect bug fix

Browse source
This commit is contained in:
Wizou 2021-10-01 02:44:56 +02:00
parent e7c5d2eb27
commit b01eed2042
1 changed files with 2 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/Client.cs
View file

@ -26,7 +26,7 @@ namespace WTelegram
public Config TLConfig { get; private set; } public Config TLConfig { get; private set; }
public int MaxAutoReconnects { get; set; } = 5; // number of automatic reconnections on connection/reactor failure public int MaxAutoReconnects { get; set; } = 5; // number of automatic reconnections on connection/reactor failure
public bool IsMainDC => (_dcSession?.DataCenter?.id ?? 0) == _session.MainDC; public bool IsMainDC => (_dcSession?.DataCenter?.id ?? 0) == _session.MainDC;
public bool Connected => _tcpClient?.Connected ?? false; public bool Disconnected => _tcpClient != null && !(_tcpClient.Client?.Connected ?? false);
private readonly Func<string, string> _config; private readonly Func<string, string> _config;
private readonly int _apiId; private readonly int _apiId;
@ -134,7 +134,6 @@ namespace WTelegram
_sendSemaphore = new(0); _sendSemaphore = new(0);
_reactorTask = null; _reactorTask = null;
_tcpClient?.Dispose(); _tcpClient?.Dispose();
_tcpClient = null;
_connecting = null; _connecting = null;
if (resetSessions) if (resetSessions)
{ {
@ -252,7 +251,7 @@ namespace WTelegram
lock (_session) lock (_session)
{ {
altSession = GetOrCreateDCSession(dcId, _dcSession.DataCenter.flags | (media_only ? DcOption.Flags.media_only : 0)); altSession = GetOrCreateDCSession(dcId, _dcSession.DataCenter.flags | (media_only ? DcOption.Flags.media_only : 0));
if (!altSession.Client.Connected) { altSession.Client.Dispose(); altSession.Client = null; } if (altSession.Client?.Disconnected ?? false) { altSession.Client.Dispose(); altSession.Client = null; }
altSession.Client ??= new Client(this, altSession); altSession.Client ??= new Client(this, altSession);
} }
Helpers.Log(2, $"Requested connection to DC {dcId}..."); Helpers.Log(2, $"Requested connection to DC {dcId}...");