+2

lib/trinity/scheduler.ex

reviewed

··· 222 222 end 223 223 224 224 def handle_down(%Simulation{} = sim, pid, :normal) do 225 225 + # TODO: use get_sim() 225 226 %{queue: queue, proc_queue_keys: proc_queue_keys} = sim 226 227 destroy_process(sim, pid) 227 228 perform_next(queue, proc_queue_keys, sim.now) ··· 229 230 end 230 231 231 232 def handle_down(%Simulation{} = sim, pid, reason) do 233 233 + # TODO: use get_sim() 232 234 %{queue: queue, proc_queue_keys: proc_queue_keys, proc_links: proc_links} = sim 233 235 linked = gather_linked(pid, proc_links) 234 236

+1

lib/trinity/scheduler/simulation_supervisor.ex

reviewed

··· 60 60 now: :atomics.new(1, signed: false), 61 61 supervisor_pid: self(), 62 62 } 63 63 + Process.put(simulation_key(), sim) 63 64 64 65 :ets.insert(sim.file_paths, {:next_fd, 0}) 65 66