1 # Pleroma: A lightweight social networking server
2 # Copyright © 2017-2018 Pleroma Authors <https://pleroma.social/>
3 # SPDX-License-Identifier: AGPL-3.0-only
5 defmodule Pleroma.Web.Federator.RetryQueue do
10 # initial timeout, 5 min
11 @initial_timeout 30_000
19 enabled = Pleroma.Config.get([:retry_queue, :enabled], false)
22 Logger.info("Starting retry queue")
23 GenServer.start_link(__MODULE__, %{delivered: 0, dropped: 0}, name: __MODULE__)
25 Logger.info("Retry queue disabled")
30 def enqueue(data, transport, retries \\ 0) do
31 GenServer.cast(__MODULE__, {:maybe_enqueue, data, transport, retries + 1})
34 def get_retry_params(retries) do
35 if retries > @max_retries do
36 {:drop, "Max retries reached"}
38 {:retry, growth_function(retries)}
42 def handle_cast({:maybe_enqueue, data, transport, retries}, %{dropped: drop_count} = state) do
43 case get_retry_params(retries) do
47 {:send, data, transport, retries},
55 {:noreply, %{state | dropped: drop_count + 1}}
59 def handle_info({:send, data, transport, retries}, %{delivered: delivery_count} = state) do
60 case transport.publish_one(data) do
62 {:noreply, %{state | delivered: delivery_count + 1}}
65 enqueue(data, transport, retries)
70 def handle_info(unknown, state) do
71 Logger.debug("RetryQueue: don't know what to do with #{inspect(unknown)}, ignoring")
75 defp growth_function(retries) do
76 round(@initial_timeout * :math.pow(retries, 3))