pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-06-14 19:11:04 +00:00
Code Issues Packages Projects Releases Wiki Activity

Subsystem channel tweaks (#6905)

Browse Source 
* subsystem tweaks for higher scale

Signed-off-by: Andrei Sandu <andrei-mihail@parity.io>

* Adjust queue sizes

Signed-off-by: Andrei Sandu <andrei-mihail@parity.io>

* Orchestra 0.0.5

Signed-off-by: Andrei Sandu <andrei-mihail@parity.io>

* cargo lock

Signed-off-by: Andrei Sandu <andrei-mihail@parity.io>

---------

Signed-off-by: Andrei Sandu <andrei-mihail@parity.io>
This commit is contained in:
Andrei Sandu
2023-03-24 19:19:37 +02:00
committed by GitHub
parent 260d073658
commit fc2cba1805
5 changed files with 11 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/Cargo.lock
Generated
+4 -4
View File
@@ -5149,9 +5149,9 @@ dependencies = [
[[package]] [[package]]
name = "orchestra" name = "orchestra"
version = "0.0.4" version = "0.0.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "17e7d5b6bb115db09390bed8842c94180893dd83df3dfce7354f2a2aa090a4ee" checksum = "227585216d05ba65c7ab0a0450a3cf2cbd81a98862a54c4df8e14d5ac6adb015"
dependencies = [ dependencies = [
"async-trait", "async-trait",
"dyn-clonable", "dyn-clonable",
@@ -5166,9 +5166,9 @@ dependencies = [
[[package]] [[package]]
name = "orchestra-proc-macro" name = "orchestra-proc-macro"
version = "0.0.4" version = "0.0.5"
source = "registry+https://github.com/rust-lang/crates.io-index" source = "registry+https://github.com/rust-lang/crates.io-index"
checksum = "c2af4dabb2286b0be0e9711d2d24e25f6217048b71210cffd3daddc3b5c84e1f" checksum = "2871aadd82a2c216ee68a69837a526dfe788ecbe74c4c5038a6acdbff6653066"
dependencies = [ dependencies = [
"expander 0.0.6", "expander 0.0.6",
"itertools", "itertools",
polkadot/node/network/bridge/src/rx/mod.rs
+1 -1
View File
@@ -652,7 +652,7 @@ where
) )
.remote_handle(); .remote_handle();
ctx.spawn("network-bridge-in-network-worker", Box::pin(task))?; ctx.spawn_blocking("network-bridge-in-network-worker", Box::pin(task))?;
futures::pin_mut!(network_event_handler); futures::pin_mut!(network_event_handler);
let orchestra_signal_handler = run_incoming_orchestra_signals( let orchestra_signal_handler = run_incoming_orchestra_signals(
polkadot/node/overseer/Cargo.toml
+1 -1
View File
@@ -15,7 +15,7 @@ polkadot-node-primitives = { path = "../primitives" }
polkadot-node-subsystem-types = { path = "../subsystem-types" } polkadot-node-subsystem-types = { path = "../subsystem-types" }
polkadot-node-metrics = { path = "../metrics" } polkadot-node-metrics = { path = "../metrics" }
polkadot-primitives = { path = "../../primitives" } polkadot-primitives = { path = "../../primitives" }
orchestra = "0.0.4" orchestra = "0.0.5"
gum = { package = "tracing-gum", path = "../gum" } gum = { package = "tracing-gum", path = "../gum" }
lru = "0.9" lru = "0.9"
sp-core = { git = "https://github.com/paritytech/substrate", branch = "master" } sp-core = { git = "https://github.com/paritytech/substrate", branch = "master" }
polkadot/node/overseer/src/lib.rs
+4 -4
View File
@@ -529,7 +529,7 @@ pub struct Overseer<SupportsParachains> {
])] ])]
availability_store: AvailabilityStore, availability_store: AvailabilityStore,
#[subsystem(NetworkBridgeRxMessage, sends: [ #[subsystem(blocking, NetworkBridgeRxMessage, sends: [
BitfieldDistributionMessage, BitfieldDistributionMessage,
StatementDistributionMessage, StatementDistributionMessage,
ApprovalDistributionMessage, ApprovalDistributionMessage,
@@ -540,7 +540,7 @@ pub struct Overseer<SupportsParachains> {
])] ])]
network_bridge_rx: NetworkBridgeRx, network_bridge_rx: NetworkBridgeRx,
#[subsystem(NetworkBridgeTxMessage, sends: [])] #[subsystem(blocking, NetworkBridgeTxMessage, sends: [])]
network_bridge_tx: NetworkBridgeTx, network_bridge_tx: NetworkBridgeTx,
#[subsystem(blocking, ChainApiMessage, sends: [])] #[subsystem(blocking, ChainApiMessage, sends: [])]
@@ -559,7 +559,7 @@ pub struct Overseer<SupportsParachains> {
])] ])]
collator_protocol: CollatorProtocol, collator_protocol: CollatorProtocol,
#[subsystem(ApprovalDistributionMessage, sends: [ #[subsystem(blocking, message_capacity: 64000, ApprovalDistributionMessage, sends: [
NetworkBridgeTxMessage, NetworkBridgeTxMessage,
ApprovalVotingMessage, ApprovalVotingMessage,
])] ])]
@@ -584,7 +584,7 @@ pub struct Overseer<SupportsParachains> {
])] ])]
gossip_support: GossipSupport, gossip_support: GossipSupport,
#[subsystem(blocking, DisputeCoordinatorMessage, sends: [ #[subsystem(blocking, message_capacity: 32000, DisputeCoordinatorMessage, sends: [
RuntimeApiMessage, RuntimeApiMessage,
ChainApiMessage, ChainApiMessage,
DisputeDistributionMessage, DisputeDistributionMessage,
polkadot/node/subsystem-types/Cargo.toml
+1 -1
View File
@@ -13,7 +13,7 @@ polkadot-node-primitives = { path = "../primitives" }
polkadot-node-network-protocol = { path = "../network/protocol" } polkadot-node-network-protocol = { path = "../network/protocol" }
polkadot-statement-table = { path = "../../statement-table" } polkadot-statement-table = { path = "../../statement-table" }
polkadot-node-jaeger = { path = "../jaeger" } polkadot-node-jaeger = { path = "../jaeger" }
orchestra = "0.0.4" orchestra = "0.0.5"
sc-network = { git = "https://github.com/paritytech/substrate", branch = "master" } sc-network = { git = "https://github.com/paritytech/substrate", branch = "master" }
sp-api = { git = "https://github.com/paritytech/substrate", branch = "master" } sp-api = { git = "https://github.com/paritytech/substrate", branch = "master" }
sp-consensus-babe = { git = "https://github.com/paritytech/substrate", branch = "master" } sp-consensus-babe = { git = "https://github.com/paritytech/substrate", branch = "master" }