add lock logs

Author: cody-wang-cb

src/flashblocks/service.rs

@@ -12,7 +12,7 @@ use std::sync::Arc;
 use thiserror::Error;
 use tokio::sync::RwLock;
 use tokio::sync::mpsc;
-use tracing::error;
+use tracing::{error, debug};
 #[derive(Debug, Error)]
 pub enum FlashblocksError {
     #[error("Missing base payload for initial flashblock")]
@@ -162,16 +162,19 @@ impl FlashblocksService {
     ) -> Result<Option<OpExecutionPayloadEnvelopeV3>, FlashblocksError> {
         // consume the best payload and reset the builder
         let payload = {
+            debug!(message = "Acquiring best payload write lock: get_best_payload() to use best_payload");
             let mut builder = self.best_payload.write().await;
             std::mem::take(&mut *builder).into_envelope()?
         };
+        debug!(message = "Acquiring best payload write lock: get_best_payload() to reset best_payload");
         *self.best_payload.write().await = FlashblockBuilder::new();
 
         Ok(Some(payload))
     }
 
     pub async fn set_current_payload_id(&self, payload_id: PayloadId) {
         tracing::debug!(message = "Setting current payload ID", payload_id = %payload_id);
+        debug!(message = "Acquiring current payload id write lock: set_current_payload_id() to use current_payload_id");
         *self.current_payload_id.write().await = payload_id;
     }
 
@@ -185,11 +188,13 @@ impl FlashblocksService {
                 );
 
                 // make sure the payload id matches the current payload id
+                debug!(message = "Acquiring current payload id read lock: on_event() to use current_payload_id");
                 if *self.current_payload_id.read().await != payload.payload_id {
                     error!(message = "Payload ID mismatch",);
                     return;
                 }
 
+                debug!(message = "Acquiring best payload write lock: on_event() to extend best_payload");
                 if let Err(e) = self.best_payload.write().await.extend(payload.clone()) {
                     error!(message = "Failed to extend payload", error = %e);
                 } else {

src/proxy.rs

@@ -308,11 +308,11 @@ async fn process_response(
     };
 
     // log the decoded body
-    debug!(
-    target: "proxy::forward_request",
-    message = "raw response body",
-        body = %String::from_utf8_lossy(&decoded_body),
-    );
+    // debug!(
+    // target: "proxy::forward_request",
+    // message = "raw response body",
+    //     body = %String::from_utf8_lossy(&decoded_body),
+    // );
 
     let rpc_status_code = parse_response_code(&decoded_body);
     record_metrics(

src/server.rs

@@ -494,7 +494,7 @@ impl RollupBoostServer {
 
             let builder = self.builder_client.clone();
 
-            if let Some(payload) = payload {
+            if let Some(_payload) = payload {
                 info!(message = "flashblocks payload exists, but not using it");
             } else {
                 info!(message = "no flashblocks payload");