Browse Source

bin/tau: clean up

ghassmo 4 years ago
parent
commit
308fa4d0da
2 changed files with 7 additions and 4 deletions
  1. 1 1
      bin/tau/taud/src/main.rs
  2. 6 3
      bin/tau/taud/src/util.rs

+ 1 - 1
bin/tau/taud/src/main.rs

@@ -49,7 +49,7 @@ async fn start(settings: Settings, executor: Arc<Executor<'_>>) -> 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

+ 6 - 3
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<SocketAddr>,
     /// Raft Connection slots
-    #[clap(long, default_value_t = 0)]
+    #[clap(long, default_value = "0")]
     pub slots: u32,
     /// Increase verbosity
     #[clap(short, parse(from_occurrences))]