1
0
Fork 0
forked from alemi/upub

feat: allow specifying worker threads

This commit is contained in:
əlemi 2024-06-14 15:51:55 +02:00
parent 6fed451513
commit a80819685a
Signed by: alemi
GPG key ID: A4895B84D311642C
2 changed files with 24 additions and 6 deletions

28
main.rs
View file

@ -41,6 +41,10 @@ struct Args {
#[arg(long, default_value_t=false)] #[arg(long, default_value_t=false)]
/// run with debug level tracing /// run with debug level tracing
debug: bool, debug: bool,
#[arg(long)]
/// force set number of worker threads for async runtime, defaults to number of cores
threads: Option<usize>,
} }
#[derive(Clone, Subcommand)] #[derive(Clone, Subcommand)]
@ -100,9 +104,7 @@ enum Mode {
}, },
} }
#[tokio::main] fn main() {
async fn main() {
let args = Args::parse(); let args = Args::parse();
tracing_subscriber::fmt() tracing_subscriber::fmt()
@ -110,13 +112,29 @@ async fn main() {
.with_max_level(if args.debug { tracing::Level::DEBUG } else { tracing::Level::INFO }) .with_max_level(if args.debug { tracing::Level::DEBUG } else { tracing::Level::INFO })
.init(); .init();
let config = upub::Config::load(args.config); let config = upub::Config::load(args.config.as_ref());
if matches!(args.command, Mode::Config) { if matches!(args.command, Mode::Config) {
println!("{}", toml::to_string_pretty(&config).expect("failed serializing config")); println!("{}", toml::to_string_pretty(&config).expect("failed serializing config"));
return; return;
} }
let mut runtime = tokio::runtime::Builder::new_multi_thread();
if let Some(threads) = args.threads {
runtime.worker_threads(threads);
}
runtime
.enable_io()
.enable_time()
.thread_name("upub-async-worker")
.build()
.expect("failed creating tokio async runtime")
.block_on(async { init(args, config).await })
}
async fn init(args: Args, config: upub::Config) {
let database = args.database.unwrap_or(config.datasource.connection_string.clone()); let database = args.database.unwrap_or(config.datasource.connection_string.clone());
let domain = args.domain.unwrap_or(config.instance.domain.clone()); let domain = args.domain.unwrap_or(config.instance.domain.clone());
@ -150,7 +168,7 @@ async fn main() {
} }
let (tx, rx) = tokio::sync::watch::channel(false); let (tx, rx) = tokio::sync::watch::channel(false);
let signals = Signals::new(&[SIGTERM, SIGINT]).expect("failed registering signal handler"); let signals = Signals::new([SIGTERM, SIGINT]).expect("failed registering signal handler");
let handle = signals.handle(); let handle = signals.handle();
let signals_task = tokio::spawn(handle_signals(signals, tx)); let signals_task = tokio::spawn(handle_signals(signals, tx));
let stop = CancellationToken(rx); let stop = CancellationToken(rx);

View file

@ -92,7 +92,7 @@ pub struct SecurityConfig {
impl Config { impl Config {
pub fn load(path: Option<std::path::PathBuf>) -> Self { pub fn load(path: Option<&std::path::PathBuf>) -> Self {
let Some(cfg_path) = path else { return Config::default() }; let Some(cfg_path) = path else { return Config::default() };
match std::fs::read_to_string(cfg_path) { match std::fs::read_to_string(cfg_path) {
Ok(x) => match toml::from_str(&x) { Ok(x) => match toml::from_str(&x) {