maviola 0.3.0

High-level MAVLink communication library with support for essential micro-services.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44

use std::marker::PhantomData;
use std::time::Duration;

use crate::core::io::ConnectionInfo;
use crate::core::marker::Proxy;
use crate::core::utils::{make_heartbeat_message, Guarded, SharedCloser, Switch};
use crate::protocol::DialectVersion;

use crate::asnc::prelude::*;
use crate::prelude::*;

pub(in crate::asnc::node) struct HeartbeatEmitter<V: Versioned> {
    pub(in crate::asnc::node) info: ConnectionInfo,
    pub(in crate::asnc::node) endpoint: Endpoint<V>,
    pub(in crate::asnc::node) interval: Duration,
    pub(in crate::asnc::node) sender: FrameSender<V, Proxy>,
    pub(in crate::asnc::node) dialect_version: Option<DialectVersion>,
    pub(in crate::asnc::node) _version: PhantomData<V>,
}

impl<V: Versioned> HeartbeatEmitter<V> {
    pub(in crate::asnc::node) fn spawn(self, mut is_active: Guarded<SharedCloser, Switch>) {
        let heartbeat_message = make_heartbeat_message(self.dialect_version);

        tokio::spawn(async move {
            let info = &self.info;

            while is_active.is() {
                let frame = self.endpoint.next_frame(&heartbeat_message).unwrap();

                log::trace!("[{info:?}] broadcasting heartbeat");
                if let Err(err) = self.sender.send_frame(&frame) {
                    log::trace!("[{info:?}] heartbeat can't be broadcast: {err:?}");
                    is_active.set(false);
                    break;
                }

                tokio::time::sleep(self.interval).await;
            }

            log::debug!("[{info:?}] heartbeats emitter stopped");
        });
    }
}