FediMovies/fedimovies
1
1
Fork 0
Code Issues 3 Pull requests Projects Releases Packages Activity

Print HTTP socket address when starting HTTP server

Browse source
This commit is contained in:
silverpill 2023-01-18 16:23:32 +00:00
parent 52112996c5
commit 6d6a41d3e5
1 changed files with 10 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

17
src/main.rs
View file

@ -75,16 +75,16 @@ async fn main() -> std::io::Result<()> {
scheduler::run(config.clone(), maybe_blockchain, db_pool.clone()); scheduler::run(config.clone(), maybe_blockchain, db_pool.clone());
log::info!("scheduler started"); log::info!("scheduler started");
let num_workers = std::cmp::max(num_cpus::get(), 4);
let http_socket_addr = format!( let http_socket_addr = format!(
"{}:{}", "{}:{}",
config.http_host, config.http_host,
config.http_port, config.http_port,
); );
let num_workers = std::cmp::max(num_cpus::get(), 4);
// Mutex is used to make server process incoming activities sequentially // Mutex is used to make server process incoming activities sequentially
let inbox_mutex = web::Data::new(Mutex::new(())); let inbox_mutex = web::Data::new(Mutex::new(()));
HttpServer::new(move || { let http_server = HttpServer::new(move || {
let cors_config = match config.environment { let cors_config = match config.environment {
Environment::Development => { Environment::Development => {
Cors::permissive() Cors::permissive()
@ -174,9 +174,12 @@ async fn main() -> std::io::Result<()> {
app = app.service(web_client::static_service(web_client_dir)); app = app.service(web_client::static_service(web_client_dir));
}; };
app app
}) });
.workers(num_workers)
.bind(http_socket_addr)? log::info!("listening on {}", http_socket_addr);
.run() http_server
.await .workers(num_workers)
.bind(http_socket_addr)?
.run()
.await
} }