darkkirb/akkoma
1
0
Fork 0
forked from mirrors/akkoma
Code Pull requests Activity

temp fix for :gun.info MatchError

Browse source
This commit is contained in:
Alexander Strizhakov 2020-03-16 15:47:25 +03:00
parent 3805e09b9c
commit 35471205f8
No known key found for this signature in database
GPG key ID: 022896A53AEF1381
1 changed files with 16 additions and 9 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

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

@ -169,6 +169,10 @@ defmodule Pleroma.Pool.Connections do
@impl true @impl true
def handle_info({:gun_up, conn_pid, _protocol}, state) do def handle_info({:gun_up, conn_pid, _protocol}, state) do
# TODO: temp fix for gun MatchError https://github.com/ninenines/gun/issues/222
# TODO: REMOVE LATER
{key, conn} =
try do
%{origin_host: host, origin_scheme: scheme, origin_port: port} = Gun.info(conn_pid) %{origin_host: host, origin_scheme: scheme, origin_port: port} = Gun.info(conn_pid)
host = host =
@ -178,10 +182,13 @@ defmodule Pleroma.Pool.Connections do
end end
key = "#{scheme}:#{host}:#{port}" key = "#{scheme}:#{host}:#{port}"
find_conn(state.conns, conn_pid, key)
rescue
MatcheError -> find_conn(state.conns, conn_pid)
end
state = state =
with {_key, conn} <- find_conn(state.conns, conn_pid, key), with {true, key} <- {Process.alive?(conn_pid), key} do
{true, key} <- {Process.alive?(conn_pid), key} do
put_in(state.conns[key], %{ put_in(state.conns[key], %{
conn conn
| gun_state: :up, | gun_state: :up,