aboutsummaryrefslogtreecommitdiff
path: root/actor-example/firmware/src/bin/temperature-monitor.rs
diff options
context:
space:
mode:
authorGravatar Jorge Aparicio <jorge.aparicio@ferrous-systems.com> 2022-06-07 11:51:59 +0200
committerGravatar Jorge Aparicio <jorge.aparicio@ferrous-systems.com> 2022-07-07 14:27:46 +0200
commitd1145a138fbe156ef865df0a9383565180f6d5b8 (patch)
tree3437dd3d32c7b9640893a8c7141b87fb8884d85f /actor-example/firmware/src/bin/temperature-monitor.rs
parent5a3f27599e71289f03d5d33a015ed18590325701 (diff)
downloadrtic-actor.tar.gz
rtic-actor.tar.zst
rtic-actor.zip
use FakeTemperatureSensor as an actoractor
Diffstat (limited to 'actor-example/firmware/src/bin/temperature-monitor.rs')
-rw-r--r--actor-example/firmware/src/bin/temperature-monitor.rs17
1 files changed, 12 insertions, 5 deletions
diff --git a/actor-example/firmware/src/bin/temperature-monitor.rs b/actor-example/firmware/src/bin/temperature-monitor.rs
index 6636d582..8e9b7613 100644
--- a/actor-example/firmware/src/bin/temperature-monitor.rs
+++ b/actor-example/firmware/src/bin/temperature-monitor.rs
@@ -6,7 +6,8 @@ use firmware as _;
#[rtic::app(device = nrf52840_hal::pac, dispatchers = [RADIO])]
mod app {
use actors::{
- FakeTemperatureSensor, TemperatureAlert, TemperatureMonitor, TemperatureReadingCelsius,
+ DoTemperatureRead, FakeTemperatureSensor, TemperatureAlert, TemperatureMonitor,
+ TemperatureReadingCelsius,
};
use rtic_actor_traits::Receive;
use systick_monotonic::*;
@@ -36,6 +37,9 @@ mod app {
#[actors]
struct Actors {
+ #[subscribe(DoTemperatureRead)]
+ temperature_sensor: FakeTemperatureSensor<Poster>,
+
#[init(AlertHandler)]
#[subscribe(TemperatureAlert)]
alert_handler: AlertHandler,
@@ -50,7 +54,7 @@ mod app {
#[local]
struct Local {
- temperature_sensor: FakeTemperatureSensor<Poster>,
+ poster: Poster,
}
#[monotonic(binds = SysTick, default = true)]
@@ -71,17 +75,20 @@ mod app {
(
Shared {},
- Local { temperature_sensor },
+ Local { poster },
init::Monotonics(mono),
Actors {
temperature_monitor,
+ temperature_sensor,
},
)
}
- #[task(local = [temperature_sensor])]
+ #[task(local = [poster])]
fn periodic(cx: periodic::Context) {
- cx.local.temperature_sensor.read();
+ // input to the actor network
+ cx.local.poster.post(DoTemperatureRead).expect("OOM");
+
periodic::spawn_after(1.secs()).expect("OOM");
}