index : static-web-server.git

bbb5a8f09bf2c82506c5ca639d2fbd5807bdb4dd [patch]

9fdd5d8cc81eb210eaba5470fd6a839f6dfa3584

c8c868d05e612c29394255eeb80cf1e452a0314c

bbb5a8f09bf2c82506c5ca639d2fbd5807bdb4dd.tar.gz

refactor: server runtime setup

Diff

 src/server.rs |  9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/src/server.rs b/src/server.rs
index ef8cdbf..39d8dfc 100644
--- a/src/server.rs
+++ b/src/server.rs
@@ -24,13 +24,15 @@ impl Server {
    /// Build and run the `Server` forever on the current thread.
    pub fn run(self) -> Result {
        tokio::runtime::Builder::new_multi_thread()
            .worker_threads(self.threads)
            .enable_all()
            .thread_name("static-web-server")
            .worker_threads(self.threads)
            .max_blocking_threads(self.threads)
            .build()?
            .block_on(async {
                let r = self.start_server().await;
                if r.is_err() {
                    panic!("Server error: {:?}", r.unwrap_err())
                    panic!("Server error during start up: {:?}", r.unwrap_err())
                }
            });

@@ -43,6 +45,9 @@ impl Server {

        logger::init(&opts.log_level)?;

        tracing::info!("runtime worker threads {}", self.threads);
        tracing::info!("runtime max blocking threads {}", self.threads);

        let ip = opts.host.parse::<IpAddr>()?;
        let addr = SocketAddr::from((ip, opts.port));