projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge remote-tracking branch 'pleroma/develop' into instance-deletion
[akkoma]
/
lib
/
pleroma
/
gun
/
connection_pool
/
reclaimer.ex
diff --git
a/lib/pleroma/gun/connection_pool/reclaimer.ex
b/lib/pleroma/gun/connection_pool/reclaimer.ex
index c37b62bf2f21b7b812037045c90644a76124b030..4c643d7cbb607805c8f070e89e910bc3100b4ed5 100644
(file)
--- a/
lib/pleroma/gun/connection_pool/reclaimer.ex
+++ b/
lib/pleroma/gun/connection_pool/reclaimer.ex
@@
-5,11
+5,11
@@
defmodule Pleroma.Gun.ConnectionPool.Reclaimer do
use GenServer, restart: :temporary
defmodule Pleroma.Gun.ConnectionPool.Reclaimer do
use GenServer, restart: :temporary
-
@registry
Pleroma.Gun.ConnectionPool
+
defp registry, do:
Pleroma.Gun.ConnectionPool
def start_monitor do
pid =
def start_monitor do
pid =
- case :gen_server.start(__MODULE__, [], name: {:via, Registry, {
@registry
, "reclaimer"}}) do
+ case :gen_server.start(__MODULE__, [], name: {:via, Registry, {
registry()
, "reclaimer"}}) do
{:ok, pid} ->
pid
{:ok, pid} ->
pid
@@
-46,7
+46,7
@@
defmodule Pleroma.Gun.ConnectionPool.Reclaimer do
# {worker_pid, crf, last_reference} end)
unused_conns =
Registry.select(
# {worker_pid, crf, last_reference} end)
unused_conns =
Registry.select(
-
@registry
,
+
registry()
,
[
{{:_, :"$1", {:_, :"$2", :"$3", :"$4"}}, [{:==, :"$2", []}], [{{:"$1", :"$3", :"$4"}}]}
]
[
{{:_, :"$1", {:_, :"$2", :"$3", :"$4"}}, [{:==, :"$2", []}], [{{:"$1", :"$3", :"$4"}}]}
]