Skip to content

Commit

Permalink
Addressed comments
Browse files Browse the repository at this point in the history
  • Loading branch information
pietrodimarco-dfinity committed Mar 4, 2025
1 parent 46147f4 commit 5805ef8
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 16 deletions.
25 changes: 10 additions & 15 deletions rs/execution_environment/src/scheduler.rs
Original file line number Diff line number Diff line change
Expand Up @@ -29,7 +29,7 @@ use ic_replicated_state::{
num_bytes_try_from,
page_map::PageAllocatorFileDescriptor,
CanisterState, CanisterStatus, ExecutionTask, InputQueueType, NetworkTopology, NumWasmPages,
ReplicatedState,
ReplicatedState, StateError,
};
use ic_system_api::InstructionLimits;
use ic_types::{
Expand Down Expand Up @@ -1038,18 +1038,14 @@ impl SchedulerImpl {
)
.map(|_| ())
.map_err(|(err, msg)| {
// Spamming a lot of logs even multiple per sec of this kind:
// Inducting Request(Request { receiver: CanisterId(7xpjo-2iaaa-aaaao-a2vxq-cai),
// sender: CanisterId(dtvyz-2iaaa-aaaao-a2xxq-cai), sender_reply_callback: 20791,
// payment: Cycles(0), method_name: "index", method_payload: "10 bytes;4449444c016d7b010000",
// metadata: RequestMetadata { call_tree_depth: 1, call_tree_start_time: Time(1737940399724249864) },
// deadline: CoarseTime(0) }) on same subnet failed with error 'Canister 7xpjo-2iaaa-aaaao-a2vxq-cai is stopped'.
error!(
self.log,
"Inducting {:?} on same subnet failed with error '{}'.",
&msg,
&err
);
if !matches!(err, StateError::CanisterStopped(_)) {
error!(
self.log,
"Inducting {:?} on same subnet failed with error '{}'.",
&msg,
&err
);
}
}),
None => Err(()),
}
Expand Down Expand Up @@ -2032,8 +2028,7 @@ fn observe_replicated_state_metrics(
// Log all old call contexts, but not (nearly) every round.
if current_round.get() % SPAMMY_LOG_INTERVAL_ROUNDS == 0 {
for (origin, origin_time) in &old_call_contexts {
// TODO: Demote it to INFO
warn!(
info!(
logger,
"Call context on canister {} with origin {:?} has been open for {:?}",
canister.canister_id(),
Expand Down
1 change: 0 additions & 1 deletion rs/orchestrator/src/orchestrator.rs
Original file line number Diff line number Diff line change
Expand Up @@ -131,7 +131,6 @@ impl Orchestrator {
thread::sleep(Duration::from_secs(10 * 60));
let (ipv4, ipv6) = Self::get_ip_addresses();

// TODO: group all newlines together currently split by newline
let message = indoc::formatdoc!(
r#"
Node-id: {node_id}
Expand Down

0 comments on commit 5805ef8

Please sign in to comment.