pezkuwichain/pezkuwi-subxt
1
0
Fork 0
mirror of https://github.com/pezkuwichain/pezkuwi-subxt.git synced 2026-06-12 08:51:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add emojis (#5420)

Browse Source
This commit is contained in:
Gavin Wood
2020-03-27 10:41:31 +01:00
committed by GitHub
parent 15df85a000
commit acab5f0570
19 changed files with 42 additions and 42 deletions
Download Patch File Download Diff File Expand all files Collapse all files
substrate/bin/node/cli/src/browser.rs
+3 -3
View File
@@ -43,9 +43,9 @@ async fn start_inner(chain_spec: String, log_level: String) -> Result<Client, Bo
info!("Substrate browser node");
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);
info!("📋 Chain specification: {}", config.expect_chain_spec().name());
info!("🏷 Node name: {}", config.name);
info!("👤 Roles: {:?}", config.roles);
// Create the service. This is the most heavy initialization step.
let service = crate::service::new_light(config)
substrate/client/basic-authorship/src/basic_authorship.rs
+2 -2
View File
@@ -76,7 +76,7 @@ impl<B, Block, C, A> ProposerFactory<A, B, C>
let id = BlockId::hash(parent_hash);
info!("Starting consensus session on top of parent {:?}", parent_hash);
info!("🙌 Starting consensus session on top of parent {:?}", parent_hash);
let proposer = Proposer {
inner: Arc::new(ProposerInner {
@@ -277,7 +277,7 @@ impl<A, B, Block, C> ProposerInner<B, Block, C, A>
let (block, storage_changes, proof) = block_builder.build()?.into_inner();
info!("Prepared block for proposing at {} [hash: {:?}; parent_hash: {}; extrinsics ({}): [{}]]",
info!("🎁 Prepared block for proposing at {} [hash: {:?}; parent_hash: {}; extrinsics ({}): [{}]]",
block.header().number(),
<Block as BlockT>::Hash::from(block.header().hash()),
block.header().parent_hash(),
substrate/client/cli/src/commands/runcmd.rs
+4 -4
View File
@@ -140,7 +140,7 @@ pub struct RunCmd {
///
/// A comma-separated list of origins (protocol://domain or special `null`
/// value). Value of `all` will disable origin validation. Default is to
/// allow localhost and https://polkadot.js.org origins. When running in
/// allow localhost and https://polkadot.js.org origins. When running in
/// --dev mode the default is to allow all origins.
#[structopt(long = "rpc-cors", value_name = "ORIGINS", parse(try_from_str = parse_cors))]
pub rpc_cors: Option<Cors>,
@@ -461,9 +461,9 @@ impl RunCmd {
info!("{}", version.name);
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());
info!("📋 Chain specification: {}", config.expect_chain_spec().name());
info!("🏷 Node name: {}", config.name);
info!("👤 Roles: {}", config.display_role());
match config.roles {
Roles::LIGHT => run_service_until_exit(
substrate/client/cli/src/lib.rs
+1 -1
View File
@@ -211,7 +211,7 @@ pub fn init_logger(pattern: &str) {
});
if builder.try_init().is_err() {
info!("Not registering Substrate logger, as there is already a global logger registered!");
info!("💬 Not registering Substrate logger, as there is already a global logger registered!");
}
}
substrate/client/consensus/babe/src/lib.rs
+3 -3
View File
@@ -368,7 +368,7 @@ pub fn start_babe<B, C, SC, E, I, SO, CAW, Error>(BabeParams {
&inherent_data_providers,
)?;
babe_info!("Starting BABE Authorship worker");
babe_info!("👶 Starting BABE Authorship worker");
Ok(sc_consensus_slots::start_slot_worker(
config.0,
select_chain,
@@ -1010,7 +1010,7 @@ impl<Block, Client, Inner> BlockImport<Block> for BabeBlockImport<Block, Client,
ConsensusError::ClientImport(Error::<Block>::FetchEpoch(parent_hash).into())
})?;
babe_info!("New epoch {} launching at block {} (block slot {} >= start slot {}).",
babe_info!("👶 New epoch {} launching at block {} (block slot {} >= start slot {}).",
viable_epoch.as_ref().epoch_index,
hash,
slot_number,
@@ -1018,7 +1018,7 @@ impl<Block, Client, Inner> BlockImport<Block> for BabeBlockImport<Block, Client,
let next_epoch = viable_epoch.increment(next_epoch_descriptor);
babe_info!("Next epoch starts at slot {}", next_epoch.as_ref().start_slot);
babe_info!("👶 Next epoch starts at slot {}", next_epoch.as_ref().start_slot);
// prune the tree of epochs not part of the finalized chain or
// that are not live anymore, and then track the given epoch change
substrate/client/consensus/manual-seal/src/finalize_block.rs
+2 -2
View File
@@ -57,8 +57,8 @@ pub async fn finalize_block<B, CB>(params: FinalizeBlockParams<B, CB>)
rpc::send_result(&mut sender, Err(e.into()))
}
Ok(()) => {
log::info!("Successfully finalized block: {}", hash);
log::info!("✅ Successfully finalized block: {}", hash);
rpc::send_result(&mut sender, Ok(()))
}
}
}
}
substrate/client/consensus/slots/src/lib.rs
+3 -3
View File
@@ -258,10 +258,10 @@ pub trait SimpleSlotWorker<B: BlockT> {
Box::new(futures::future::select(proposing, delay).map(move |v| match v {
futures::future::Either::Left((b, _)) => b.map(|b| (b, claim)),
futures::future::Either::Right(_) => {
info!("Discarding proposal for slot {}; block production took too long", slot_number);
info!("⌛️ Discarding proposal for slot {}; block production took too long", slot_number);
// If the node was compiled with debug, tell the user to use release optimizations.
#[cfg(build_type="debug")]
info!("Recompile your node in `--release` mode to mitigate this problem.");
info!("👉 Recompile your node in `--release` mode to mitigate this problem.");
telemetry!(CONSENSUS_INFO; "slots.discarding_proposal_took_too_long";
"slot" => slot_number,
);
@@ -289,7 +289,7 @@ pub trait SimpleSlotWorker<B: BlockT> {
);
info!(
"Pre-sealed block for proposal at {}. Hash now {:?}, previously {:?}.",
"🔖 Pre-sealed block for proposal at {}. Hash now {:?}, previously {:?}.",
header_num,
block_import_params.post_hash(),
header_hash,
substrate/client/finality-grandpa/src/environment.rs
+2 -2
View File
@@ -1090,9 +1090,9 @@ pub(crate) fn finalize_block<BE, Block, Client>(
let (new_id, set_ref) = authority_set.current();
if set_ref.len() > 16 {
info!("Applying GRANDPA set change to new set with {} authorities", set_ref.len());
info!("👴 Applying GRANDPA set change to new set with {} authorities", set_ref.len());
} else {
info!("Applying GRANDPA set change to new set {:?}", set_ref);
info!("👴 Applying GRANDPA set change to new set {:?}", set_ref);
}
telemetry!(CONSENSUS_INFO; "afg.generating_new_authority_set";
substrate/client/finality-grandpa/src/import.rs
+1 -1
View File
@@ -629,7 +629,7 @@ where
match result {
Err(CommandOrError::VoterCommand(command)) => {
info!(target: "afg", "Imported justification for block #{} that triggers \
info!(target: "afg", "👴 Imported justification for block #{} that triggers \
command {}, signaling voter.", number, command);
// send the command to the voter
substrate/client/informant/src/display.rs
+3 -3
View File
@@ -68,9 +68,9 @@ impl<B: BlockT> InformantDisplay<B> {
self.last_number = Some(best_number);
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::Idle, _) => ("💤 Idle".into(), "".into()),
(SyncState::Downloading, None) => (format!("⚙️ Syncing{}", speed), "".into()),
(SyncState::Downloading, Some(n)) => (format!("⚙️ Syncing{}", speed), format!(", target=#{}", n)),
};
if self.format == OutputFormat::Coloured {
substrate/client/informant/src/lib.rs
+2 -2
View File
@@ -79,7 +79,7 @@ pub fn build(service: &impl AbstractService, format: OutputFormat) -> impl futur
match maybe_ancestor {
Ok(ref ancestor) if ancestor.hash != *last_hash => info!(
"Reorg from #{},{} to #{},{}, common ancestor #{},{}",
"♻️ Reorg from #{},{} to #{},{}, common ancestor #{},{}",
last_num, last_hash,
n.header.number(), n.hash,
ancestor.number, ancestor.hash,
@@ -94,7 +94,7 @@ pub fn build(service: &impl AbstractService, format: OutputFormat) -> impl futur
last_best = Some((n.header.number().clone(), n.hash.clone()));
}
info!(target: "substrate", "Imported #{} ({})", n.header.number(), n.hash);
info!(target: "substrate", "✨ Imported #{} ({})", n.header.number(), n.hash);
future::ready(())
});
substrate/client/network/src/discovery.rs
+1 -1
View File
@@ -293,7 +293,7 @@ impl NetworkBehaviour for DiscoveryBehaviour {
fn inject_new_external_addr(&mut self, addr: &Multiaddr) {
let new_addr = addr.clone()
.with(Protocol::P2p(self.local_peer_id.clone().into()));
info!(target: "sub-libp2p", "Discovered new external address for our node: {}", new_addr);
info!(target: "sub-libp2p", "🔍 Discovered new external address for our node: {}", new_addr);
NetworkBehaviour::inject_new_external_addr(&mut self.kademlia, addr)
}
substrate/client/network/src/protocol/light_dispatch.rs
+3 -3
View File
@@ -270,7 +270,7 @@ impl<B: BlockT> LightDispatch<B> where
let request = match self.remove(peer.clone(), request_id) {
Some(request) => request,
None => {
info!("Invalid remote {} response from peer {}", rtype, peer);
info!("💔 Invalid remote {} response from peer {}", rtype, peer);
network.report_peer(&peer, ReputationChange::new_fatal("Invalid remote response"));
network.disconnect_peer(&peer);
self.remove_peer(&peer);
@@ -282,7 +282,7 @@ impl<B: BlockT> LightDispatch<B> where
let (retry_count, retry_request_data) = match try_accept(request, &self.checker) {
Accept::Ok => (retry_count, None),
Accept::CheckFailed(error, retry_request_data) => {
info!("Failed to check remote {} response from peer {}: {}", rtype, peer, error);
info!("💔 Failed to check remote {} response from peer {}: {}", rtype, peer, error);
network.report_peer(&peer, ReputationChange::new_fatal("Failed remote response check"));
network.disconnect_peer(&peer);
self.remove_peer(&peer);
@@ -296,7 +296,7 @@ impl<B: BlockT> LightDispatch<B> where
}
},
Accept::Unexpected(retry_request_data) => {
info!("Unexpected response to remote {} from peer", rtype);
info!("💔 Unexpected response to remote {} from peer", rtype);
network.report_peer(&peer, ReputationChange::new_fatal("Unexpected remote response"));
network.disconnect_peer(&peer);
self.remove_peer(&peer);
substrate/client/network/src/protocol/sync.rs
+5 -5
View File
@@ -378,12 +378,12 @@ impl<B: BlockT> ChainSync<B> {
Err(BadPeer(who, rep::BLOCKCHAIN_READ_ERROR))
}
Ok(BlockStatus::KnownBad) => {
info!("New peer with known bad best block {} ({}).", best_hash, best_number);
info!("💔 New peer with known bad best block {} ({}).", best_hash, best_number);
Err(BadPeer(who, rep::BAD_BLOCK))
}
Ok(BlockStatus::Unknown) => {
if best_number.is_zero() {
info!("New peer with unknown genesis hash {} ({}).", best_hash, best_number);
info!("💔 New peer with unknown genesis hash {} ({}).", best_hash, best_number);
return Err(BadPeer(who, rep::GENESIS_MISMATCH));
}
// If there are more than `MAJOR_SYNC_BLOCKS` in the import queue then we have
@@ -711,7 +711,7 @@ impl<B: BlockT> ChainSync<B> {
return Err(BadPeer(who, rep::UNKNOWN_ANCESTOR))
},
(_, Err(e)) => {
info!("Error answering legitimate blockchain query: {:?}", e);
info!("❌ Error answering legitimate blockchain query: {:?}", e);
return Err(BadPeer(who, rep::BLOCKCHAIN_READ_ERROR))
}
};
@@ -943,7 +943,7 @@ impl<B: BlockT> ChainSync<B> {
if aux.bad_justification {
if let Some(peer) = who {
info!("Sent block with bad justification to import");
info!("💔 Sent block with bad justification to import");
output.push(Err(BadPeer(peer, rep::BAD_JUSTIFICATION)));
}
}
@@ -973,7 +973,7 @@ impl<B: BlockT> ChainSync<B> {
},
Err(BlockImportError::BadBlock(who)) => {
if let Some(peer) = who {
info!("Block {:?} received from peer {} has been blacklisted", hash, peer);
info!("💔 Block {:?} received from peer {} has been blacklisted", hash, peer);
output.push(Err(BadPeer(peer, rep::BAD_BLOCK)));
}
},
substrate/client/network/src/protocol/sync/extra_requests.rs
+1 -1
View File
@@ -221,7 +221,7 @@ impl<B: BlockT> ExtraRequests<B> {
};
if self.tree.finalize_root(&finalized_hash).is_none() {
warn!(target: "sync", "Imported {:?} {:?} which isn't a root in the tree: {:?}",
warn!(target: "sync", "‼️ Imported {:?} {:?} which isn't a root in the tree: {:?}",
finalized_hash,
finalized_number,
self.tree.roots().collect::<Vec<_>>()
substrate/client/network/src/service.rs
+2 -2
View File
@@ -1090,7 +1090,7 @@ impl<'a, B: BlockT, H: ExHashT> Link<B> for NetworkLink<'a, B, H> {
fn justification_imported(&mut self, who: PeerId, hash: &B::Hash, number: NumberFor<B>, success: bool) {
self.protocol.user_protocol_mut().justification_import_result(hash.clone(), number, success);
if !success {
info!("Invalid justification provided by {} for #{}", who, hash);
info!("💔 Invalid justification provided by {} for #{}", who, hash);
self.protocol.user_protocol_mut().disconnect_peer(&who);
self.protocol.user_protocol_mut().report_peer(who, ReputationChange::new_fatal("Invalid justification"));
}
@@ -1110,7 +1110,7 @@ impl<'a, B: BlockT, H: ExHashT> Link<B> for NetworkLink<'a, B, H> {
let success = finalization_result.is_ok();
self.protocol.user_protocol_mut().finality_proof_import_result(request_block, finalization_result);
if !success {
info!("Invalid finality proof provided by {} for #{}", who, request_block.0);
info!("💔 Invalid finality proof provided by {} for #{}", who, request_block.0);
self.protocol.user_protocol_mut().disconnect_peer(&who);
self.protocol.user_protocol_mut().report_peer(who, ReputationChange::new_fatal("Invalid finality proof"));
}
substrate/client/service/src/builder.rs
+1 -1
View File
@@ -827,7 +827,7 @@ ServiceBuilder<
let chain_spec = config.expect_chain_spec();
let version = config.full_version();
info!("Highest known block at #{}", chain_info.best_number);
info!("📦 Highest known block at #{}", chain_info.best_number);
telemetry!(
SUBSTRATE_INFO;
"node.start";
substrate/client/service/src/chain_ops.rs
+2 -2
View File
@@ -125,7 +125,7 @@ impl<
return std::task::Poll::Ready(Err(From::from(err)));
},
};
info!("Importing {} blocks", c);
info!("📦 Importing {} blocks", c);
count = Some(c);
c
}
@@ -185,7 +185,7 @@ impl<
}
if link.imported_blocks >= count {
info!("Imported {} blocks. Best: #{}", read_block_count, client.chain_info().best_number);
info!("🎉 Imported {} blocks. Best: #{}", read_block_count, client.chain_info().best_number);
return std::task::Poll::Ready(Ok(()));
} else {
substrate/client/src/client.rs
+1 -1
View File
@@ -260,7 +260,7 @@ impl<B, E, Block, RA> Client<B, E, Block, RA> where
backend.begin_state_operation(&mut op, BlockId::Hash(Default::default()))?;
let state_root = op.reset_storage(genesis_storage)?;
let genesis_block = genesis::construct_genesis_block::<Block>(state_root.into());
info!("Initializing Genesis block/state (state: {}, header-hash: {})",
info!("🔨 Initializing Genesis block/state (state: {}, header-hash: {})",
genesis_block.header().state_root(),
genesis_block.header().hash()
);