client: downgrade logs from error/warn -> debug (#1343)

paritytech · Apr 5, 2024 · 659ab6e · 659ab6e
1 parent 0620f86
commit 659ab6e
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 10 deletions.
diff --git 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
@@ -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(&notif.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(&notif.method);
 			}
 		},

diff --git 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<S: TransportSenderT>(
 	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<S: TransportSenderT>(
 		// 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<S: TransportSenderT>(
 				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);
 					}
 				}