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

Additional logging (#2693)

Browse Source
This commit is contained in:
Arkadiy Paronyan
2021-03-24 17:24:54 +01:00
committed by GitHub
parent fa11c6d785
commit d78e2fbf86
1 changed files with 73 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
polkadot/node/network/approval-distribution/src/lib.rs
+73 -5
View File
@@ -410,6 +410,14 @@ impl State {
Some(entry) => entry, Some(entry) => entry,
None => { None => {
if let Some(peer_id) = source.peer_id() { if let Some(peer_id) = source.peer_id() {
tracing::debug!(
target: LOG_TARGET,
?source,
?peer_id,
?block_hash,
?validator_index,
"Unexpected assignment",
);
modify_reputation(ctx, peer_id, COST_UNEXPECTED_MESSAGE).await; modify_reputation(ctx, peer_id, COST_UNEXPECTED_MESSAGE).await;
} }
return; return;
@@ -428,11 +436,25 @@ impl State {
match entry.known_by.entry(peer_id.clone()) { match entry.known_by.entry(peer_id.clone()) {
hash_map::Entry::Occupied(knowledge) => { hash_map::Entry::Occupied(knowledge) => {
if knowledge.get().known_messages.contains(&fingerprint) { if knowledge.get().known_messages.contains(&fingerprint) {
tracing::debug!(
target: LOG_TARGET,
?source,
?peer_id,
?fingerprint,
"Duplicate assignment",
);
modify_reputation(ctx, peer_id, COST_DUPLICATE_MESSAGE).await; modify_reputation(ctx, peer_id, COST_DUPLICATE_MESSAGE).await;
return; return;
} }
} }
hash_map::Entry::Vacant(_) => { hash_map::Entry::Vacant(_) => {
tracing::debug!(
target: LOG_TARGET,
?source,
?peer_id,
?fingerprint,
"Assignment from unknown peer",
);
modify_reputation(ctx, peer_id.clone(), COST_UNEXPECTED_MESSAGE).await; modify_reputation(ctx, peer_id.clone(), COST_UNEXPECTED_MESSAGE).await;
} }
} }
@@ -441,6 +463,13 @@ impl State {
if entry.knowledge.known_messages.contains(&fingerprint) { if entry.knowledge.known_messages.contains(&fingerprint) {
modify_reputation(ctx, peer_id.clone(), BENEFIT_VALID_MESSAGE).await; modify_reputation(ctx, peer_id.clone(), BENEFIT_VALID_MESSAGE).await;
if let Some(peer_knowledge) = entry.known_by.get_mut(&peer_id) { if let Some(peer_knowledge) = entry.known_by.get_mut(&peer_id) {
tracing::trace!(
target: LOG_TARGET,
?source,
?peer_id,
?fingerprint,
"Known assignment",
);
peer_knowledge.known_messages.insert(fingerprint.clone()); peer_knowledge.known_messages.insert(fingerprint.clone());
} }
return; return;
@@ -465,6 +494,14 @@ impl State {
} }
}; };
tracing::trace!(
target: LOG_TARGET,
?source,
?peer_id,
?fingerprint,
?result,
"Checked assignment",
);
match result { match result {
AssignmentCheckResult::Accepted => { AssignmentCheckResult::Accepted => {
modify_reputation(ctx, peer_id.clone(), BENEFIT_VALID_MESSAGE_FIRST).await; modify_reputation(ctx, peer_id.clone(), BENEFIT_VALID_MESSAGE_FIRST).await;
@@ -488,11 +525,6 @@ impl State {
} }
AssignmentCheckResult::Bad => { AssignmentCheckResult::Bad => {
modify_reputation(ctx, peer_id, COST_INVALID_MESSAGE).await; modify_reputation(ctx, peer_id, COST_INVALID_MESSAGE).await;
tracing::info!(
target: LOG_TARGET,
?peer_id,
"Got a bad assignment from peer",
);
return; return;
} }
} }
@@ -599,6 +631,13 @@ impl State {
); );
if !entry.knowledge.known_messages.contains(&assignment_fingerprint) { if !entry.knowledge.known_messages.contains(&assignment_fingerprint) {
tracing::debug!(
target: LOG_TARGET,
?source,
?peer_id,
?fingerprint,
"Unknown approval assignment",
);
modify_reputation(ctx, peer_id, COST_UNEXPECTED_MESSAGE).await; modify_reputation(ctx, peer_id, COST_UNEXPECTED_MESSAGE).await;
return; return;
} }
@@ -606,18 +645,39 @@ impl State {
// check if our knowledge of the peer already contains this approval // check if our knowledge of the peer already contains this approval
match entry.known_by.entry(peer_id.clone()) { match entry.known_by.entry(peer_id.clone()) {
hash_map::Entry::Occupied(knowledge) => { hash_map::Entry::Occupied(knowledge) => {
tracing::debug!(
target: LOG_TARGET,
?source,
?peer_id,
?fingerprint,
"Duplicate approval",
);
if knowledge.get().known_messages.contains(&fingerprint) { if knowledge.get().known_messages.contains(&fingerprint) {
modify_reputation(ctx, peer_id, COST_DUPLICATE_MESSAGE).await; modify_reputation(ctx, peer_id, COST_DUPLICATE_MESSAGE).await;
return; return;
} }
} }
hash_map::Entry::Vacant(_) => { hash_map::Entry::Vacant(_) => {
tracing::debug!(
target: LOG_TARGET,
?source,
?peer_id,
?fingerprint,
"Approval from unknown peer",
);
modify_reputation(ctx, peer_id.clone(), COST_UNEXPECTED_MESSAGE).await; modify_reputation(ctx, peer_id.clone(), COST_UNEXPECTED_MESSAGE).await;
} }
} }
// if the approval is known to be valid, reward the peer // if the approval is known to be valid, reward the peer
if entry.knowledge.known_messages.contains(&fingerprint) { if entry.knowledge.known_messages.contains(&fingerprint) {
tracing::trace!(
target: LOG_TARGET,
?source,
?peer_id,
?fingerprint,
"Known approval",
);
modify_reputation(ctx, peer_id.clone(), BENEFIT_VALID_MESSAGE).await; modify_reputation(ctx, peer_id.clone(), BENEFIT_VALID_MESSAGE).await;
if let Some(peer_knowledge) = entry.known_by.get_mut(&peer_id) { if let Some(peer_knowledge) = entry.known_by.get_mut(&peer_id) {
peer_knowledge.known_messages.insert(fingerprint.clone()); peer_knowledge.known_messages.insert(fingerprint.clone());
@@ -643,6 +703,14 @@ impl State {
} }
}; };
tracing::trace!(
target: LOG_TARGET,
?source,
?peer_id,
?fingerprint,
?result,
"Checked approval",
);
match result { match result {
ApprovalCheckResult::Accepted => { ApprovalCheckResult::Accepted => {
modify_reputation(ctx, peer_id.clone(), BENEFIT_VALID_MESSAGE_FIRST).await; modify_reputation(ctx, peer_id.clone(), BENEFIT_VALID_MESSAGE_FIRST).await;