Compare commits
4 commits
Author | SHA1 | Date | |
---|---|---|---|
3c7a6186d4 | |||
4da353ab28 | |||
e9050fa59e | |||
841b7025bb |
2 changed files with 95 additions and 3 deletions
|
@ -14,3 +14,7 @@ embassy-stm32 = { git = "https://github.com/embassy-rs/embassy", features = ["de
|
||||||
embassy-sync = { version = "0.3", features = ["nightly"] }
|
embassy-sync = { version = "0.3", features = ["nightly"] }
|
||||||
embassy-time = { version = "0.1.3", features = ["defmt", "nightly"] }
|
embassy-time = { version = "0.1.3", features = ["defmt", "nightly"] }
|
||||||
panic-probe = { version = "0.3", features = ["print-defmt"] }
|
panic-probe = { version = "0.3", features = ["print-defmt"] }
|
||||||
|
|
||||||
|
[profile.release]
|
||||||
|
debug = true
|
||||||
|
opt-level = "z"
|
||||||
|
|
94
src/main.rs
94
src/main.rs
|
@ -3,19 +3,23 @@
|
||||||
#![feature(async_fn_track_caller, type_alias_impl_trait)]
|
#![feature(async_fn_track_caller, type_alias_impl_trait)]
|
||||||
#![warn(rust_2018_idioms)]
|
#![warn(rust_2018_idioms)]
|
||||||
#![forbid(elided_lifetimes_in_paths, unsafe_code)]
|
#![forbid(elided_lifetimes_in_paths, unsafe_code)]
|
||||||
|
// STOP HIGHLIGHTING MY ENTIRE CODE RED YOU MOTHERFUCKING PEACE OF GARBAGE SOFTWARE
|
||||||
|
// SOMETIMES I AM WRITING CODE BEFORE I INSERT A BREAK SOMEWHERE
|
||||||
|
// ARE YOU AWARE THAT CODING DOESN'T PRODUCE FINISHED CODE IN A MILLISECOND???????
|
||||||
|
#![allow(clippy::never_loop, unreachable_code)]
|
||||||
|
|
||||||
mod static_mutex;
|
mod static_mutex;
|
||||||
|
|
||||||
use defmt::*;
|
use defmt::{info, println, unwrap};
|
||||||
use defmt_rtt as _;
|
use defmt_rtt as _;
|
||||||
use embassy_executor::Spawner;
|
use embassy_executor::Spawner;
|
||||||
use embassy_stm32::{
|
use embassy_stm32::{
|
||||||
exti::ExtiInput,
|
exti::ExtiInput,
|
||||||
gpio::{Input, Level, Output, Pull, Speed},
|
gpio::{Input, Level, Output, Pull, Speed},
|
||||||
peripherals::{PA5, PC13}
|
peripherals::{PA0, PA1, PA5, PC13}
|
||||||
};
|
};
|
||||||
use embassy_sync::blocking_mutex::raw::ThreadModeRawMutex;
|
use embassy_sync::blocking_mutex::raw::ThreadModeRawMutex;
|
||||||
use embassy_time::{Duration, Timer};
|
use embassy_time::{Duration, Instant, Timer};
|
||||||
use panic_probe as _;
|
use panic_probe as _;
|
||||||
use static_mutex::StaticMutex;
|
use static_mutex::StaticMutex;
|
||||||
|
|
||||||
|
@ -24,6 +28,8 @@ type MutexGuard<'a, T> = embassy_sync::mutex::MutexGuard<'a, ThreadModeRawMutex,
|
||||||
|
|
||||||
type NucleoLed = Output<'static, PA5>;
|
type NucleoLed = Output<'static, PA5>;
|
||||||
type NucleoButton = ExtiInput<'static, PC13>;
|
type NucleoButton = ExtiInput<'static, PC13>;
|
||||||
|
type POn = Output<'static, PA0>;
|
||||||
|
type Tco = ExtiInput<'static, PA1>;
|
||||||
|
|
||||||
static LED: StaticMutex<NucleoLed> = StaticMutex::new();
|
static LED: StaticMutex<NucleoLed> = StaticMutex::new();
|
||||||
static BLINKING: Mutex<bool> = Mutex::new(true);
|
static BLINKING: Mutex<bool> = Mutex::new(true);
|
||||||
|
@ -54,10 +60,92 @@ async fn button_handler(mut button: NucleoButton) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
#[embassy_executor::task]
|
||||||
|
async fn query_time(mut pon: POn, mut tco: Tco, interval: Duration) {
|
||||||
|
loop {
|
||||||
|
pon.set_low();
|
||||||
|
info!("Waiting");
|
||||||
|
|
||||||
|
// we need to find the minute marker
|
||||||
|
// that means we won't receive a transmission for an entire second
|
||||||
|
tco.wait_for_rising_edge().await;
|
||||||
|
loop {
|
||||||
|
tco.wait_for_falling_edge().await;
|
||||||
|
let start = Instant::now();
|
||||||
|
tco.wait_for_rising_edge().await;
|
||||||
|
// our starting edge should have at least 800ms from the previous second,
|
||||||
|
// and then a full second.
|
||||||
|
if start.elapsed().as_millis() > 1500 {
|
||||||
|
break;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
let mut start = Instant::now();
|
||||||
|
|
||||||
|
info!("Receiving");
|
||||||
|
|
||||||
|
// we always start on the rising edge, with `start` set already
|
||||||
|
const SECONDS: usize = 60;
|
||||||
|
let mut bytes = [0u64; SECONDS];
|
||||||
|
let mut timing = [0u64; SECONDS];
|
||||||
|
let mut i = 0;
|
||||||
|
while i < SECONDS {
|
||||||
|
tco.wait_for_falling_edge().await;
|
||||||
|
bytes[i] = start.elapsed().as_millis();
|
||||||
|
tco.wait_for_rising_edge().await;
|
||||||
|
timing[i] = start.elapsed().as_millis();
|
||||||
|
start = Instant::now();
|
||||||
|
|
||||||
|
// verify that the transmission wasn't just noise of the previous one
|
||||||
|
if i > 0 && bytes[i] < 100 && timing[i - 1] - bytes[i - 1] < 100 {
|
||||||
|
bytes[i - 1] += timing[i - 1] + bytes[i];
|
||||||
|
timing[i - 1] += timing[i];
|
||||||
|
}
|
||||||
|
// and verify that the transmission wasn't a minute marker
|
||||||
|
else if timing[i] >= 1500 {
|
||||||
|
info!("Retrying");
|
||||||
|
i = 0;
|
||||||
|
}
|
||||||
|
// otherwise advance the second
|
||||||
|
else {
|
||||||
|
i += 1;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
pon.set_high();
|
||||||
|
info!("Done");
|
||||||
|
|
||||||
|
let mut garbage = false;
|
||||||
|
for i in 0 .. SECONDS {
|
||||||
|
let data = match (bytes[i], timing[i]) {
|
||||||
|
(75 ..= 174, 900 ..= 1100) => "0",
|
||||||
|
(175 ..= 300, 900 ..= 1100) => "1",
|
||||||
|
_ => {
|
||||||
|
garbage = true;
|
||||||
|
"GARBAGE"
|
||||||
|
}
|
||||||
|
};
|
||||||
|
println!(
|
||||||
|
"Bit {:02}: on for {:04} ms of {:04} ms total -- {:02}: {}",
|
||||||
|
i, bytes[i], timing[i], i, data
|
||||||
|
);
|
||||||
|
Timer::after(Duration::from_millis(50)).await;
|
||||||
|
}
|
||||||
|
|
||||||
|
if !garbage {
|
||||||
|
Timer::after(interval).await;
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
#[embassy_executor::main]
|
#[embassy_executor::main]
|
||||||
async fn main(spawner: Spawner) {
|
async fn main(spawner: Spawner) {
|
||||||
let p = embassy_stm32::init(Default::default());
|
let p = embassy_stm32::init(Default::default());
|
||||||
|
|
||||||
|
let pon = Output::new(p.PA0, Level::High, Speed::Low);
|
||||||
|
let tco = ExtiInput::new(Input::new(p.PA1, Pull::None), p.EXTI1);
|
||||||
|
|
||||||
|
unwrap!(spawner.spawn(query_time(pon, tco, Duration::from_secs(120))));
|
||||||
|
|
||||||
LED.init(Output::new(p.PA5, Level::Low, Speed::Low)).await;
|
LED.init(Output::new(p.PA5, Level::Low, Speed::Low)).await;
|
||||||
let button = ExtiInput::new(Input::new(p.PC13, Pull::Up), p.EXTI13);
|
let button = ExtiInput::new(Input::new(p.PC13, Pull::Up), p.EXTI13);
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue