From 308fa4d0dac1523038f13775ee9a1081971bc7bf Mon Sep 17 00:00:00 2001 From: ghassmo Date: Tue, 12 Apr 2022 15:38:04 +0400 Subject: [PATCH] bin/tau: clean up --- bin/tau/taud/src/main.rs | 2 +- bin/tau/taud/src/util.rs | 9 ++++++--- 2 files changed, 7 insertions(+), 4 deletions(-) diff --git a/bin/tau/taud/src/main.rs b/bin/tau/taud/src/main.rs index 4fdb2069c..d3d101033 100644 --- a/bin/tau/taud/src/main.rs +++ b/bin/tau/taud/src/main.rs @@ -49,7 +49,7 @@ async fn start(settings: Settings, executor: Arc>) -> TaudResult<() let raft_sender = raft.get_broadcast(); let commits = raft.get_commits(); let initial_sync_commits = raft.get_commits().clone(); - let initial_sync_raft_sender = raft.get_broadcast().clone(); + let initial_sync_raft_sender = raft_sender.clone(); // // RPC diff --git a/bin/tau/taud/src/util.rs b/bin/tau/taud/src/util.rs index 67ff0fb22..819f7a72d 100644 --- a/bin/tau/taud/src/util.rs +++ b/bin/tau/taud/src/util.rs @@ -95,8 +95,11 @@ impl Settings { args.accept }; - let outbound_connections = - if args.slots == 0 { config.outbound_connections.unwrap_or(0) } else { args.slots }; + let outbound_connections = if args.slots == 0 { + config.outbound_connections.unwrap_or_default() + } else { + args.slots + }; let connect = args.connect; @@ -143,7 +146,7 @@ pub struct CliTaud { #[clap(short, long)] pub connect: Vec, /// Raft Connection slots - #[clap(long, default_value_t = 0)] + #[clap(long, default_value = "0")] pub slots: u32, /// Increase verbosity #[clap(short, parse(from_occurrences))]