1 defmodule Pleroma.Web.Federator.RetryQueue do
6 # initial timeout, 5 min
7 @initial_timeout 30_000
15 enabled = Pleroma.Config.get([:retry_queue, :enabled], false)
18 Logger.info("Starting retry queue")
19 GenServer.start_link(__MODULE__, %{delivered: 0, dropped: 0}, name: __MODULE__)
21 Logger.info("Retry queue disabled")
26 def enqueue(data, transport, retries \\ 0) do
27 GenServer.cast(__MODULE__, {:maybe_enqueue, data, transport, retries + 1})
30 def get_retry_params(retries) do
31 if retries > @max_retries do
32 {:drop, "Max retries reached"}
34 {:retry, growth_function(retries)}
38 def handle_cast({:maybe_enqueue, data, transport, retries}, %{dropped: drop_count} = state) do
39 case get_retry_params(retries) do
43 {:send, data, transport, retries},
51 {:noreply, %{state | dropped: drop_count + 1}}
55 def handle_info({:send, data, transport, retries}, %{delivered: delivery_count} = state) do
56 case transport.publish_one(data) do
58 {:noreply, %{state | delivered: delivery_count + 1}}
61 enqueue(data, transport, retries)
66 def handle_info(unknown, state) do
67 Logger.debug("RetryQueue: don't know what to do with #{inspect(unknown)}, ignoring")
71 defp growth_function(retries) do
72 round(@initial_timeout * :math.pow(retries, 3))