reachability/
main.rs

1// Copyright 2019 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
5//! The reachability monitor monitors reachability state and generates an event to signal
6//! changes.
7
8use fuchsia_component::server::ServiceFs;
9use fuchsia_inspect::component;
10use futures::channel::mpsc::unbounded;
11use futures::{FutureExt as _, StreamExt as _};
12use log::info;
13use reachability_core::{Monitor, NetworkCheckAction, NetworkCheckCookie};
14use reachability_handler::ReachabilityHandler;
15use std::pin::pin;
16
17mod eventloop;
18
19use crate::eventloop::EventLoop;
20
21#[fuchsia::main(logging_tags = ["reachability"])]
22pub fn main() {
23    // TODO(dpradilla): use a `StructOpt` to pass in a log level option where the user can control
24    // how verbose logs should be.
25    info!("Starting reachability monitor!");
26    let mut executor = fuchsia_async::LocalExecutor::new();
27
28    let mut fs = ServiceFs::new_local();
29
30    let mut handler = ReachabilityHandler::new();
31    handler.publish_service(fs.dir("svc"));
32
33    let inspector = component::inspector();
34    // Report data on the size of the inspect VMO, and the number of allocation
35    // failures encountered. (Allocation failures can lead to missing data.)
36    component::serve_inspect_stats();
37
38    let _inspect_server_task =
39        inspect_runtime::publish(inspector, inspect_runtime::PublishOptions::default())
40            .expect("publish Inspect task");
41
42    let fs = fs.take_and_serve_directory_handle().expect("failed to serve ServiceFS directory");
43
44    let (sender, receiver) = unbounded::<(NetworkCheckAction, NetworkCheckCookie)>();
45    let mut monitor = Monitor::new(sender).expect("failed to create reachability monitor");
46    let () = monitor.set_inspector(inspector);
47
48    info!("monitoring");
49    let mut eventloop = EventLoop::new(monitor, handler, receiver, inspector);
50    let mut eventloop_fut = pin!(eventloop.run().fuse());
51    let mut serve_fut = pin!(fs.fuse().collect());
52
53    executor.run_singlethreaded(async {
54        futures::select! {
55            r = eventloop_fut => {
56                let r: Result<(), anyhow::Error> = r;
57                panic!("unexpectedly exited event loop with result {:?}", r);
58            },
59            () = serve_fut => {
60                panic!("unexpectedly stopped serving ServiceFS");
61            },
62        }
63    })
64}
reachability/main.rs

reachability/
main.rs
