Skip to content

Commit 8d43595

Browse files
committed
add debug output
1 parent b6f8ae4 commit 8d43595

File tree

1 file changed

+3
-2
lines changed

1 file changed

+3
-2
lines changed

edgeless_orc/src/orchestrator_task.rs

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1050,6 +1050,7 @@ impl OrchestratorTask {
10501050
}
10511051

10521052
async fn refresh(&mut self) {
1053+
log::info!("refresh called");
10531054
//
10541055
// Make sure that all active logical functions are assigned
10551056
// to at least one instance: for all the function instances that
@@ -1075,7 +1076,7 @@ impl OrchestratorTask {
10751076
original_start_req: edgeless_api::function_instance::SpawnFunctionRequest,
10761077
// TODO:2 next patch, takes into account where the other replicas reside to make sure replicas only start
10771078
// on different nodes
1078-
nodes_blacklist: Option<std::collections::HashSet<edgeless_api::function_instance::NodeId>>,
1079+
_nodes_blacklist: Option<std::collections::HashSet<edgeless_api::function_instance::NodeId>>,
10791080
}
10801081

10811082
// Functions that have to have some instances created to make up for
@@ -1152,7 +1153,7 @@ impl OrchestratorTask {
11521153
// FEAT: fill out the blacklist
11531154
let physical_instance = PhysicalFunctionInstance {
11541155
original_start_req: start_req.clone(),
1155-
nodes_blacklist: None,
1156+
_nodes_blacklist: None,
11561157
};
11571158
// TODO:2 handle the error properly here
11581159
fun_to_be_created.entry(*origin_lid).or_insert_with(Vec::new).push(physical_instance);

0 commit comments

Comments
 (0)