diff --git a/uplink/src/base/bridge/actions_lane.rs b/uplink/src/base/bridge/actions_lane.rs new file mode 100644 index 000000000..e69de29bb diff --git a/uplink/src/base/bridge/mod.rs b/uplink/src/base/bridge/mod.rs index 879e34b31..f82ebcc64 100644 --- a/uplink/src/base/bridge/mod.rs +++ b/uplink/src/base/bridge/mod.rs @@ -156,7 +156,7 @@ impl Bridge { pub fn register_action_route(&mut self, route: ActionRoute) -> Receiver { let (actions_tx, actions_rx) = bounded(1); - self.insert_route(route, actions_tx.clone()); + self.insert_route(route, actions_tx); actions_rx } diff --git a/uplink/src/collector/simulator/mod.rs b/uplink/src/collector/simulator/mod.rs index 10d81ec03..d454a4c85 100644 --- a/uplink/src/collector/simulator/mod.rs +++ b/uplink/src/collector/simulator/mod.rs @@ -113,7 +113,7 @@ pub fn spawn_data_simulators(device: DeviceData, tx: Sender) { spawn(Imu::simulate(tx.clone())); spawn(Motor::simulate(tx.clone())); spawn(PeripheralState::simulate(tx.clone())); - spawn(DeviceShadow::simulate(tx.clone())); + spawn(DeviceShadow::simulate(tx)); } #[tokio::main(flavor = "current_thread")] diff --git a/uplink/src/lib.rs b/uplink/src/lib.rs index de0c4f562..296d0fa73 100644 --- a/uplink/src/lib.rs +++ b/uplink/src/lib.rs @@ -426,7 +426,7 @@ impl Uplink { if let Some(config) = self.config.logging.clone() { let route = ActionRoute { name: "journalctl_config".to_string(), timeout: 10 }; let actions_rx = bridge.register_action_route(route); - let logger = JournalCtl::new(config.clone(), actions_rx, bridge_tx.clone()); + let logger = JournalCtl::new(config, actions_rx, bridge_tx.clone()); thread::spawn(move || { if let Err(e) = logger.start() { error!("Logger stopped!! Error = {:?}", e); @@ -438,7 +438,7 @@ impl Uplink { if let Some(config) = self.config.logging.clone() { let route = ActionRoute { name: "journalctl_config".to_string(), timeout: 10 }; let actions_rx = bridge.register_action_route(route); - let logger = Logcat::new(config.clone(), actions_rx, bridge_tx.clone()); + let logger = Logcat::new(config, actions_rx, bridge_tx.clone()); thread::spawn(move || { if let Err(e) = logger.start() { error!("Logger stopped!! Error = {:?}", e); @@ -462,7 +462,7 @@ impl Uplink { if let Some(actions_rx) = bridge.register_action_routes(&self.config.script_runner) { let script_runner = - ScriptRunner::new(self.config.script_runner.clone(), actions_rx, bridge_tx.clone()); + ScriptRunner::new(self.config.script_runner.clone(), actions_rx, bridge_tx); thread::spawn(move || { if let Err(e) = script_runner.start() { error!("Script runner stopped!! Error = {:?}", e);