status-im
/
nim-eth
mirror of https://github.com/status-im/nim-eth.git
2
0
Fork 0
Code Issues Projects Releases Wiki Activity
nim-eth/eth/async_utils.nim

46 lines
1.6 KiB
Nim
Raw Normal View History

Add a new asyncDiscard replacement that traces recoverable errors and aborts on defects
2019-03-28 10:52:31 +00:00
import
wait for cancellation to be processed on timeout (#311)
2020-11-17 14:36:41 +00:00
chronos, chronicles/chronos_tools
Address review feedback
2019-04-05 08:13:22 +00:00
Delegate traceAsyncErrors to Chronicles
2020-08-14 21:31:09 +00:00
export
chronos_tools
Add a helper from NBC
2020-06-17 16:14:05 +00:00
template awaitWithTimeout*[T](operation: Future[T],
deadline: Future[void],
onTimeout: untyped): T =
let f = operation
await f or deadline
if not f.finished:
wait for cancellation to be processed on timeout (#311)
2020-11-17 14:36:41 +00:00
# If we don't wait for for the cancellation here, it's possible that
# the "next" operation will run concurrently to this one, messing up
# the order of operations (since await/async is not fair)
await cancelAndWait(f)
better async timeout wait (#659) * don't call timeout code if future finishes before getting cancelled * avoid extra raises effect resulting from `read` (vs `await`)
2024-01-16 17:12:47 +00:00
if f.cancelled: # It could have finished instead of getting cancelled
Add a helper from NBC
2020-06-17 16:14:05 +00:00
onTimeout
else:
better async timeout wait (#659) * don't call timeout code if future finishes before getting cancelled * avoid extra raises effect resulting from `read` (vs `await`)
2024-01-16 17:12:47 +00:00
await f # Await avoids extraneous exception effects
Add a helper from NBC
2020-06-17 16:14:05 +00:00
template awaitWithTimeout*[T](operation: Future[T],
timeout: Duration,
onTimeout: untyped): T =
awaitWithTimeout(operation, sleepAsync(timeout), onTimeout)
awaitWithTimeout for Future[void]
2021-02-04 14:45:50 +00:00
template awaitWithTimeout*(operation: Future[void],
deadline: Future[void],
onTimeout: untyped) =
let f = operation
await f or deadline
if not f.finished:
# If we don't wait for for the cancellation here, it's possible that
# the "next" operation will run concurrently to this one, messing up
# the order of operations (since await/async is not fair)
await cancelAndWait(f)
better async timeout wait (#659) * don't call timeout code if future finishes before getting cancelled * avoid extra raises effect resulting from `read` (vs `await`)
2024-01-16 17:12:47 +00:00
if f.cancelled: # It could have finished instead of getting cancelled
awaitWithTimeout for Future[void]
2021-02-04 14:45:50 +00:00
onTimeout
template awaitWithTimeout*(operation: Future[void],
timeout: Duration,
onTimeout: untyped) =
awaitWithTimeout(operation, sleepAsync(timeout), onTimeout)