diff options
author | Alexander Strizhakov <alex.strizhakov@gmail.com> | 2020-04-21 16:00:06 +0300 |
---|---|---|
committer | Alexander Strizhakov <alex.strizhakov@gmail.com> | 2020-05-06 13:25:48 +0300 |
commit | 7fb95ddb314e0a0490b615b6845b72be9efd78dd (patch) | |
tree | 763ee2d36f924373ec0cd7ad51aacedcb59b4e16 | |
parent | ec282d1d6295259d56af5e9d58cc62dac94b1f77 (diff) | |
download | pleroma-7fb95ddb314e0a0490b615b6845b72be9efd78dd.tar.gz |
fix for conn_state
-rw-r--r-- | lib/pleroma/pool/connections.ex | 6 |
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 |