From a03c420b84d9901be70520d8c027ccb53449990d Mon Sep 17 00:00:00 2001
From: Alexander Strizhakov <alex.strizhakov@gmail.com>
Date: Fri, 21 Feb 2020 12:32:42 +0300
Subject: [PATCH] by default don't use gun retries

remove conn depends on retry setting from config
---
 config/config.exs               |  2 +-
 lib/pleroma/pool/connections.ex | 11 +++++++----
 2 files changed, 8 insertions(+), 5 deletions(-)

diff --git a/config/config.exs b/config/config.exs
index 853a53fc9..7f3a4d1b6 100644
--- a/config/config.exs
+++ b/config/config.exs
@@ -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
 
diff --git a/lib/pleroma/pool/connections.ex b/lib/pleroma/pool/connections.ex
index c7136e0e0..d20927580 100644
--- a/lib/pleroma/pool/connections.ex
+++ b/lib/pleroma/pool/connections.ex
@@ -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(