summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorAlexander Strizhakov <alex.strizhakov@gmail.com>2020-04-21 16:00:06 +0300
committerAlexander Strizhakov <alex.strizhakov@gmail.com>2020-05-06 13:25:48 +0300
commit7fb95ddb314e0a0490b615b6845b72be9efd78dd (patch)
tree763ee2d36f924373ec0cd7ad51aacedcb59b4e16
parentec282d1d6295259d56af5e9d58cc62dac94b1f77 (diff)
fix for conn_state
-rw-r--r--lib/pleroma/pool/connections.ex6
1 files changed, 4 insertions, 2 deletions
diff --git a/lib/pleroma/pool/connections.ex b/lib/pleroma/pool/connections.ex
index b4699edf7..b9618d3c7 100644
--- a/lib/pleroma/pool/connections.ex
+++ b/lib/pleroma/pool/connections.ex
@@ -95,7 +95,7 @@ defmodule Pleroma.Pool.Connections do
with true <- Process.alive?(conn_pid),
{key, conn} <- find_conn(state.conns, conn_pid),
used_by <- List.keydelete(conn.used_by, pid, 0) do
- conn_state = if used_by == [], do: :idle, else: conn.conn_state
+ conn_state = if used_by == [], do: :idle, else: :active
put_in(state.conns[key], %{conn | conn_state: conn_state, used_by: used_by})
else
@@ -186,10 +186,12 @@ defmodule Pleroma.Pool.Connections do
state =
with {key, conn} <- find_conn(state.conns, conn_pid, key),
{true, key} <- {Process.alive?(conn_pid), key} do
+ conn_state = if conn.used_by == [], do: :idle, else: :active
+
put_in(state.conns[key], %{
conn
| gun_state: :up,
- conn_state: :active,
+ conn_state: conn_state,
retries: 0
})
else