projects
/
akkoma
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
non condition dir creation
[akkoma]
/
restarter
/
lib
/
pleroma.ex
diff --git
a/restarter/lib/pleroma.ex
b/restarter/lib/pleroma.ex
index d7817909d8cbdc586651d8b168bfdea75a3386c2..149a569ce42b016910c9780814aa24999d640176 100644
(file)
--- a/
restarter/lib/pleroma.ex
+++ b/
restarter/lib/pleroma.ex
@@
-3,11
+3,21
@@
defmodule Restarter.Pleroma do
require Logger
require Logger
+ @init_state %{need_reboot: false, rebooted: false, after_boot: false}
+
def start_link(_) do
GenServer.start_link(__MODULE__, [], name: __MODULE__)
end
def start_link(_) do
GenServer.start_link(__MODULE__, [], name: __MODULE__)
end
- def init(_), do: {:ok, %{need_reboot?: false}}
+ def init(_), do: {:ok, @init_state}
+
+ def rebooted? do
+ GenServer.call(__MODULE__, :rebooted?)
+ end
+
+ def rebooted do
+ GenServer.cast(__MODULE__, :rebooted)
+ end
def need_reboot? do
GenServer.call(__MODULE__, :need_reboot?)
def need_reboot? do
GenServer.call(__MODULE__, :need_reboot?)
@@
-29,41
+39,51
@@
defmodule Restarter.Pleroma do
GenServer.cast(__MODULE__, {:after_boot, env})
end
GenServer.cast(__MODULE__, {:after_boot, env})
end
+ def handle_call(:rebooted?, _from, state) do
+ {:reply, state[:rebooted], state}
+ end
+
def handle_call(:need_reboot?, _from, state) do
def handle_call(:need_reboot?, _from, state) do
- {:reply, state[:need_reboot
?
], state}
+ {:reply, state[:need_reboot], state}
end
end
- def handle_cast(:re
fresh, _
state) do
- {:noreply,
%{need_reboot?: false}
}
+ def handle_cast(:re
booted,
state) do
+ {:noreply,
Map.put(state, :rebooted, true)
}
end
end
- def handle_cast(:need_reboot, %{need_reboot
?
: true} = state), do: {:noreply, state}
+ def handle_cast(:need_reboot, %{need_reboot: true} = state), do: {:noreply, state}
def handle_cast(:need_reboot, state) do
def handle_cast(:need_reboot, state) do
- {:noreply, Map.put(state, :need_reboot?, true)}
+ {:noreply, Map.put(state, :need_reboot, true)}
+ end
+
+ def handle_cast(:refresh, _state) do
+ {:noreply, @init_state}
end
def handle_cast({:restart, :test, _}, state) do
end
def handle_cast({:restart, :test, _}, state) do
- Logger.
warn("pleroma
restarted")
- {:noreply, Map.put(state, :need_reboot
?
, false)}
+ Logger.
debug("pleroma manually
restarted")
+ {:noreply, Map.put(state, :need_reboot, false)}
end
def handle_cast({:restart, _, delay}, state) do
Process.sleep(delay)
do_restart(:pleroma)
end
def handle_cast({:restart, _, delay}, state) do
Process.sleep(delay)
do_restart(:pleroma)
- {:noreply, Map.put(state, :need_reboot
?
, false)}
+ {:noreply, Map.put(state, :need_reboot, false)}
end
def handle_cast({:after_boot, _}, %{after_boot: true} = state), do: {:noreply, state}
def handle_cast({:after_boot, :test}, state) do
end
def handle_cast({:after_boot, _}, %{after_boot: true} = state), do: {:noreply, state}
def handle_cast({:after_boot, :test}, state) do
- Logger.warn("pleroma restarted")
- {:noreply, Map.put(state, :after_boot, true)}
+ Logger.debug("pleroma restarted after boot")
+ state = %{state | after_boot: true, rebooted: true}
+ {:noreply, state}
end
def handle_cast({:after_boot, _}, state) do
do_restart(:pleroma)
end
def handle_cast({:after_boot, _}, state) do
do_restart(:pleroma)
- {:noreply, Map.put(state, :after_boot, true)}
+ state = %{state | after_boot: true, rebooted: true}
+ {:noreply, state}
end
defp do_restart(app) do
end
defp do_restart(app) do