rafaelcaricio/relay
1
0
Fork 0
forked from mirrors/relay
Code Pull requests Activity

Give verify & admin a different queue than deliver

Browse source
This commit is contained in:
asonix 2023-07-27 09:55:13 -05:00
parent 2a7fed743f
commit 05c266c23c
1 changed files with 8 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
src/main.rs
View file

@ -260,6 +260,7 @@ async fn do_server_main(
let keys = config.open_keys()?; let keys = config.open_keys()?;
let spawner = Spawner::build(config.signature_threads())?; let spawner = Spawner::build(config.signature_threads())?;
let verify_spawner = Spawner::build((config.signature_threads() / 2).max(1))?;
let bind_address = config.bind_address(); let bind_address = config.bind_address();
let server = HttpServer::new(move || { let server = HttpServer::new(move || {
@ -282,7 +283,7 @@ async fn do_server_main(
.app_data(web::Data::new(job_server)) .app_data(web::Data::new(job_server))
.app_data(web::Data::new(media.clone())) .app_data(web::Data::new(media.clone()))
.app_data(web::Data::new(collector.clone())) .app_data(web::Data::new(collector.clone()))
.app_data(web::Data::new(spawner.clone())); .app_data(web::Data::new(verify_spawner.clone()));
let app = if let Some(data) = config.admin_config() { let app = if let Some(data) = config.admin_config() {
app.app_data(data) app.app_data(data)
@ -300,7 +301,12 @@ async fn do_server_main(
web::resource("/inbox") web::resource("/inbox")
.wrap(config.digest_middleware()) .wrap(config.digest_middleware())
.wrap(VerifySignature::new( .wrap(VerifySignature::new(
MyVerify(requests, actors.clone(), state.clone(), spawner.clone()), MyVerify(
requests,
actors.clone(),
state.clone(),
verify_spawner.clone(),
),
Default::default(), Default::default(),
)) ))
.wrap(DebugPayload(config.debug())) .wrap(DebugPayload(config.debug()))