-
Notifications
You must be signed in to change notification settings - Fork 690
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
sc_network::NetworkWorker::event_streams should be a bounded channel #557
Comments
The |
Relates to #554 |
Hey, is anyone still working on this? Due to the inactivity this issue has been automatically marked as stale. It will be closed if no further activity occurs. Thank you for your contributions. |
Issue still relevant and important. |
* chore: minor improve for rpc * Fix libsecp256k1 crate name reference Co-authored-by: Wei Tang <wei@that.world> Co-authored-by: Wei Tang <accounts@that.world>
Right now if for example a
sc_network_gossip::GossipEngine
doesn't process notifications quickly enough, we will continue buffering notifications forever in its events stream.Instead, we should considering limiting the events stream to a certain size. If the channel is full, we would freeze the network worker itself, with a certain timeout after which the events stream is dropped and an error printed in the logs.
The first step to do so would be to turn
impl Future for NetworkWorker
into an async method.The text was updated successfully, but these errors were encountered: