X-Git-Url: http://git.squeep.com/?a=blobdiff_plain;f=lib%2Fpleroma%2Fweb%2Ffederator%2Ffederator.ex;h=eccade88349e5fd1616a12cab2426e6c20d8cdd2;hb=59770c3f5c9a038dbde6b2e1cd1551a7b8f1672b;hp=4d6ebff8e42434f7c48b7542fe803fd48bcab6c5;hpb=8004ee8ccfa63181fb103ea50db3b10956d81ce9;p=akkoma diff --git a/lib/pleroma/web/federator/federator.ex b/lib/pleroma/web/federator/federator.ex index 4d6ebff8e..eccade883 100644 --- a/lib/pleroma/web/federator/federator.ex +++ b/lib/pleroma/web/federator/federator.ex @@ -71,7 +71,7 @@ defmodule Pleroma.Web.Federator do end end - def handle(type, payload) do + def handle(type, _) do Logger.debug(fn -> "Unknown task: #{type}" end) {:error, "Don't know what do do with this"} end @@ -101,14 +101,14 @@ defmodule Pleroma.Web.Federator do {:noreply, {running_jobs, queue}} end + def handle_cast(m, state) do + IO.inspect("Unknown: #{inspect(m)}, #{inspect(state)}") + {:noreply, state} + end + def handle_info({:DOWN, ref, :process, _pid, _reason}, {running_jobs, queue}) do running_jobs = :sets.del_element(ref, running_jobs) {running_jobs, queue} = maybe_start_job(running_jobs, queue) {:noreply, {running_jobs, queue}} end - - def handle_cast(m, state) do - IO.inspect("Unknown: #{inspect(m)}, #{inspect(state)}") - {:noreply, state} - end end