re-run clippy
This commit is contained in:
@ -28,7 +28,7 @@ use spacepackets::time::TimeWriter;
|
||||
use spacepackets::tm::PusTm;
|
||||
use std::collections::HashMap;
|
||||
use std::net::{IpAddr, SocketAddr};
|
||||
use std::sync::mpsc::channel;
|
||||
use std::sync::mpsc::{channel, TryRecvError};
|
||||
use std::sync::{mpsc, Arc, RwLock};
|
||||
use std::thread;
|
||||
use std::time::Duration;
|
||||
@ -181,8 +181,15 @@ fn main() {
|
||||
println!("Starting AOCS thread");
|
||||
let jh3 = thread::spawn(move || loop {
|
||||
match acs_thread_rx.try_recv() {
|
||||
Ok(_) => {}
|
||||
Err(_) => {}
|
||||
Ok(request) => {
|
||||
println!("ACS thread: Received request {:?}", request)
|
||||
}
|
||||
Err(e) => match e {
|
||||
TryRecvError::Empty => {}
|
||||
TryRecvError::Disconnected => {
|
||||
println!("ACS thread: Message Queue TX disconnected!")
|
||||
}
|
||||
},
|
||||
}
|
||||
thread::sleep(Duration::from_millis(500));
|
||||
});
|
||||
|
@ -164,7 +164,7 @@ impl PusReceiver {
|
||||
let sender = self.request_map.get(&addressable_id.target_id).unwrap();
|
||||
sender
|
||||
.send(Request::HkRequest(request))
|
||||
.expect(&format!("Sending HK request {:?} failed", request))
|
||||
.unwrap_or_else(|_| panic!("Sending HK request {:?} failed", request));
|
||||
};
|
||||
if PusPacket::subservice(pus_tc) == hk::Subservice::TcEnableGeneration as u8 {
|
||||
send_request(HkRequest::Enable(addressable_id.unique_id));
|
||||
|
Reference in New Issue
Block a user