diff --git a/iris-mpc/src/bin/server.rs b/iris-mpc/src/bin/server.rs index 3585a9708..f5f30faeb 100644 --- a/iris-mpc/src/bin/server.rs +++ b/iris-mpc/src/bin/server.rs @@ -722,6 +722,8 @@ async fn server_main(config: Config) -> eyre::Result<()> { let mut skip_request_ids = sync_result.deleted_request_ids(); background_tasks.check_tasks(); + + tracing::info!("Start thread that will be responsible for communicating back the results"); // Start thread that will be responsible for communicating back the results let (tx, mut rx) = mpsc::channel::(32); // TODO: pick some buffer value @@ -729,7 +731,7 @@ async fn server_main(config: Config) -> eyre::Result<()> { let config_bg = config.clone(); let store_bg = store.clone(); let _result_sender_abort = background_tasks.spawn(async move { - + tracing::info!("In _result_sender_abort"); while let Some(ServerJobResult { merged_results, request_ids, @@ -741,6 +743,7 @@ async fn server_main(config: Config) -> eyre::Result<()> { deleted_ids, }) = rx.recv().await { + tracing::info!("Received results for {} queries", request_ids.len()); // returned serial_ids are 0 indexed, but we want them to be 1 indexed let uniqueness_results = merged_results .iter()