openthread_fuchsia/backing/
mod.rs

1// Copyright 2021 The Fuchsia Authors. All rights reserved.
2// Use of this source code is governed by a BSD-style license that can be
3// found in the LICENSE file.
4
5use futures::prelude::*;
6use openthread::prelude::*;
7use spinel_pack::prelude::*;
8
9use fuchsia_async as fasync;
10use futures::channel::mpsc as fmpsc;
11use lowpan_driver_common::spinel::*;
12use std::cell::{Cell, RefCell};
13use std::sync::atomic::AtomicBool;
14use std::sync::mpsc;
15use std::time::Duration;
16
17#[allow(unused_imports)]
18use log::{debug, error, info, trace, warn};
19
20mod alarm;
21mod infra_if;
22mod nat64;
23mod radio;
24mod reset;
25mod resolver;
26mod trel;
27mod udp;
28
29pub(crate) use alarm::*;
30pub(crate) use infra_if::InfraIfInstance;
31pub(crate) use nat64::{Nat64Instance, Nat64PlatformInstance};
32use openthread::ot::NetifIdentifier;
33pub(crate) use reset::PlatformResetRequested;
34pub(crate) use resolver::*;
35pub(crate) use udp::*;
36
37pub(super) struct PlatformBacking {
38    pub(super) ot_to_rcp_sender: RefCell<mpsc::Sender<Vec<u8>>>,
39    pub(super) rcp_to_ot_receiver: RefCell<mpsc::Receiver<Vec<u8>>>,
40    pub(super) alarm: AlarmInstance,
41    pub(super) netif_index_thread: Option<ot::NetifIndex>,
42    pub(super) netif_index_backbone: Option<ot::NetifIndex>,
43    pub(super) trel: RefCell<Option<trel::TrelInstance>>,
44    pub(super) infra_if: Option<InfraIfInstance>,
45    pub(super) is_platform_reset_requested: AtomicBool,
46    pub(super) nat64: Nat64Instance,
47    pub(super) resolver: Resolver,
48}
49
50impl PlatformBacking {
51    // SAFETY: Unsafe because the type system cannot enforce thread safety on globals.
52    //         Caller should ensure that no other calls in this section are being
53    //         simultaneously made on other threads.
54    unsafe fn glob() -> &'static mut Option<PlatformBacking> {
55        static mut SINGLETON_BACKING: Option<PlatformBacking> = None;
56        // TODO(b/319328255) -- Fix usage so lint no longer applies
57        #[allow(static_mut_refs)]
58        &mut SINGLETON_BACKING
59    }
60
61    // SAFETY: Unsafe because the type system cannot enforce thread safety on globals.
62    //         Caller should ensure that no other calls in this section are being
63    //         simultaneously made on other threads.
64    pub(super) unsafe fn as_ref() -> &'static PlatformBacking {
65        Self::glob().as_ref().expect("Platform is uninitialized")
66    }
67
68    // SAFETY: Unsafe because the type system cannot enforce thread safety on globals.
69    //         Caller should ensure that no other calls in this section are being
70    //         simultaneously made on other threads.
71    pub(super) unsafe fn set_singleton(backing: PlatformBacking) {
72        assert!(Self::glob().replace(backing).is_none(), "Tried to make two Platform instances");
73    }
74
75    // SAFETY: Must only be called from Drop.
76    pub(super) unsafe fn drop_singleton() {
77        // SAFETY: When we are dropped, we can safely assume no other simultaneous calls are
78        //         being made on other threads.
79        assert!(Self::glob().take().is_some(), "Tried to drop singleton that was never allocated");
80    }
81}
82
83impl PlatformBacking {
84    fn lookup_netif_index(&self, id: ot::NetifIdentifier) -> Option<ot::NetifIndex> {
85        match id {
86            NetifIdentifier::Backbone => self.netif_index_backbone,
87            NetifIdentifier::Thread => self.netif_index_thread,
88            NetifIdentifier::Unspecified => Some(ot::NETIF_INDEX_UNSPECIFIED),
89        }
90    }
91}
openthread_fuchsia/backing/mod.rs

openthread_fuchsia/backing/
mod.rs
