Skip to content

Commit

Permalink
more debug logs
Browse files Browse the repository at this point in the history
  • Loading branch information
eaypek-tfh committed Sep 25, 2024
1 parent 0478791 commit 2d135ce
Showing 1 changed file with 4 additions and 1 deletion.
5 changes: 4 additions & 1 deletion iris-mpc/src/bin/server.rs
Original file line number Diff line number Diff line change
Expand Up @@ -722,14 +722,16 @@ 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::<ServerJobResult>(32); // TODO: pick some buffer value
let sns_client_bg = sns_client.clone();
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,
Expand All @@ -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()
Expand Down

0 comments on commit 2d135ce

Please sign in to comment.