pezkuwichain/pezkuwi-telemetry
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-telemetry.git synced 2026-04-29 06:47:59 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix broken test (node being banned) and allow test config of new max-bytes option on shard

Browse Source
This commit is contained in:
James Wilson
2021-07-30 16:55:06 +01:00
parent a368553085
commit 3f523178be
2 changed files with 22 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files
backend/test_utils/src/workspace/start_server.rs
+18 -4
View File
@@ -31,12 +31,16 @@ impl Default for CoreOpts {
/// Additional options to pass to the shard command.
pub struct ShardOpts {
pub max_nodes_per_connection: Option<usize>,
pub max_node_data_per_second: Option<usize>,
pub node_block_seconds: Option<u64>,
}
impl Default for ShardOpts {
fn default() -> Self {
Self {
max_nodes_per_connection: None,
max_node_data_per_second: None,
node_block_seconds: None
}
}
}
@@ -95,10 +99,20 @@ pub async fn start_server(
});
// Append additional opts to the shard command
if let Some(max_nodes_per_connection) = shard_opts.max_nodes_per_connection {
if let Some(val) = shard_opts.max_nodes_per_connection {
shard_command = shard_command
.arg("--max-nodes-per-connection")
.arg(max_nodes_per_connection.to_string());
.arg(val.to_string());
}
if let Some(val) = shard_opts.max_node_data_per_second {
shard_command = shard_command
.arg("--max-node-data-per-second")
.arg(val.to_string());
}
if let Some(val) = shard_opts.node_block_seconds {
shard_command = shard_command
.arg("--node-block-seconds")
.arg(val.to_string());
}
// Build the core command
@@ -110,10 +124,10 @@ pub async fn start_server(
});
// Append additional opts to the core command
if let Some(feed_timeout) = core_opts.feed_timeout {
if let Some(val) = core_opts.feed_timeout {
core_command = core_command
.arg("--feed-timeout")
.arg(feed_timeout.to_string());
.arg(val.to_string());
}
// Star the server