openthread_fuchsia/backing/
infra_if.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 super::*;
6use crate::{platformInfraIfInit, platformInfraIfOnReceiveIcmp6Msg};
7use fuchsia_async::net::EventedFd;
8use std::os::unix::io::AsRawFd;
9use std::task::{Context, Poll};
10
11pub struct OtRawSocket {
12    fd: i32,
13}
14impl AsRawFd for OtRawSocket {
15    fn as_raw_fd(&self) -> i32 {
16        self.fd
17    }
18}
19
20impl From<i32> for OtRawSocket {
21    fn from(file_desc: i32) -> Self {
22        OtRawSocket { fd: file_desc }
23    }
24}
25
26pub(crate) struct InfraIfInstance {
27    event_fd: Option<fasync::net::EventedFd<OtRawSocket>>,
28}
29
30impl InfraIfInstance {
31    pub fn new(infra_if_idx: ot::NetifIndex) -> Option<InfraIfInstance> {
32        if infra_if_idx == 0 {
33            info!(tag = "infra_if"; "InfraIfInstance failed to initialize: invalid infra_if_idx");
34            return None;
35        }
36        let raw_fd_int: i32 = unsafe { platformInfraIfInit(infra_if_idx) };
37        if raw_fd_int <= 0 {
38            info!(tag = "infra_if"; "InfraIfInstance failed to initialize: invalid raw_fd_int");
39            return None;
40        }
41        let raw_fd: OtRawSocket = raw_fd_int.into();
42        info!(tag = "infra_if"; "InfraIfInstance initialized");
43        Some(InfraIfInstance { event_fd: Some(unsafe { EventedFd::new(raw_fd).unwrap() }) })
44    }
45
46    pub fn poll(&self, instance: &ot::Instance, cx: &mut Context<'_>) {
47        if let Some(event_fd) = self.event_fd.as_ref() {
48            match event_fd.poll_readable(cx) {
49                Poll::Ready(Ok(())) => unsafe {
50                    platformInfraIfOnReceiveIcmp6Msg(instance.as_ot_ptr())
51                },
52                Poll::Ready(Err(x)) => {
53                    error!(
54                        tag = "infra_if";
55                        "InfraIfInstance: Error poll readable from raw socket: {:?}", x
56                    );
57                }
58                _ => {}
59            }
60        }
61    }
62}
openthread_fuchsia/backing/infra_if.rs

openthread_fuchsia/backing/
infra_if.rs
