diff options
Diffstat (limited to 'lib/pleroma/pool/connections.ex')
-rw-r--r-- | lib/pleroma/pool/connections.ex | 22 |
1 files changed, 9 insertions, 13 deletions
diff --git a/lib/pleroma/pool/connections.ex b/lib/pleroma/pool/connections.ex index 86bb00bc5..87fa50a22 100644 --- a/lib/pleroma/pool/connections.ex +++ b/lib/pleroma/pool/connections.ex @@ -16,21 +16,20 @@ defmodule Pleroma.Pool.Connections do @type seconds :: pos_integer() @type t :: %__MODULE__{ - conns: %{domain() => conn()}, - opts: keyword() + conns: %{domain() => conn()} } - defstruct conns: %{}, opts: [] + defstruct conns: %{} - @spec start_link({atom(), keyword()}) :: {:ok, pid()} - def start_link({name, opts}) do - GenServer.start_link(__MODULE__, opts, name: name) + @spec start_link(atom()) :: {:ok, pid()} + def start_link(name) do + GenServer.start_link(__MODULE__, [], name: name) end @impl true - def init(opts) do + def init(_) do schedule_close_idle_conns() - {:ok, %__MODULE__{conns: %{}, opts: opts}} + {:ok, %__MODULE__{conns: %{}}} end @spec checkin(String.t() | URI.t(), atom()) :: pid() | nil @@ -43,11 +42,8 @@ defmodule Pleroma.Pool.Connections do @spec alive?(atom()) :: boolean() def alive?(name) do - if pid = Process.whereis(name) do - Process.alive?(pid) - else - false - end + pid = Process.whereis(name) + is_pid(pid) and Process.alive?(pid) end @spec get_state(atom()) :: t() |