-
Notifications
You must be signed in to change notification settings - Fork 707
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
Pool channels should be created with capacity #3828
Comments
We could start with few thousands on each to be sure. The number should be specified in the config. |
Having a look through the code base, It's difficult to see where the entry point to this task is. I'm guessing it's to do with // massa-node/src/main.rs
let pool_channels = PoolChannels {
endorsement_sender: broadcast::channel(pool_config.broadcast_endorsements_channel_capacity)
.0,
operation_sender: broadcast::channel(pool_config.broadcast_operations_channel_capacity).0,
selector: selector_controller.clone(),
}; Am I missing anything? |
This are the channels to broadcast what's going on to be used by other modules (for now used only by grpc API for streaming). The The internal channels are created in function |
So if the pool is late, items in channels are dropped instead of blocking the emitter
The text was updated successfully, but these errors were encountered: