openthread/ot/
cli.rs

1// Copyright 2022 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 crate::prelude_internal::*;
6use std::os::raw::c_int;
7
8/// Methods from the [OpenThread "CLI" Module](https://openthread.io/reference/group/api-cli).
9pub trait Cli {
10    /// Functional equivalent of [`otsys::otCliInputLine`](crate::otsys::otCliInputLine).
11    fn cli_input_line(&self, line: &CStr);
12
13    /// Functional equivalent of [`otsys::otCliInit`](crate::otsys::otCliInit).
14    fn cli_init<'a, F>(&self, output_callback: F)
15    where
16        F: FnMut(&CStr) + 'a;
17}
18
19impl<T: Cli + ot::Boxable> Cli for ot::Box<T> {
20    fn cli_input_line(&self, line: &CStr) {
21        self.as_ref().cli_input_line(line);
22    }
23
24    fn cli_init<'a, F>(&self, output_callback: F)
25    where
26        F: FnMut(&CStr) + 'a,
27    {
28        self.as_ref().cli_init(output_callback);
29    }
30}
31
32impl Cli for Instance {
33    fn cli_input_line(&self, line: &CStr) {
34        unsafe { otCliInputLine(line.as_ptr() as *mut c_char) }
35    }
36
37    fn cli_init<'a, F>(&self, f: F)
38    where
39        F: FnMut(&CStr) + 'a,
40    {
41        unsafe extern "C" fn _ot_cli_output_callback(
42            context: *mut ::std::os::raw::c_void,
43            line: *const c_char,
44            _: *mut otsys::__va_list_tag,
45        ) -> c_int {
46            let line = CStr::from_ptr(line);
47
48            trace!("_ot_cli_output_callback: {:?}", line);
49
50            // Reconstitute a reference to our instance
51            let instance = Instance::ref_from_ot_ptr(context as *mut otInstance).unwrap();
52
53            // Get a reference to our instance backing.
54            let backing = instance.borrow_backing();
55
56            // Remove our line sender from the cell in the backing.
57            // We will replace it once we are done.
58            let mut sender_option = backing.cli_output_fn.replace(None);
59
60            if let Some(sender) = sender_option.as_mut() {
61                sender(line);
62            } else {
63                info!("_ot_cli_output_callback: Nothing to handle CLI output");
64            }
65
66            // Put the sender back into the backing so that we can
67            // use it again later.
68            if let Some(new_sender) = backing.cli_output_fn.replace(sender_option) {
69                // In this case someone called the init function while
70                // they were in the callback. We want to restore that
71                // callback.
72                backing.cli_output_fn.set(Some(new_sender));
73            }
74
75            line.to_bytes().len().try_into().unwrap()
76        }
77
78        // Put our sender closure in a box.
79        // This will go into the backing.
80        let fn_box = Box::new(f) as Box<dyn FnMut(&CStr) + 'a>;
81
82        // Prepare a function pointer for our callback closure.
83        let cb: otCliOutputCallback = Some(_ot_cli_output_callback);
84
85        // Go ahead and get our context pointer ready for the callback.
86        // In this case our context pointer is the `otInstance` pointer.
87        let fn_ptr = self.as_ot_ptr() as *mut ::std::os::raw::c_void;
88
89        unsafe {
90            // Make sure our object eventually gets cleaned up.
91            // Here we must also transmute our closure to have a 'static
92            // lifetime.
93            // SAFETY: We need to do this because the borrow checker
94            //         cannot infer the proper lifetime for the
95            //         singleton instance backing, but this is guaranteed
96            //         by the API.
97            let prev_callback =
98                self.borrow_backing().cli_output_fn.replace(std::mem::transmute::<
99                    Option<Box<dyn FnMut(&'_ CStr) + 'a>>,
100                    Option<Box<dyn FnMut(&'_ CStr) + 'static>>,
101                >(Some(fn_box)));
102
103            // Check to see if there was a previous callback registered.
104            // We only want to call `otCliInit()` if there was no
105            // previously registered callback.
106            if prev_callback.is_none() {
107                // SAFETY: This must only be called once.
108                otCliInit(self.as_ot_ptr(), cb, fn_ptr);
109            }
110        }
111    }
112}
openthread/ot/cli.rs

openthread/ot/
cli.rs
