builtins/
ioport_resource.rs

1// Copyright 2020 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 anyhow::{Error, format_err};
6use fidl_fuchsia_kernel as fkernel;
7use futures::prelude::*;
8use std::sync::Arc;
9use zx::Resource;
10
11/// An implementation of fuchsia.kernel.IoportResource protocol.
12pub struct IoportResource {
13    resource: Resource,
14}
15
16impl IoportResource {
17    /// `resource` must be the IOPORT resource.
18    pub fn new(resource: Resource) -> Arc<Self> {
19        Arc::new(Self { resource })
20    }
21
22    pub async fn serve(
23        self: Arc<Self>,
24        mut stream: fkernel::IoportResourceRequestStream,
25    ) -> Result<(), Error> {
26        if self.resource.info()?.kind != zx::sys::ZX_RSRC_KIND_IOPORT {
27            return Err(format_err!("invalid handle kind, expected IOPORT"));
28        }
29        while let Some(fkernel::IoportResourceRequest::Get { responder }) =
30            stream.try_next().await?
31        {
32            responder.send(self.resource.duplicate_handle(zx::Rights::SAME_RIGHTS)?)?;
33        }
34        Ok(())
35    }
36}
37
38#[cfg(test)]
39mod tests {
40    use super::*;
41    use fidl_fuchsia_kernel as fkernel;
42    use fuchsia_async as fasync;
43    use fuchsia_component::client::connect_to_protocol;
44
45    async fn get_ioport_resource() -> Result<Resource, Error> {
46        let ioport_resource_provider = connect_to_protocol::<fkernel::IoportResourceMarker>()?;
47        let ioport_resource_handle = ioport_resource_provider.get().await?;
48        Ok(Resource::from(ioport_resource_handle))
49    }
50
51    async fn serve_ioport_resource() -> Result<fkernel::IoportResourceProxy, Error> {
52        let ioport_resource = get_ioport_resource().await?;
53
54        let (proxy, stream) =
55            fidl::endpoints::create_proxy_and_stream::<fkernel::IoportResourceMarker>();
56        fasync::Task::local(
57            IoportResource::new(ioport_resource)
58                .serve(stream)
59                .unwrap_or_else(|e| panic!("Error while serving IOPORT resource service: {}", e)),
60        )
61        .detach();
62        Ok(proxy)
63    }
64
65    #[fuchsia::test]
66    async fn fail_with_no_ioport_resource() -> Result<(), Error> {
67        let (_, stream) =
68            fidl::endpoints::create_proxy_and_stream::<fkernel::IoportResourceMarker>();
69        IoportResource::new(Resource::from(zx::NullableHandle::invalid()))
70            .serve(stream)
71            .await
72            .expect_err("should fail to serve stream with an invalid resource");
73        Ok(())
74    }
75
76    #[fuchsia::test]
77    async fn kind_type_is_ioport() -> Result<(), Error> {
78        let ioport_resource_provider = serve_ioport_resource().await?;
79        let ioport_resource: Resource = ioport_resource_provider.get().await?;
80        let resource_info = ioport_resource.info()?;
81        assert_eq!(resource_info.kind, zx::sys::ZX_RSRC_KIND_IOPORT);
82        assert_eq!(resource_info.base, 0);
83        assert_eq!(resource_info.size, 0);
84        Ok(())
85    }
86}
builtins/ioport_resource.rs

builtins/
ioport_resource.rs
