Skip to content

Commit 0659c3b

Browse files
committed
No need to monitor nodes
The runner is already monitor the remote node and a nodedown will necessarily be picked up
1 parent a99467d commit 0659c3b

File tree

2 files changed

+1
-17
lines changed

2 files changed

+1
-17
lines changed

lib/flame.ex

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -210,7 +210,7 @@ defmodule FLAME do
210210
211211
*Note*: The placed child process is linked to the caller and will only survive
212212
as long as the caller does. This is to ensure that the child process is never
213-
oprhaned permanently on the remote node.
213+
orphaned permanently on the remote node.
214214
215215
*Note*: The child spec will be rewritten to use a temporary restart strategy
216216
to ensure that the child process is never restarted on the remote node when it

lib/flame/fly_backend.ex

Lines changed: 0 additions & 16 deletions
Original file line numberDiff line numberDiff line change
@@ -90,7 +90,6 @@ defmodule FLAME.FlyBackend do
9090

9191
@impl true
9292
def init(opts) do
93-
:global_group.monitor_nodes(true)
9493
conf = Application.get_env(:flame, __MODULE__) || []
9594
[node_base | ip] = node() |> to_string() |> String.split("@")
9695

@@ -226,21 +225,6 @@ defmodule FLAME.FlyBackend do
226225
end
227226
end
228227

229-
@impl true
230-
def handle_info({:nodedown, down_node}, state) do
231-
if down_node == state.runner_node_name do
232-
{:stop, {:shutdown, :noconnection}, state}
233-
else
234-
{:noreply, state}
235-
end
236-
end
237-
238-
def handle_info({:nodeup, _}, state), do: {:noreply, state}
239-
240-
def handle_info(_msg, state) do
241-
{:noreply, state}
242-
end
243-
244228
defp rand_id(len) do
245229
len |> :crypto.strong_rand_bytes() |> Base.encode64(padding: false) |> binary_part(0, len)
246230
end

0 commit comments

Comments
 (0)