Current section
Files
Jump to
Current section
Files
lib/pi/session/supervisor.ex
defmodule Pi.Session.Supervisor do
@moduledoc "Dynamic supervisor for server-owned Pi sessions."
use DynamicSupervisor
def start_link(opts \\ []) do
DynamicSupervisor.start_link(__MODULE__, opts, name: __MODULE__)
end
def install do
case Process.whereis(__MODULE__) do
nil ->
case start_link([]) do
{:ok, pid} ->
Process.unlink(pid)
{:ok, pid}
other ->
other
end
_pid ->
:ok
end
end
def start_session(opts) when is_list(opts) do
install()
DynamicSupervisor.start_child(__MODULE__, {Pi.Session.Worker, opts})
end
def workers do
install()
__MODULE__
|> DynamicSupervisor.which_children()
|> Enum.flat_map(fn
{:undefined, pid, :worker, [Pi.Session.Worker]} when is_pid(pid) -> [pid]
_child -> []
end)
end
@impl true
def init(_opts), do: DynamicSupervisor.init(strategy: :one_for_one)
end