projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Merge branch 'develop' of https://git.pleroma.social/pleroma/pleroma into develop
[akkoma]
/
lib
/
pleroma
/
web
/
federator
/
retry_queue.ex
diff --git
a/lib/pleroma/web/federator/retry_queue.ex
b/lib/pleroma/web/federator/retry_queue.ex
index e0ce251d201f813b2d22529b4f8962698734777c..71e49494fd5a381616b6ed7a7eb324cba0112558 100644
(file)
--- a/
lib/pleroma/web/federator/retry_queue.ex
+++ b/
lib/pleroma/web/federator/retry_queue.ex
@@
-13,7
+13,7
@@
defmodule Pleroma.Web.Federator.RetryQueue do
{:ok, %{args | queue_table: queue_table, running_jobs: :sets.new()}}
end
{:ok, %{args | queue_table: queue_table, running_jobs: :sets.new()}}
end
- def start_link
()
do
+ def start_link do
enabled =
if Mix.env() == :test, do: true, else: Pleroma.Config.get([__MODULE__, :enabled], false)
enabled =
if Mix.env() == :test, do: true, else: Pleroma.Config.get([__MODULE__, :enabled], false)
@@
-39,11
+39,11
@@
defmodule Pleroma.Web.Federator.RetryQueue do
GenServer.cast(__MODULE__, {:maybe_enqueue, data, transport, retries + 1})
end
GenServer.cast(__MODULE__, {:maybe_enqueue, data, transport, retries + 1})
end
- def get_stats
()
do
+ def get_stats do
GenServer.call(__MODULE__, :get_stats)
end
GenServer.call(__MODULE__, :get_stats)
end
- def reset_stats
()
do
+ def reset_stats do
GenServer.call(__MODULE__, :reset_stats)
end
GenServer.call(__MODULE__, :reset_stats)
end
@@
-55,7
+55,7
@@
defmodule Pleroma.Web.Federator.RetryQueue do
end
end
end
end
- def get_retry_timer_interval
()
do
+ def get_retry_timer_interval do
Pleroma.Config.get([:retry_queue, :interval], 1000)
end
Pleroma.Config.get([:retry_queue, :interval], 1000)
end
@@
-231,7
+231,7
@@
defmodule Pleroma.Web.Federator.RetryQueue do
end
end
end
end
- defp maybe_kickoff_timer
()
do
+ defp maybe_kickoff_timer do
GenServer.cast(__MODULE__, :kickoff_timer)
end
end
GenServer.cast(__MODULE__, :kickoff_timer)
end
end