Skip to content
This repository has been archived by the owner on Nov 15, 2023. It is now read-only.

rpc-author: Downgrade the logging level of some logs #10483

Merged
merged 3 commits into from
Dec 14, 2021
Merged

rpc-author: Downgrade the logging level of some logs #10483

Changes from 1 commit
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
83d0e8a
rpc-author: Downgrade the logging level of some logs
bkchr Dec 14, 2021
69d8fdc
FMT
bkchr Dec 14, 2021
a7fdef2
Merge remote-tracking branch 'origin/master' into bkchr-rpc-author-do…
bkchr Dec 14, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 4 additions & 5 deletions client/rpc/src/author/mod.rs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -21,7 +21,6 @@
#[cfg(test)]
mod tests;

use log::warn;
use std::{convert::TryInto, sync::Arc};

use sp_blockchain::HeaderBackend;
Expand Down Expand Up @@ -188,7 +187,7 @@ where
let dxt = match TransactionFor::<P>::decode(&mut &xt[..]).map_err(error::Error::from) {
Ok(tx) => tx,
Err(err) => {
warn!("Failed to submit extrinsic: {}", err);
log::debug!("Failed to submit extrinsic: {}", err);
// reject the subscriber (ignore errors - we don't care if subscriber is no longer
// there).
let _ = subscriber.reject(err.into());
Expand All @@ -211,7 +210,7 @@ where
let tx_stream = match submit.await {
Ok(s) => s,
Err(err) => {
warn!("Failed to submit extrinsic: {}", err);
log::debug!("Failed to submit extrinsic: {}", err);
// reject the subscriber (ignore errors - we don't care if subscriber is no
// longer there).
let _ = subscriber.reject(err.into());
Expand All @@ -222,14 +221,14 @@ where
subscriptions.add(subscriber, move |sink| {
tx_stream
.map(|v| Ok(Ok(v)))
.forward(sink.sink_map_err(|e| warn!("Error sending notifications: {:?}", e)))
.forward(sink.sink_map_err(|e| log::debug!("Error sending notifications: {:?}", e)))
.map(drop)
});
};

let res = self.subscriptions.executor().spawn_obj(future.boxed().into());
if res.is_err() {
warn!("Error spawning subscription RPC task.");
log::warn!("Error spawning subscription RPC task.");
}
}

Expand Down