Skip to content
This repository has been archived by the owner on Nov 15, 2023. It is now read-only.

Use async/await instead of manual polling of NetworkWorker #13219

Merged
merged 43 commits into from
Feb 20, 2023
Merged

Use async/await instead of manual polling of NetworkWorker #13219

Show file tree
Hide file tree
Changes from 8 commits
Commits
Show all changes
43 commits
Select commit Hold shift + click to select a range
fb272a6
Convert `NetworkWorker::poll()` into async `next_action()`
dmitry-markin Jan 16, 2023
4b5d851
Use `NetworkWorker::next_action` instead of `poll` in `sc-network-test`
dmitry-markin Jan 18, 2023
1c87141
Revert "Use `NetworkWorker::next_action` instead of `poll` in `sc-net…
dmitry-markin Jan 23, 2023
dbd8ad9
Fix `sc-network-test` to poll `NetworkWorker::next_action`
dmitry-markin Jan 23, 2023
e8d0758
Fix `sc_network::service` tests to poll `NetworkWorker::next_action`
dmitry-markin Jan 23, 2023
3071b05
Fix docs
dmitry-markin Jan 23, 2023
431e550
Merge remote-tracking branch 'origin/master' into dm-network-service-…
dmitry-markin Jan 23, 2023
d7be660
kick CI
dmitry-markin Jan 23, 2023
78cce1a
Factor out `next_worker_message()` & `next_swarm_event()`
dmitry-markin Feb 3, 2023
c9f75f7
Error handling: replace `futures::pending!()` with `expect()`
dmitry-markin Feb 6, 2023
4a85d1f
Simplify stream polling in `select!`
dmitry-markin Feb 6, 2023
c165185
Replace `NetworkWorker::next_action()` with `run()`
dmitry-markin Feb 6, 2023
d827ae9
Merge remote-tracking branch 'origin/master' into dm-network-service-…
dmitry-markin Feb 6, 2023
019ec35
Apply suggestions from code review
dmitry-markin Feb 6, 2023
d38b2b7
minor: comment
dmitry-markin Feb 6, 2023
343e9e9
Merge remote-tracking branch 'origin/master' into dm-network-service-…
dmitry-markin Feb 6, 2023
dd4980d
Apply suggestions from code review
dmitry-markin Feb 7, 2023
403dded
Print debug log when network future is shut down
dmitry-markin Feb 7, 2023
5a7ec32
Merge remote-tracking branch 'origin/master' into dm-network-service-…
dmitry-markin Feb 7, 2023
73dfd4b
Merge remote-tracking branch 'origin/master' into dm-network-service-…
dmitry-markin Feb 8, 2023
5a63842
Evaluate `NetworkWorker::run()` future once before the loop
dmitry-markin Feb 10, 2023
913e21c
Merge remote-tracking branch 'origin/master' into dm-network-service-…
dmitry-markin Feb 10, 2023
8e1db2c
Fix client code to match new `NetworkService` interfaces
dmitry-markin Feb 11, 2023
faec2e9
Make clippy happy
dmitry-markin Feb 11, 2023
9fa646d
Apply suggestions from code review
dmitry-markin Feb 13, 2023
9c5b610
Apply suggestions from code review
dmitry-markin Feb 13, 2023
f324937
Revert "Apply suggestions from code review"
dmitry-markin Feb 13, 2023
9856cc4
Make `NetworkWorker::run()` consume `self`
dmitry-markin Feb 13, 2023
f86ec12
Terminate system RPC future if RPC rx stream has terminated.
dmitry-markin Feb 13, 2023
9557a42
Rewrite with let-else
dmitry-markin Feb 13, 2023
533cc04
Fix comments
dmitry-markin Feb 13, 2023
e669c6a
Get `best_seen_block` and call `on_block_finalized` via `ChainSync` i…
dmitry-markin Feb 13, 2023
6ed5d48
rustfmt
dmitry-markin Feb 13, 2023
ab1ced4
make clippy happy
dmitry-markin Feb 13, 2023
4be62c7
Tests: schedule wake if `next_action()` returned true
dmitry-markin Feb 14, 2023
5e90af0
minor: comment
dmitry-markin Feb 14, 2023
a9123a7
Merge remote-tracking branch 'origin/master' into dm-network-service-…
dmitry-markin Feb 14, 2023
113a888
minor: fix `NetworkWorker` rustdoc
dmitry-markin Feb 14, 2023
ac1452c
minor: amend the rustdoc
dmitry-markin Feb 14, 2023
5fc3831
Fix bug that caused `on_demand_beefy_justification_sync` test to hang
dmitry-markin Feb 15, 2023
6005109
Merge remote-tracking branch 'origin/master' into dm-network-service-…
dmitry-markin Feb 15, 2023
9df7d0e
rustfmt
dmitry-markin Feb 15, 2023
812c316
Apply review suggestions
dmitry-markin Feb 17, 2023
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Loading