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

Commit c02c24d

Browse files
authored
collator-protocol: fix wrong warning (#4909)
* collator-protocol: fix wrong warning * collator-protocol: add debug log
1 parent 45f21da commit c02c24d

File tree

1 file changed

+10
-2
lines changed
  • node/network/collator-protocol/src/collator_side

1 file changed

+10
-2
lines changed

node/network/collator-protocol/src/collator_side/mod.rs

Lines changed: 10 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -958,6 +958,7 @@ where
958958
// but can also include the previous group at
959959
// rotation boundaries and considering forks
960960
let mut group_validators = HashSet::new();
961+
let mut maybe_core = None;
961962

962963
for relay_parent in state.view.iter().cloned() {
963964
tracing::debug!(
@@ -970,7 +971,10 @@ where
970971
// Determine our assigned core.
971972
// If it is not scheduled then ignore the relay parent.
972973
let (our_core, num_cores) = match determine_core(ctx, id, relay_parent).await? {
973-
Some(core) => core,
974+
Some(core) => {
975+
maybe_core = Some(core);
976+
core
977+
},
974978
None => continue,
975979
};
976980

@@ -987,7 +991,11 @@ where
987991
let validators: Vec<_> = group_validators.into_iter().collect();
988992
let no_one_is_assigned = validators.is_empty();
989993
if no_one_is_assigned {
990-
tracing::warn!(target: LOG_TARGET, "No validators assigned to our core.",);
994+
if let Some(core) = maybe_core {
995+
tracing::warn!(target: LOG_TARGET, ?core, "No validators assigned to our core.");
996+
} else {
997+
tracing::debug!(target: LOG_TARGET, "Core is occupied for all active leaves.");
998+
}
991999
return Ok(())
9921000
}
9931001
tracing::debug!(

0 commit comments

Comments
 (0)