+3

lib/construct/scheduler.ex

reviewed

··· 150 150 :ok 151 151 end 152 152 153 153 + @spec restart_node(pid, atom, non_neg_integer) :: :ok | {:error, :node_not_found | :node_stopped} 153 154 def restart_node(scheduler, name, delay) when is_atom(name) do 154 155 GenServer.call(scheduler, {:restart_node, name, delay}) 155 156 end 156 157 158 158 + @spec list_nodes(pid) :: [atom] 157 159 def list_nodes(scheduler) do 158 160 GenServer.call(scheduler, :list_nodes) 159 161 end ··· 724 726 ProcStore.list_processes(state.proc_store) 725 727 |> Enum.filter(&(&1.node == node.name)) 726 728 |> Enum.each(fn %ProcState{pid: pid} -> 729 729 + # TODO: the order here is not deterministic, but it probably doesn't matter? 727 730 :ok = kill_process(pid, :shutdown) 728 731 :ok = remove_process(state, pid) 729 732 end)

+2

lib/construct/sim_server.ex

reviewed

··· 337 337 end 338 338 end 339 339 340 340 + @spec list_nodes :: [atom] 340 341 def list_nodes do 341 342 if not simulated?(), do: raise "list_nodes/0 can only be called in simulation" 342 343 scheduler_pid = fetch_scheduler_pid!() ··· 352 353 Scheduler.start_node(scheduler_pid, name, app_module, args) 353 354 end 354 355 356 356 + @spec restart_node(atom, non_neg_integer) :: :ok | {:error, :node_not_found | :node_stopped} 355 357 def restart_node(name, delay_ms \\ 0) when is_atom(name) and is_integer(delay_ms) do 356 358 if not simulated?(), do: raise "restart_node/1 can only be called in simulation" 357 359 scheduler_pid = fetch_scheduler_pid!()