more debug logs

iris-mpc-gpu/src/server/actor.rs

@@ -832,11 +832,9 @@ impl ServerActor {
             deleted_ids: batch.deletion_requests_indices,
         };
         tracing::info!("Res: {:?}", res);
-        
+
         // Pass to internal sender thread
-        return_channel
-            .send(res)
-            .unwrap();
+        return_channel.send(res).unwrap();
 
         // Wait for all streams before get timings
         self.device_manager.await_streams(&self.streams[0]);

iris-mpc-store/src/lib.rs

@@ -306,7 +306,10 @@ DO UPDATE SET right_code = EXCLUDED.right_code, right_mask = EXCLUDED.right_mask
             query.push_bind(result);
         });
 
+        tracing::info!("Before insert_results execution");
         query.build().execute(tx.deref_mut()).await?;
+        tracing::info!("After insert_results execution");
+
         Ok(())
     }
 

iris-mpc/src/bin/server.rs

@@ -722,7 +722,7 @@ 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
@@ -762,11 +762,14 @@ async fn server_main(config: Config) -> eyre::Result<()> {
                             false => None,
                         },
                     );
+                    tracing::info!("result_event: {:?}", result_event);
 
                     serde_json::to_string(&result_event).wrap_err("failed to serialize result")
                 })
                 .collect::<eyre::Result<Vec<_>>>()?;
 
+            tracing::info!("uniqueness_results: {:?}", uniqueness_results);
+
             // Insert non-matching queries into the persistent store.
             let codes_and_masks: Vec<StoredIrisRef> = matches
                 .iter()
@@ -786,11 +789,14 @@ async fn server_main(config: Config) -> eyre::Result<()> {
                 })
                 .collect();
 
+            tracing::info!("Start awaiting store_bg tx");
             let mut tx = store_bg.tx().await?;
+            tracing::info!("End awaiting store_bg tx");
 
             store_bg
                 .insert_results(&mut tx, &uniqueness_results)
                 .await?;
+            tracing::info!("Inserted results");
 
             if !codes_and_masks.is_empty() {
                 store_bg