Parcourir la source

修复一些小问题。

skyffire il y a 1 an
Parent
commit
d5b02e2f43
2 fichiers modifiés avec 4 ajouts et 1 suppressions
  1. 1 1
      global/src/trace_stack.rs
  2. 3 0
      strategy/src/bybit_usdt_swap.rs

+ 1 - 1
global/src/trace_stack.rs

@@ -141,7 +141,7 @@ impl fmt::Display for TraceStack {
             msg.push_str(format!("数据格式化完毕{}ns  ", self.after_format).as_str());
         }
 
-        if self.after_format != 0 {
+        if self.after_unlock_core != 0 {
             msg.push_str(format!("解锁完毕{}ns  ", self.after_unlock_core).as_str());
         }
 

+ 3 - 0
strategy/src/bybit_usdt_swap.rs

@@ -6,6 +6,7 @@ use rust_decimal::Decimal;
 use tokio::{spawn, time};
 use tokio::sync::Mutex;
 use tokio::time::Instant;
+use tracing::info;
 use exchanges::bybit_swap_ws::{BybitSwapLogin, BybitSwapSubscribeType, BybitSwapWs, BybitSwapWsType};
 use exchanges::response_base::ResponseData;
 use global::trace_stack::TraceStack;
@@ -179,6 +180,8 @@ async fn on_public_data(core_arc_clone: Arc<Mutex<Core>>, update_flag_u: &mut De
             let special_depth = standard::handle_info::HandleSwapInfo::handle_book_ticker(BybitSwap, &response);
             trace_stack.on_after_format();
 
+            info!("{}", trace_stack.to_string());
+
             on_special_depth(core_arc_clone, update_flag_u, &response.label, &mut trace_stack, &special_depth).await;
         }
         "orderbook" => {