naming for checkin from pool timeout
authorAlexander Strizhakov <alex.strizhakov@gmail.com>
Tue, 3 Mar 2020 10:05:28 +0000 (13:05 +0300)
committerAlexander Strizhakov <alex.strizhakov@gmail.com>
Tue, 3 Mar 2020 10:05:28 +0000 (13:05 +0300)
config/config.exs
docs/configuration/cheatsheet.md
lib/pleroma/pool/connections.ex
test/pool/connections_test.exs

index 7c94a0f26bfaad6115fe58d92778604462982997..661dfad20195105e15d570e6364308b8bc1298be 100644 (file)
@@ -607,7 +607,7 @@ config :pleroma, Pleroma.Repo,
   prepare: :unnamed
 
 config :pleroma, :connections_pool,
-  receive_connection_timeout: 250,
+  checkin_timeout: 250,
   max_connections: 250,
   retry: 0,
   retry_timeout: 100,
index 65f37e8460087c021800e072217163e1bf90ed83..ef3cc40e67e23d0c4bd6888ec3c0d53bf0dbc854 100644 (file)
@@ -404,7 +404,7 @@ Advanced settings for connections pool. Pool with opened connections. These conn
 For big instances it's recommended to increase `config :pleroma, :connections_pool, max_connections: 500` up to 500-1000.
 It will increase memory usage, but federation would work faster.
 
-* `:receive_connection_timeout` - timeout to receive connection from pool. Default: 250ms.
+* `:checkin_timeout` - timeout to checkin connection from pool. Default: 250ms.
 * `:max_connections` - maximum number of connections in the pool. Default: 250 connections.
 * `:retry` - number of retries, while `gun` will try to reconnect if connections goes down. Default: 5.
 * `:retry_timeout` - timeout while `gun` will try to reconnect. Default: 100ms.
index 84617815fa2c3580c3d099d6dccd46cc8d79ad84..05fa8f7adeaf9f3ab3b4c001e81a35b96b59400a 100644 (file)
@@ -34,7 +34,7 @@ defmodule Pleroma.Pool.Connections do
   def checkin(url, name) when is_binary(url), do: checkin(URI.parse(url), name)
 
   def checkin(%URI{} = uri, name) do
-    timeout = Config.get([:connections_pool, :receive_connection_timeout], 250)
+    timeout = Config.get([:connections_pool, :checkin_timeout], 250)
 
     GenServer.call(
       name,
@@ -184,6 +184,7 @@ defmodule Pleroma.Pool.Connections do
         time = :os.system_time(:second)
         last_reference = time - conn.last_reference
         current_crf = crf(last_reference, 100, conn.crf)
+
         put_in(state.conns[key], %{
           conn
           | gun_state: :up,
index 0e7a118abc0157dc610914429f6af87ffbbe8bca..a084f31b9f0a9ec59bdd2d2e70f69878ec58337d 100644 (file)
@@ -24,8 +24,7 @@ defmodule Pleroma.Pool.ConnectionsTest do
     adapter = Application.get_env(:tesla, :adapter)
     Application.put_env(:tesla, :adapter, Tesla.Adapter.Gun)
 
-    {:ok, pid} =
-      Connections.start_link({name, [max_connections: 2, receive_connection_timeout: 1_500]})
+    {:ok, pid} = Connections.start_link({name, [max_connections: 2, checkin_timeout: 1_500]})
 
     on_exit(fn ->
       Application.put_env(:tesla, :adapter, adapter)