gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Complete --rpc-pubsub-max-in-buffer-capacity/--rpc-pubsub-max-out-buffer-capacity plumbing

Browse Source
This commit is contained in:
Michael Vines
2021-02-08 22:06:01 -08:00
committed by mergify[bot]
parent f2f4003e70
commit 2caed6bd4c
1 changed files with 3 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
core/src/rpc_pubsub_service.rs
View File

@ -56,19 +56,6 @@ impl PubSubService {
let rpc = RpcSolPubSubImpl::new(subscriptions.clone()); let rpc = RpcSolPubSubImpl::new(subscriptions.clone());
let exit_ = exit.clone(); let exit_ = exit.clone();
// TODO: Once https://github.com/paritytech/jsonrpc/pull/594 lands, use
// `ServerBuilder::max_in_buffer_capacity()` and `Server::max_out_buffer_capacity() methods
// instead of only `ServerBuilder::max_payload`
let max_payload = *[
pubsub_config.max_fragment_size,
pubsub_config.max_in_buffer_capacity,
pubsub_config.max_out_buffer_capacity,
]
.iter()
.max()
.unwrap();
info!("rpc_pubsub max_payload: {}", max_payload);
let thread_hdl = Builder::new() let thread_hdl = Builder::new()
.name("solana-pubsub".to_string()) .name("solana-pubsub".to_string())
.spawn(move || { .spawn(move || {
@ -84,7 +71,9 @@ impl PubSubService {
session session
}) })
.max_connections(pubsub_config.max_connections) .max_connections(pubsub_config.max_connections)
.max_payload(max_payload) .max_payload(pubsub_config.max_fragment_size)
.max_in_buffer_capacity(pubsub_config.max_in_buffer_capacity)
.max_out_buffer_capacity(pubsub_config.max_out_buffer_capacity)
.start(&pubsub_addr); .start(&pubsub_addr);
if let Err(e) = server { if let Err(e) = server {