More emojies and spaces (#5498)

* More emojies and spaces

* Sync emojis

* More emoji
This commit is contained in:
Gavin Wood
2020-04-02 20:17:39 +02:00
committed by GitHub
parent 2e720f93a2
commit 3b43429729
7 changed files with 23 additions and 23 deletions
+2 -2
View File
@@ -41,8 +41,8 @@ async fn start_inner(chain_spec: String, log_level: String) -> Result<Client, Bo
let config = browser_configuration(chain_spec).await?;
info!("Substrate browser node");
info!(" version {}", config.full_version());
info!(" by Parity Technologies, 2017-2020");
info!("✌️ version {}", config.full_version());
info!("❤️ by Parity Technologies, 2017-2020");
info!("📋 Chain specification: {}", config.expect_chain_spec().name());
info!("🏷 Node name: {}", config.name);
info!("👤 Roles: {:?}", config.roles);
+2 -2
View File
@@ -459,8 +459,8 @@ impl RunCmd {
SF: AbstractService + Unpin,
{
info!("{}", version.name);
info!(" version {}", config.full_version());
info!(" by {}, {}-{}", version.author, version.copyright_start_year, Local::today().year());
info!("✌️ version {}", config.full_version());
info!("❤️ by {}, {}-{}", version.author, version.copyright_start_year, Local::today().year());
info!("📋 Chain specification: {}", config.expect_chain_spec().name());
info!("🏷 Node name: {}", config.name);
info!("👤 Roles: {}", config.display_role());
@@ -262,7 +262,7 @@ where
// check if the given best block is in the same branch as the block that signaled the change.
if is_descendent_of(&change.canon_hash, &best_hash)? {
// apply this change: make the set canonical
info!(target: "afg", "Applying authority set change forced at block #{:?}",
info!(target: "afg", "👴 Applying authority set change forced at block #{:?}",
change.canon_height);
telemetry!(CONSENSUS_INFO; "afg.applying_forced_authority_set_change";
"block" => ?change.canon_height
@@ -328,7 +328,7 @@ where
self.pending_forced_changes.clear();
if let Some(change) = change {
info!(target: "afg", "Applying authority set change scheduled at block #{:?}",
info!(target: "afg", "👴 Applying authority set change scheduled at block #{:?}",
change.canon_height);
telemetry!(CONSENSUS_INFO; "afg.applying_scheduled_authority_set_change";
"block" => ?change.canon_height
+2 -2
View File
@@ -69,8 +69,8 @@ impl<B: BlockT> InformantDisplay<B> {
let (status, target) = match (net_status.sync_state, net_status.best_seen_block) {
(SyncState::Idle, _) => ("💤 Idle".into(), "".into()),
(SyncState::Downloading, None) => (format!("⚙️ Syncing{}", speed), "".into()),
(SyncState::Downloading, Some(n)) => (format!("⚙️ Syncing{}", speed), format!(", target=#{}", n)),
(SyncState::Downloading, None) => (format!("⚙️ Preparing{}", speed), "".into()),
(SyncState::Downloading, Some(n)) => (format!("⚙️ Syncing{}", speed), format!(", target=#{}", n)),
};
if self.format == OutputFormat::Coloured {
+12 -12
View File
@@ -818,7 +818,7 @@ impl<B: BlockT> ChainSync<B> {
if let Some(peer) = self.peers.get_mut(&who) {
peer
} else {
error!(target: "sync", "Called on_block_justification with a bad peer ID");
error!(target: "sync", "💔 Called on_block_justification with a bad peer ID");
return Ok(OnBlockJustification::Nothing)
};
@@ -831,7 +831,7 @@ impl<B: BlockT> ChainSync<B> {
if hash != block.hash {
info!(
target: "sync",
"Invalid block justification provided by {}: requested: {:?} got: {:?}", who, hash, block.hash
"💔 Invalid block justification provided by {}: requested: {:?} got: {:?}", who, hash, block.hash
);
return Err(BadPeer(who, rep::BAD_JUSTIFICATION));
}
@@ -865,7 +865,7 @@ impl<B: BlockT> ChainSync<B> {
if let Some(peer) = self.peers.get_mut(&who) {
peer
} else {
error!(target: "sync", "Called on_block_finality_proof_data with a bad peer ID");
error!(target: "sync", "💔 Called on_block_finality_proof_data with a bad peer ID");
return Ok(OnBlockFinalityProof::Nothing)
};
@@ -877,7 +877,7 @@ impl<B: BlockT> ChainSync<B> {
if hash != resp.block {
info!(
target: "sync",
"Invalid block finality proof provided: requested: {:?} got: {:?}",
"💔 Invalid block finality proof provided: requested: {:?} got: {:?}",
hash,
resp.block
);
@@ -959,14 +959,14 @@ impl<B: BlockT> ChainSync<B> {
},
Err(BlockImportError::IncompleteHeader(who)) => {
if let Some(peer) = who {
warn!("Peer sent block with incomplete header to import");
warn!("💔 Peer sent block with incomplete header to import");
output.push(Err(BadPeer(peer, rep::INCOMPLETE_HEADER)));
output.extend(self.restart());
}
},
Err(BlockImportError::VerificationFailed(who, e)) => {
if let Some(peer) = who {
warn!("Verification failed for block {:?} received from peer: {}, {:?}", hash, peer, e);
warn!("💔 Verification failed for block {:?} received from peer: {}, {:?}", hash, peer, e);
output.push(Err(BadPeer(peer, rep::VERIFICATION_FAIL)));
output.extend(self.restart());
}
@@ -985,7 +985,7 @@ impl<B: BlockT> ChainSync<B> {
},
e @ Err(BlockImportError::UnknownParent) |
e @ Err(BlockImportError::Other(_)) => {
warn!(target: "sync", "Error importing block {:?}: {:?}", hash, e);
warn!(target: "sync", "💔 Error importing block {:?}: {:?}", hash, e);
output.extend(self.restart());
},
Err(BlockImportError::Cancelled) => {}
@@ -1017,7 +1017,7 @@ impl<B: BlockT> ChainSync<B> {
});
if let Err(err) = r {
warn!(target: "sync", "Error cleaning up pending extra finality proof data requests: {:?}", err)
warn!(target: "sync", "💔 Error cleaning up pending extra finality proof data requests: {:?}", err)
}
let client = &self.client;
@@ -1026,7 +1026,7 @@ impl<B: BlockT> ChainSync<B> {
});
if let Err(err) = r {
warn!(target: "sync", "Error cleaning up pending extra justification data requests: {:?}", err);
warn!(target: "sync", "💔 Error cleaning up pending extra justification data requests: {:?}", err);
}
}
@@ -1080,7 +1080,7 @@ impl<B: BlockT> ChainSync<B> {
let number = *header.number();
debug!(target: "sync", "Received block announcement {:?} with number {:?} from {}", hash, number, who);
if number.is_zero() {
warn!(target: "sync", "Ignored genesis block (#0) announcement from {}: {}", who, hash);
warn!(target: "sync", "💔 Ignored genesis block (#0) announcement from {}: {}", who, hash);
return OnBlockAnnounce::Nothing
}
let parent_status = self.block_status(header.parent_hash()).ok().unwrap_or(BlockStatus::Unknown);
@@ -1091,7 +1091,7 @@ impl<B: BlockT> ChainSync<B> {
let peer = if let Some(peer) = self.peers.get_mut(&who) {
peer
} else {
error!(target: "sync", "Called on_block_announce with a bad peer ID");
error!(target: "sync", "💔 Called on_block_announce with a bad peer ID");
return OnBlockAnnounce::Nothing
};
while peer.recently_announced.len() >= ANNOUNCE_HISTORY_SIZE {
@@ -1137,7 +1137,7 @@ impl<B: BlockT> ChainSync<B> {
return OnBlockAnnounce::Nothing
}
Err(e) => {
error!(target: "sync", "Block announcement validation errored: {}", e);
error!(target: "sync", "💔 Block announcement validation errored: {}", e);
return OnBlockAnnounce::Nothing
}
}
+1 -1
View File
@@ -441,7 +441,7 @@ fn build_network_future<
log!(
target: "service",
if polling_dur >= Duration::from_secs(1) { Level::Warn } else { Level::Trace },
"Polling the network future took {:?}",
"⚠️ Polling the network future took {:?}",
polling_dur
);
@@ -116,7 +116,7 @@ where TTrans: Clone + Unpin, TTrans::Dial: Unpin,
pending.push_back(payload.into());
Ok(())
} else {
warn!(target: "telemetry", "⚠️ Rejected log entry because queue is full for {:?}",
warn!(target: "telemetry", "⚠️ Rejected log entry because queue is full for {:?}",
self.addr);
Err(())
}
@@ -137,7 +137,7 @@ where TTrans: Clone + Unpin, TTrans::Dial: Unpin,
break NodeSocket::Connected(conn)
},
Poll::Ready(Err(err)) => {
warn!(target: "telemetry", "⚠️ Disconnected from {}: {:?}", self.addr, err);
warn!(target: "telemetry", "⚠️ Disconnected from {}: {:?}", self.addr, err);
let timeout = gen_rand_reconnect_delay();
self.socket = NodeSocket::WaitingReconnect(timeout);
return Poll::Ready(NodeEvent::Disconnected(err))