sam/pleroma
sam/pleroma
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

by default don't use gun retries

Browse source 
remove conn depends on retry setting from config
This commit is contained in:
Alexander Strizhakov 2020-02-21 12:32:42 +03:00
parent 3849bbb60d
commit a03c420b84
No known key found for this signature in database
GPG key ID: 022896A53AEF1381
2 changed files with 8 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
config/config.exs
View file

@ -599,7 +599,7 @@
config :pleroma, :connections_pool,
receive_connection_timeout: 250,
max_connections: 250,
retry: 5,
retry: 0,
retry_timeout: 100,
await_up_timeout: 5_000

11
lib/pleroma/pool/connections.ex
View file

@ -5,6 +5,8 @@
defmodule Pleroma.Pool.Connections do
use GenServer
alias Pleroma.Config
require Logger
@type domain :: String.t()
@ -33,7 +35,7 @@ def checkin(url, name)
def checkin(url, name) when is_binary(url), do: checkin(URI.parse(url), name)
def checkin(%URI{} = uri, name) do
timeout = Pleroma.Config.get([:connections_pool, :receive_connection_timeout], 250)
timeout = Config.get([:connections_pool, :receive_connection_timeout], 250)
GenServer.call(
name,
@ -47,7 +49,7 @@ def open_conn(url, name, opts \\ [])
def open_conn(url, name, opts) when is_binary(url), do: open_conn(URI.parse(url), name, opts)
def open_conn(%URI{} = uri, name, opts) do
pool_opts = Pleroma.Config.get([:connections_pool], [])
pool_opts = Config.get([:connections_pool], [])
opts =
opts
@ -193,12 +195,13 @@ def handle_info({:gun_up, conn_pid, _protocol}, state) do
@impl true
def handle_info({:gun_down, conn_pid, _protocol, _reason, _killed}, state) do
retries = Config.get([:connections_pool, :retry], 0)
# we can't get info on this pid, because pid is dead
state =
with true <- Process.alive?(conn_pid),
{key, conn} <- find_conn(state.conns, conn_pid) do
if conn.retries == 5 do
Logger.debug("closing conn if retries is eq 5 #{inspect(conn_pid)}")
if conn.retries == retries do
Logger.debug("closing conn if retries is eq #{inspect(conn_pid)}")
:ok = API.close(conn.conn)
put_in(