jrd/floorbell
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

reorder functions

Browse Source
This commit is contained in:
Jared Burce
2020-10-29 06:41:40 -07:00
parent 85a69b2420
commit 429f8258bc
1 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

24
src/main.rs
View File

@@ -17,18 +17,6 @@ const OUTDOOR_CHIME_FILE: &str = "static/outdoor.mp3";
const BUTTON_PIN: u8 = 26; const BUTTON_PIN: u8 = 26;
const CHANNEL_VEC_SIZE: usize = 32; const CHANNEL_VEC_SIZE: usize = 32;
fn button_pressed(_level: Level,
clients: &Arc<Mutex<SmallVec<[mpsc::Sender<()>; CHANNEL_VEC_SIZE]>>>) {
info!("DOORBELL PRESS");
clients.lock().unwrap().retain(|tx: &mut mpsc::Sender<()>| {
match tx.try_send(()) {
Ok(_) => true,
Err(mpsc::error::TrySendError::Full(_)) => true, // we just get some free debouncing
Err(mpsc::error::TrySendError::Closed(_)) => { info!("Event client disconnected"); false }
}
});
}
thread_local! { thread_local! {
static AUDIO_CHILD: RefCell<Option<process::Child>> = RefCell::new(None) static AUDIO_CHILD: RefCell<Option<process::Child>> = RefCell::new(None)
} }
@@ -60,6 +48,18 @@ async fn main() {
} }
} }
fn button_pressed(_level: Level,
clients: &Arc<Mutex<SmallVec<[mpsc::Sender<()>; CHANNEL_VEC_SIZE]>>>) {
info!("DOORBELL PRESS");
clients.lock().unwrap().retain(|tx: &mut mpsc::Sender<()>| {
match tx.try_send(()) {
Ok(_) => true,
Err(mpsc::error::TrySendError::Full(_)) => true, // we just get some free debouncing
Err(mpsc::error::TrySendError::Closed(_)) => { info!("Event client disconnected"); false }
}
});
}
async fn warp(clients: Arc<Mutex<SmallVec<[mpsc::Sender<()>; CHANNEL_VEC_SIZE]>>>) { async fn warp(clients: Arc<Mutex<SmallVec<[mpsc::Sender<()>; CHANNEL_VEC_SIZE]>>>) {
// GET / // GET /
let root = warp::path::end() let root = warp::path::end()