no try block in checkout connection
authorAlexander Strizhakov <alex.strizhakov@gmail.com>
Tue, 3 Mar 2020 14:44:04 +0000 (17:44 +0300)
committerAlexander Strizhakov <alex.strizhakov@gmail.com>
Tue, 3 Mar 2020 14:44:04 +0000 (17:44 +0300)
lib/pleroma/http/adapter/gun.ex

index 5e88786bd1df23ff4d18659075715fe866765c0f..30c5c3c16f8e38f737d73d6044fe4d895b44d017 100644 (file)
@@ -86,56 +86,21 @@ defmodule Pleroma.HTTP.Adapter.Gun do
   end
 
   defp try_to_get_conn(uri, opts) do
-    try do
-      case Connections.checkin(uri, :gun_connections) do
-        nil ->
-          Logger.debug(
-            "Gun connections pool checkin was not successful. Trying to open conn for next request."
-          )
-
-          Task.start(fn -> Pleroma.Gun.Conn.open(uri, :gun_connections, opts) end)
-          opts
-
-        conn when is_pid(conn) ->
-          Logger.debug("received conn #{inspect(conn)} #{Connections.compose_uri_log(uri)}")
-
-          opts
-          |> Keyword.put(:conn, conn)
-          |> Keyword.put(:close_conn, false)
-      end
-    rescue
-      error ->
-        Logger.warn(
-          "Gun connections pool checkin caused error #{Connections.compose_uri_log(uri)} #{
-            inspect(error)
-          }"
+    case Connections.checkin(uri, :gun_connections) do
+      nil ->
+        Logger.debug(
+          "Gun connections pool checkin was not successful. Trying to open conn for next request."
         )
 
+        Task.start(fn -> Pleroma.Gun.Conn.open(uri, :gun_connections, opts) end)
         opts
-    catch
-      # TODO: here must be no timeouts
-      :exit, {:timeout, {_, operation, [_, {method, _}, _]}} ->
-        {:message_queue_len, messages_len} =
-          :gun_connections
-          |> Process.whereis()
-          |> Process.info(:message_queue_len)
-
-        Logger.warn(
-          "Gun connections pool checkin with timeout error for #{operation} #{method} #{
-            Connections.compose_uri_log(uri)
-          }. Messages length: #{messages_len}"
-        )
 
-        opts
-
-      :exit, error ->
-        Logger.warn(
-          "Gun pool checkin exited with error #{Connections.compose_uri_log(uri)} #{
-            inspect(error)
-          }"
-        )
+      conn when is_pid(conn) ->
+        Logger.debug("received conn #{inspect(conn)} #{Connections.compose_uri_log(uri)}")
 
         opts
+        |> Keyword.put(:conn, conn)
+        |> Keyword.put(:close_conn, false)
     end
   end