logos-storage/logos-storage-nim
1
0
Fork 0
mirror of https://github.com/logos-storage/logos-storage-nim.git synced 2026-02-06 22:53:11 +00:00
Code Issues Packages Projects Releases Wiki Activity

better exception handling

Browse Source
This commit is contained in:
Marcin Czenko 2025-03-29 11:12:37 +01:00
parent 5abce8107c
commit b0be205765
No known key found for this signature in database
GPG Key ID: 33DEA0C8E30937C0
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
codex/bittorrent/torrentdownloader.nim
View File

@ -177,7 +177,8 @@ proc downloadPieces*(self: TorrentDownloader): Future[void] {.async: (raises: []
# mark it as ready
trace "Piece fetched and validated", pieceIndex = piece.pieceIndex
piece.handle.complete()
await sleepAsync(1.millis)
if not self.queue.empty:
await sleepAsync(1.millis)
except CancelledError:
trace "Downloading pieces cancelled"
except AsyncQueueFullError as e:
@ -223,7 +224,7 @@ proc finished*(self: TorrentDownloader): bool =
proc start*(self: TorrentDownloader) =
self.trackedFutures.track(self.downloadPieces())
proc stop*(self: TorrentDownloader) {.async.} =
proc stop*(self: TorrentDownloader) {.async: (raises: []).} =
self.pieceIndex = -1
await noCancel self.cancel()
await noCancel self.trackedFutures.cancelTracked()