瀏覽代碼

ws报错使用error而不是trace……

skyffire 1 年之前
父節點
當前提交
5459775416
共有 3 個文件被更改,包括 6 次插入6 次删除
  1. 2 2
      exchanges/src/binance_swap_ws.rs
  2. 2 2
      exchanges/src/bybit_swap_ws.rs
  3. 2 2
      exchanges/src/gate_swap_ws.rs

+ 2 - 2
exchanges/src/binance_swap_ws.rs

@@ -5,7 +5,7 @@ use futures_channel::mpsc::{UnboundedReceiver, UnboundedSender};
 use serde_json::{json, Value};
 use tokio::sync::Mutex;
 use tokio_tungstenite::tungstenite::{Error, Message};
-use tracing::{info, trace};
+use tracing::{error, info, trace};
 
 use crate::response_base::ResponseData;
 use crate::socket_tool::AbstractWsMode;
@@ -194,7 +194,7 @@ impl BinanceSwapWs {
                                                    Self::message_pong,
             ).await {
                 Ok(_) => { trace!("线程-异步链接-结束"); }
-                Err(e) => { trace!("发生异常:币安-期货链接关闭-{:?}",e); }
+                Err(e) => { error!("发生异常:币安-期货链接关闭-{:?}",e); }
             }
         });
         tokio::try_join!(t2).unwrap();

+ 2 - 2
exchanges/src/bybit_swap_ws.rs

@@ -6,7 +6,7 @@ use futures_channel::mpsc::{UnboundedReceiver, UnboundedSender};
 use serde_json::{json, Value};
 use tokio::sync::Mutex;
 use tokio_tungstenite::tungstenite::{Error, Message};
-use tracing::{info, trace};
+use tracing::{error, info, trace};
 
 use ring::hmac;
 
@@ -253,7 +253,7 @@ impl BybitSwapWs {
                                                    Self::message_pong,
             ).await {
                 Ok(_) => { trace!("线程-异步链接-结束"); }
-                Err(e) => { trace!("发生异常:bitget-期货链接关闭-{:?}",e); }
+                Err(e) => { error!("发生异常:bybit_usdt_swap 链接关闭-{:?}",e); }
             }
         });
         tokio::try_join!(t2).unwrap();

+ 2 - 2
exchanges/src/gate_swap_ws.rs

@@ -9,7 +9,7 @@ use serde_json::{json, Value};
 use sha2::Sha512;
 use tokio::sync::Mutex;
 use tokio_tungstenite::tungstenite::{Error, Message};
-use tracing::{info, trace};
+use tracing::{error, info, trace};
 
 use crate::response_base::ResponseData;
 use crate::socket_tool::{AbstractWsMode, HeartbeatType};
@@ -306,7 +306,7 @@ impl GateSwapWs {
                                                    Self::message_pong,
             ).await {
                 Ok(_) => { trace!("线程-异步链接-结束"); }
-                Err(e) => { trace!("发生异常:gate-期货链接关闭-{:?}",e); }
+                Err(e) => { error!("发生异常:gate-期货链接关闭-{:?}",e); }
             }
         });
         tokio::try_join!(t2).unwrap();