Compare commits
No commits in common. "dcf77" and "main" have entirely different histories.
2 changed files with 3 additions and 95 deletions
|
@ -14,7 +14,3 @@ embassy-stm32 = { git = "https://github.com/embassy-rs/embassy", features = ["de
|
|||
embassy-sync = { version = "0.3", features = ["nightly"] }
|
||||
embassy-time = { version = "0.1.3", features = ["defmt", "nightly"] }
|
||||
panic-probe = { version = "0.3", features = ["print-defmt"] }
|
||||
|
||||
[profile.release]
|
||||
debug = true
|
||||
opt-level = "z"
|
||||
|
|
94
src/main.rs
94
src/main.rs
|
@ -3,23 +3,19 @@
|
|||
#![feature(async_fn_track_caller, type_alias_impl_trait)]
|
||||
#![warn(rust_2018_idioms)]
|
||||
#![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;
|
||||
|
||||
use defmt::{info, println, unwrap};
|
||||
use defmt::*;
|
||||
use defmt_rtt as _;
|
||||
use embassy_executor::Spawner;
|
||||
use embassy_stm32::{
|
||||
exti::ExtiInput,
|
||||
gpio::{Input, Level, Output, Pull, Speed},
|
||||
peripherals::{PA0, PA1, PA5, PC13}
|
||||
peripherals::{PA5, PC13}
|
||||
};
|
||||
use embassy_sync::blocking_mutex::raw::ThreadModeRawMutex;
|
||||
use embassy_time::{Duration, Instant, Timer};
|
||||
use embassy_time::{Duration, Timer};
|
||||
use panic_probe as _;
|
||||
use static_mutex::StaticMutex;
|
||||
|
||||
|
@ -28,8 +24,6 @@ type MutexGuard<'a, T> = embassy_sync::mutex::MutexGuard<'a, ThreadModeRawMutex,
|
|||
|
||||
type NucleoLed = Output<'static, PA5>;
|
||||
type NucleoButton = ExtiInput<'static, PC13>;
|
||||
type POn = Output<'static, PA0>;
|
||||
type Tco = ExtiInput<'static, PA1>;
|
||||
|
||||
static LED: StaticMutex<NucleoLed> = StaticMutex::new();
|
||||
static BLINKING: Mutex<bool> = Mutex::new(true);
|
||||
|
@ -60,92 +54,10 @@ 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]
|
||||
async fn main(spawner: Spawner) {
|
||||
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;
|
||||
let button = ExtiInput::new(Input::new(p.PC13, Pull::Up), p.EXTI13);
|
||||
|
||||
|
|
Loading…
Reference in a new issue