diff --git a/client/transport/src/ws/mod.rs b/client/transport/src/ws/mod.rs index 8ea8aaf2e4..4a2fd6ef8b 100644 --- a/client/transport/src/ws/mod.rs +++ b/client/transport/src/ws/mod.rs @@ -372,7 +372,7 @@ impl WsTransportClientBuilder { Ok(uri) => { // Absolute URI. target = uri.try_into().map_err(|e| { - tracing::error!(target: LOG_TARGET, "Redirection failed: {:?}", e); + tracing::debug!(target: LOG_TARGET, "Redirection failed: {:?}", e); e })?; diff --git a/core/src/client/async_client/helpers.rs b/core/src/client/async_client/helpers.rs index fa9f917465..9137a342bf 100644 --- a/core/src/client/async_client/helpers.rs +++ b/core/src/client/async_client/helpers.rs @@ -63,7 +63,7 @@ pub(crate) fn process_batch_response( let batch_state = match manager.complete_pending_batch(range.clone()) { Some(state) => state, None => { - tracing::warn!(target: LOG_TARGET, "Received unknown batch response"); + tracing::debug!(target: LOG_TARGET, "Received unknown batch response"); return Err(InvalidRequestId::NotPendingRequest(format!("{:?}", range))); } }; @@ -110,7 +110,7 @@ pub(crate) fn process_subscription_response( Ok(_) => None, Err(TrySubscriptionSendError::Closed) => Some(sub_id), Err(TrySubscriptionSendError::TooSlow(m)) => { - tracing::error!(target: LOG_TARGET, "Subscription {{method={}, sub_id={:?}}} couldn't keep up with server; failed to send {m}", response.method, sub_id); + tracing::debug!(target: LOG_TARGET, "Subscription {{method={}, sub_id={:?}}} couldn't keep up with server; failed to send {m}", response.method, sub_id); Some(sub_id) } }, @@ -156,7 +156,7 @@ pub(crate) fn process_notification(manager: &mut RequestManager, notif: Notifica let _ = manager.remove_notification_handler(¬if.method); } Err(TrySubscriptionSendError::TooSlow(m)) => { - tracing::error!(target: LOG_TARGET, "Notification `{}` couldn't keep up with server; failed to send {m}", notif.method); + tracing::debug!(target: LOG_TARGET, "Notification `{}` couldn't keep up with server; failed to send {m}", notif.method); let _ = manager.remove_notification_handler(¬if.method); } }, diff --git a/core/src/client/async_client/mod.rs b/core/src/client/async_client/mod.rs index ff29978055..dfbd697a40 100644 --- a/core/src/client/async_client/mod.rs +++ b/core/src/client/async_client/mod.rs @@ -846,7 +846,7 @@ async fn handle_frontend_messages( match message { FrontToBack::Batch(batch) => { if let Err(send_back) = manager.lock().insert_pending_batch(batch.ids.clone(), batch.send_back) { - tracing::warn!(target: LOG_TARGET, "Batch request already pending: {:?}", batch.ids); + tracing::debug!(target: LOG_TARGET, "Batch request already pending: {:?}", batch.ids); let _ = send_back.send(Err(InvalidRequestId::Occupied(format!("{:?}", batch.ids)).into())); return Ok(()); } @@ -860,7 +860,7 @@ async fn handle_frontend_messages( // User called `request` on the front-end FrontToBack::Request(request) => { if let Err(send_back) = manager.lock().insert_pending_call(request.id.clone(), request.send_back) { - tracing::warn!(target: LOG_TARGET, "Denied duplicate method call"); + tracing::debug!(target: LOG_TARGET, "Denied duplicate method call"); if let Some(s) = send_back { let _ = s.send(Err(InvalidRequestId::Occupied(request.id.to_string()).into())); @@ -878,7 +878,7 @@ async fn handle_frontend_messages( sub.send_back, sub.unsubscribe_method, ) { - tracing::warn!(target: LOG_TARGET, "Denied duplicate subscription"); + tracing::debug!(target: LOG_TARGET, "Denied duplicate subscription"); let _ = send_back.send(Err(InvalidRequestId::Occupied(format!( "sub_id={}:req_id={}", @@ -974,13 +974,13 @@ where if let Err(e) = handle_frontend_messages(msg, &manager, &mut sender, max_buffer_capacity_per_subscription).await { - tracing::error!(target: LOG_TARGET, "ws send failed: {e}"); + tracing::debug!(target: LOG_TARGET, "ws send failed: {e}"); break Err(Error::Transport(e.into())); } } _ = ping_interval.next() => { if let Err(err) = sender.send_ping().await { - tracing::error!(target: LOG_TARGET, "Send ws ping failed: {err}"); + tracing::debug!(target: LOG_TARGET, "Send ws ping failed: {err}"); break Err(Error::Transport(err.into())); } } @@ -1051,7 +1051,7 @@ where } } Err(e) => { - tracing::error!(target: LOG_TARGET, "Failed to read message: {e}"); + tracing::debug!(target: LOG_TARGET, "Failed to read message: {e}"); break Err(e); } }