pkg_resolver_config/
config_lib_rust_config_lib_source.rs

1use fidl::unpersist;
2use fidl_cf_sc_internal_pkgresolverconfig::Config as FidlConfig;
3use fuchsia_component_config::{Config as ComponentConfig, Error};
4use fuchsia_inspect::Node;
5use std::convert::TryInto;
6const EXPECTED_CHECKSUM: &[u8] = &[
7    0x8f, 0xee, 0xaf, 0x59, 0x30, 0x7c, 0x0d, 0xb4, 0xeb, 0x00, 0x0c, 0xb3, 0x58, 0x25, 0xf8, 0xd1,
8    0x41, 0x03, 0x6b, 0x68, 0x7b, 0x07, 0x53, 0x1a, 0x90, 0x0a, 0x38, 0x65, 0xbe, 0xce, 0x09, 0xa2,
9];
10const EXPECTED_CHECKSUM_LENGTH: [u8; 2] = (EXPECTED_CHECKSUM.len() as u16).to_le_bytes();
11#[derive(Debug)]
12pub struct Config {
13    pub blob_download_concurrency_limit: u16,
14    pub blob_download_resumption_attempts_limit: u32,
15    pub blob_network_body_timeout_seconds: u32,
16    pub blob_network_header_timeout_seconds: u32,
17    pub delivery_blob_type: u32,
18    pub tuf_metadata_timeout_seconds: u32,
19    pub tuf_network_header_timeout_seconds: u32,
20}
21impl Config {
22    #[doc = r" Take the config startup handle and parse its contents."]
23    #[doc = r""]
24    #[doc = r" # Panics"]
25    #[doc = r""]
26    #[doc = r" If the config startup handle was already taken or if it is not valid."]
27    pub fn take_from_startup_handle() -> Self {
28        <Self as ComponentConfig>::take_from_startup_handle()
29    }
30    #[doc = r" Parse `Self` from `vmo`."]
31    pub fn from_vmo(vmo: &zx::Vmo) -> Result<Self, Error> {
32        <Self as ComponentConfig>::from_vmo(vmo)
33    }
34    #[doc = r" Parse `Self` from `bytes`."]
35    pub fn from_bytes(bytes: &[u8]) -> Result<Self, Error> {
36        <Self as ComponentConfig>::from_bytes(bytes)
37    }
38    pub fn record_inspect(&self, inspector_node: &Node) {
39        <Self as ComponentConfig>::record_inspect(self, inspector_node)
40    }
41}
42impl ComponentConfig for Config {
43    #[doc = r" Parse `Self` from `bytes`."]
44    fn from_bytes(bytes: &[u8]) -> Result<Self, Error> {
45        let (checksum_len_bytes, bytes) = bytes.split_at_checked(2).ok_or(Error::TooFewBytes)?;
46        let checksum_len_bytes: [u8; 2] =
47            checksum_len_bytes.try_into().expect("previous call guaranteed 2 element slice");
48        let checksum_length = u16::from_le_bytes(checksum_len_bytes) as usize;
49        let (observed_checksum, bytes) =
50            bytes.split_at_checked(checksum_length).ok_or(Error::TooFewBytes)?;
51        if observed_checksum != EXPECTED_CHECKSUM {
52            return Err(Error::ChecksumMismatch {
53                expected_checksum: EXPECTED_CHECKSUM.to_vec(),
54                observed_checksum: observed_checksum.to_vec(),
55            });
56        }
57        let fidl_config: FidlConfig = unpersist(bytes).map_err(Error::Unpersist)?;
58        Ok(Self {
59            blob_download_concurrency_limit: fidl_config.blob_download_concurrency_limit,
60            blob_download_resumption_attempts_limit: fidl_config
61                .blob_download_resumption_attempts_limit,
62            blob_network_body_timeout_seconds: fidl_config.blob_network_body_timeout_seconds,
63            blob_network_header_timeout_seconds: fidl_config.blob_network_header_timeout_seconds,
64            delivery_blob_type: fidl_config.delivery_blob_type,
65            tuf_metadata_timeout_seconds: fidl_config.tuf_metadata_timeout_seconds,
66            tuf_network_header_timeout_seconds: fidl_config.tuf_network_header_timeout_seconds,
67        })
68    }
69    fn to_bytes(&self) -> Result<Vec<u8>, Error> {
70        let fidl_config = FidlConfig {
71            blob_download_concurrency_limit: self.blob_download_concurrency_limit.clone(),
72            blob_download_resumption_attempts_limit: self
73                .blob_download_resumption_attempts_limit
74                .clone(),
75            blob_network_body_timeout_seconds: self.blob_network_body_timeout_seconds.clone(),
76            blob_network_header_timeout_seconds: self.blob_network_header_timeout_seconds.clone(),
77            delivery_blob_type: self.delivery_blob_type.clone(),
78            tuf_metadata_timeout_seconds: self.tuf_metadata_timeout_seconds.clone(),
79            tuf_network_header_timeout_seconds: self.tuf_network_header_timeout_seconds.clone(),
80        };
81        let mut fidl_bytes = fidl::persist(&fidl_config).map_err(Error::Persist)?;
82        let mut bytes = Vec::with_capacity(
83            EXPECTED_CHECKSUM_LENGTH.len() + EXPECTED_CHECKSUM.len() + fidl_bytes.len(),
84        );
85        bytes.extend_from_slice(&EXPECTED_CHECKSUM_LENGTH);
86        bytes.extend_from_slice(EXPECTED_CHECKSUM);
87        bytes.append(&mut fidl_bytes);
88        Ok(bytes)
89    }
90    fn record_inspect(&self, inspector_node: &Node) {
91        inspector_node.record_uint(
92            "blob_download_concurrency_limit",
93            self.blob_download_concurrency_limit as u64,
94        );
95        inspector_node.record_uint(
96            "blob_download_resumption_attempts_limit",
97            self.blob_download_resumption_attempts_limit as u64,
98        );
99        inspector_node.record_uint(
100            "blob_network_body_timeout_seconds",
101            self.blob_network_body_timeout_seconds as u64,
102        );
103        inspector_node.record_uint(
104            "blob_network_header_timeout_seconds",
105            self.blob_network_header_timeout_seconds as u64,
106        );
107        inspector_node.record_uint("delivery_blob_type", self.delivery_blob_type as u64);
108        inspector_node
109            .record_uint("tuf_metadata_timeout_seconds", self.tuf_metadata_timeout_seconds as u64);
110        inspector_node.record_uint(
111            "tuf_network_header_timeout_seconds",
112            self.tuf_network_header_timeout_seconds as u64,
113        );
114    }
115}
pkg_resolver_config/config_lib_rust_config_lib_source.rs

pkg_resolver_config/
config_lib_rust_config_lib_source.rs
