diff options
author | Alexander Strizhakov <alex.strizhakov@gmail.com> | 2020-04-30 15:07:21 +0300 |
---|---|---|
committer | Alexander Strizhakov <alex.strizhakov@gmail.com> | 2020-05-06 13:25:50 +0300 |
commit | a16fb7c35c3b556c28b8e7ad708f6129b2aad161 (patch) | |
tree | d6f4bfdfc4bcbb311f8de8c6978a1f0cf0943019 /lib/pleroma/gun/conn.ex | |
parent | 8e4bd2c1cf0e0570d1e3a1180d8b8a25f1425cc2 (diff) | |
download | pleroma-gun-memory-leak.tar.gz |
clean up and test coveragegun-memory-leak
Diffstat (limited to 'lib/pleroma/gun/conn.ex')
-rw-r--r-- | lib/pleroma/gun/conn.ex | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/lib/pleroma/gun/conn.ex b/lib/pleroma/gun/conn.ex index de3173351..fb7153a16 100644 --- a/lib/pleroma/gun/conn.ex +++ b/lib/pleroma/gun/conn.ex @@ -34,11 +34,8 @@ defmodule Pleroma.Gun.Conn do crf: 1, retries: 0 - @spec open(String.t() | URI.t(), atom(), keyword()) :: :ok | nil - def open(url, name, opts \\ []) - def open(url, name, opts) when is_binary(url), do: open(URI.parse(url), name, opts) - - def open(%URI{} = uri, name, opts) do + @spec open(URI.t(), atom(), keyword()) :: :ok + def open(%URI{} = uri, name, opts \\ []) do pool_opts = Pleroma.Config.get([:connections_pool], []) opts = @@ -62,7 +59,7 @@ defmodule Pleroma.Gun.Conn do end defp try_open(name, uri, opts, max_connections) do - if Connections.count(name) < max_connections do + if Connections.count(name) <= max_connections do do_open(uri, opts) else close_least_used_and_do_open(name, uri, opts) |