rnp 0.1.146

A simple layer 4 ping tool for cloud.
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22

use crate::stub_servers::stub_server_tcp::StubServerTcp;
use crate::*;
use contracts::requires;
use futures_intrusive::sync::ManualResetEvent;
use std::error::Error;
use std::sync::Arc;
use tokio::task::JoinHandle;

#[requires(config.report_interval.as_millis() > 0)]
#[tracing::instrument(name = "Start running stub server", level = "debug", skip(stop_event))]
pub fn run(
    config: &RnpStubServerConfig,
    stop_event: Arc<ManualResetEvent>,
    server_started_event: Arc<ManualResetEvent>,
) -> JoinHandle<Result<(), Box<dyn Error + Send + Sync>>> {
    println!("Starting rnp {} server at {} ...", config.protocol, config.server_address);

    match config.protocol {
        RnpSupportedProtocol::TCP => return StubServerTcp::run_new(config.clone(), stop_event, server_started_event),
        _ => panic!("Protocol {} is not supported!", config.protocol),
    }
}