clean log messages

bench-tps/src/confirmations_processing.rs

@@ -140,15 +140,15 @@ impl LogTransactionService {
                             });});
                         }
                         Err(e) => {
-                            info!("@@@ Stop LogTransactionService, message received: {e}");
+                            info!("Stop LogTransactionService, message received: {e}");
                             log_writer.flush();
                             break;
                         }
                     }
                 },
                 recv(block_processing_timer_receiver) -> _ => {
                     let mut measure_process_blocks = Measure::start("measure_process_blocks");
-                    info!("@@@ sign_receiver queue len: {}", signature_receiver.len());
+                    info!("sign_receiver queue len: {}", signature_receiver.len());
                     let block_slots = get_blocks_with_retry(&client, start_block);
                     let Ok(block_slots) = block_slots else {
                         error!("Failed to get blocks, stop LogWriterService.");
@@ -178,12 +178,11 @@ impl LogTransactionService {
                         )
                     }
                     Self::clean_transaction_map(&mut log_writer, &mut signature_to_tx_info);
-
-                    // maybe ok to write every time here? Or create a separate timer
-                    log_writer.flush();
                     measure_process_blocks.stop();
+
                     let time_send_us = measure_process_blocks.as_us();
-                    info!("@@@ Time to process {num_blocks} blocks: {time_send_us}")
+                    info!("Time to process {num_blocks} blocks: {time_send_us}");
+                    log_writer.flush();
                 },
             }
         }