rms/mirrors-mautrix-telegram
1
0
Fork 0
mirror of https://github.com/mautrix/telegram.git synced 2026-05-17 07:25:46 +03:00
Code Issues Packages Projects Releases Wiki Activity

gotd: fix infinite loop if server keeps replying with timeout to download request

Browse Source
This commit is contained in:
Tulir Asokan
2026-03-28 16:32:37 +02:00
parent bec7ee8f5e
commit 472b9df44c
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
pkg/gotd/telegram/downloader/reader.go
View File

@@ -88,11 +88,13 @@ func (r *reader) nextPlain(ctx context.Context) (block, error) {
}
func (r *reader) next(ctx context.Context, offset int64, limit int) (block, error) {
floodOrTimeoutRetries := 0
for {
ch, err := r.sch.Chunk(ctx, offset, limit)
if flood, err := tgerr.FloodWait(ctx, err); err != nil {
if flood || tgerr.Is(err, tg.ErrTimeout) {
if (flood || tgerr.Is(err, tg.ErrTimeout)) && floodOrTimeoutRetries < 10 {
floodOrTimeoutRetries++
continue
}
return block{}, errors.Wrap(err, "get next chunk")