X-Git-Url: https://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fpool%2Frequest.ex;h=3fb930db72fbb51d4d7fcac9011b64b4efa03c29;hb=2069ec5006b9142b784dc6ab8b190838481dfe5b;hp=2c35745614baea1d226314620836f217b7b74a49;hpb=4427161ca3798aeee0290f0ed7ac5536039509d8;p=akkoma
diff --git a/lib/pleroma/pool/request.ex b/lib/pleroma/pool/request.ex
index 2c3574561..3fb930db7 100644
--- a/lib/pleroma/pool/request.ex
+++ b/lib/pleroma/pool/request.ex
@@ -1,5 +1,5 @@
# Pleroma: A lightweight social networking server
-# Copyright © 2017-2019 Pleroma Authors
+# Copyright © 2017-2020 Pleroma Authors
# SPDX-License-Identifier: AGPL-3.0-only
defmodule Pleroma.Pool.Request do
@@ -22,18 +22,13 @@ defmodule Pleroma.Pool.Request do
@impl true
def handle_call({:execute, client, request}, _from, state) do
- response = Pleroma.HTTP.request_try(client, request)
+ response = Pleroma.HTTP.request(client, request)
{:reply, response, state}
end
@impl true
- def handle_info({:gun_data, _conn, stream, _, _}, state) do
- # in some cases if we reuse conn and got {:error, :body_too_large}
- # gun continues to send messages to this process,
- # so we flush messages for this request
- :ok = :gun.flush(stream)
-
+ def handle_info({:gun_data, _conn, _stream, _, _}, state) do
{:noreply, state}
end
@@ -44,13 +39,11 @@ defmodule Pleroma.Pool.Request do
@impl true
def handle_info({:gun_down, _conn, _protocol, _reason, _killed}, state) do
- # don't flush messages here, because gun can reconnect
{:noreply, state}
end
@impl true
- def handle_info({:gun_error, _conn, stream, _error}, state) do
- :ok = :gun.flush(stream)
+ def handle_info({:gun_error, _conn, _stream, _error}, state) do
{:noreply, state}
end