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

ParallelTransfers property can configure how many parallel download/upload of file chunks can occur at the same time. Default is 2 (optimal for non-premium accounts), was 10 in previous versions.

Browse source
This commit is contained in:
Wizou 2025-06-24 19:11:14 +02:00
parent d49d620edd
commit 04e043222e
1 changed files with 14 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
src/Client.cs
View file

@ -59,6 +59,18 @@ namespace WTelegram
public long UserId => _session.UserId; public long UserId => _session.UserId;
/// <summary>Info about the current logged-in user. This is only filled after a successful (re)login, not updated later</summary> /// <summary>Info about the current logged-in user. This is only filled after a successful (re)login, not updated later</summary>
public User User { get; private set; } public User User { get; private set; }
/// <summary>Number of parallel transfers operations (uploads/downloads) allowed at the same time.</summary>
/// <remarks>Don't use this property while transfers are ongoing!</remarks>
public int ParallelTransfers
{
get => _parallelTransfers.CurrentCount;
set
{
int delta = value - _parallelTransfers.CurrentCount;
for (; delta < 0; delta++) _parallelTransfers.Wait();
if (delta > 0) _parallelTransfers.Release(delta);
}
}
private Func<string, string> _config; private Func<string, string> _config;
private readonly Session _session; private readonly Session _session;
@ -83,7 +95,7 @@ namespace WTelegram
private int _reactorReconnects = 0; private int _reactorReconnects = 0;
private const string ConnectionShutDown = "Could not read payload length : Connection shut down"; private const string ConnectionShutDown = "Could not read payload length : Connection shut down";
private const long Ticks5Secs = 5 * TimeSpan.TicksPerSecond; private const long Ticks5Secs = 5 * TimeSpan.TicksPerSecond;
private readonly SemaphoreSlim _parallelTransfers = new(10); // max parallel part uploads/downloads private readonly SemaphoreSlim _parallelTransfers = new(2); // max parallel part uploads/downloads
private readonly SHA256 _sha256 = SHA256.Create(); private readonly SHA256 _sha256 = SHA256.Create();
private readonly SHA256 _sha256Recv = SHA256.Create(); private readonly SHA256 _sha256Recv = SHA256.Create();
#if OBFUSCATION #if OBFUSCATION
@ -209,7 +221,7 @@ namespace WTelegram
if (_tcpClient != null) throw new InvalidOperationException("Cannot switch to HTTP after TCP connection"); if (_tcpClient != null) throw new InvalidOperationException("Cannot switch to HTTP after TCP connection");
_httpClient = httpClient ?? new(); _httpClient = httpClient ?? new();
_httpWait = defaultHttpWait; _httpWait = defaultHttpWait;
while (_parallelTransfers.CurrentCount > 1) _parallelTransfers.Wait(); ParallelTransfers = 1;
} }
/// <summary>Disconnect from Telegram <i>(shouldn't be needed in normal usage)</i></summary> /// <summary>Disconnect from Telegram <i>(shouldn't be needed in normal usage)</i></summary>