jonasbhjulstad

jonasbhjulstad

Hi!
I’ve been able to setup child nodes, but I’m trying to get them online. The intention is to make the nodes act as separate computers, such that I can broadcast messages to them via udp.

Code I’ve been using for parent node:

Node.start(:master@localhost, :shortnames)

(When running :longnames, I get a name error when initializing child nodes)

Code for initializing child nodes:

defmodule Child_Nodes do

  def init child_names do
    :os.cmd('epmd -daemon')
    for child_name <- child_names do
      {:ok, node} = start_child child_name
      load_code node
    end
  end

  def project_module_path do
    Path.absname('_build/dev/ebin') |>
    to_charlist()
  end

  def start_child name do
    :slave.start(:localhost, name)
  end

  def load_code node do
    :rpc.block_call(node, :code, :add_paths, [:code.get_path()])
    :rpc.block_call(node, :code, :add_paths, [project_module_path()])
  end
end

This allows me to run my projects code on the child_nodes and access them using Node.ping(). However, each node are going to find eachother over udp using this module, with different ports:

defmodule Broadcasting do

  @broadcast_timeout 1000

  @localhost {10, 0, 0, 68}

  #Node-name format: OrderHandler_<port>@<address>

  def init port do

    {:ok, socket} = :gen_udp.open(port, [active: true, broadcast: true])

    Task.async fn -> broadcast socket, port end

    IO.puts "Node at port #{port} initialized"

    listen socket, port

  end

  def broadcast socket, port do

    :gen_udp.send(socket, {255,255,255,255}, port, to_string(port))

    :timer.sleep(@broadcast_timeout)

    broadcast socket, port

  end

  def listen socket, port do

    local_msg = to_string(port)

    receive do

      {:udp, _socket, _address, port, ^local_msg} ->

        IO.inspect port

        IO.puts "localmsg"

        listen socket, port

      {:udp, _socket, address, remote_port, _msg} ->

        string_address = ip_to_string(address)

        IO.puts "new node added at port: #{port}"

        #"OrderHandler_" <> to_string(remote_port) <> "@" <> string_address |> String.to_atom |> Node.ping

        #localhost-version

        "OrderHandler_" <> to_string(remote_port) <> "@localhost" |> String.to_atom |> Node.ping

      end

  end

  def ip_to_string ip do

    :inet.ntoa(ip) |> to_string()

  end

end

Is it possible to bring all child nodes online?

Showing Posts 1 to 6

ityonemo

ityonemo

What is going to call this broadcasting module? A task? I think this is a place you should use gen_servers.

Also, the nodes have to be on the same layer-2 network that supports udp broadcasting and most major cloud providers don’t support this.

You might need to give beam.smp special setuid permissions (CAP_NET_RAW iirc) for it to be able to broadcast.

Finally you may run out of udp connections if you’re using nf_conntrack on Ubuntu 18.04.

jonasbhjulstad

jonasbhjulstad OP

The plan was to simply spawn the broadcasting procedure in each child node:

for node <- Node.list() do
Node.spawn(node, fn -> Broadcasting.init('uniqe ports') end)
end

The thing is that they aren’t able to find each other once the broadcasting starts.
This isn’t going to be a long-time robust solution, it is only going to be a replacement for the lack of computers atm

ityonemo

ityonemo

What’s the result of gen_udp.send?

jonasbhjulstad

jonasbhjulstad OP

iex(2)> Node.start(:master@localhost, :shortnames)
{:ok, #PID<0.275.0>}
iex(master@localhost)3> Child_Nodes.init(['1', '2', '3'])
[:ok, :ok, :ok]
iex(master@localhost)4> Node.spawn(:'1@localhost', fn -> Broadcasting.init(3456) end) 
#PID<17862.95.0>
iex(master@localhost)5> Node at port 3456 initialized
iex(master@localhost)5> new node added at port: 3456
iex(master@localhost)6> Node.spawn(:'3@localhost', fn -> Broadcasting.init(3455) end) 
#PID<17960.95.0>
iex(master@localhost)7> Node at port 3455 initialized
iex(master@localhost)7> new node added at port: 3455

They are able to detect themselves, but not each other

ityonemo

ityonemo

What is the result of :gen_udp.send? Can you IO.inspect it?

jonasbhjulstad

jonasbhjulstad OP

Sorry, for the late reply, inspecting the :gen_udp.send was a good idea:

iex(master@localhost)4> Node at port 3456 initialized
iex(master@localhost)4> new node added at port: 3456
iex(master@localhost)4> :ok
iex(master@localhost)4> {:error, :closed}
— All posts loaded —

Where Next? Top

Trending in Questions Top

RSP87
I’m working on a project that simulates the bumbl example in the programming phoenix book. It acts almost like an email client. We have a...
New
kszambelanczyk
Hello! Could someone please give me a help/sample code, how to delete a file from s3 using waffle/waffle_ecto from Phoenix app. I creat...
New
RemyXRenard
I’m seeing that a list inside a Kino.DataTable will be interpreted as a charlist, even if the Kino.configure() is set to charlists: :as_l...
New
velrest
So my question is quite simple and i have found no conclusive answer on forum, google or AI. Should we use :erlang.float for Integer to ...
New
samoloth
Hi, I’ve just set up an application with ash_authentication. There is only magic link strategy for now, so there is no confirmation add o...
New
FlyingNoodle
If a change or preparation module uses Ash.Changeset.get_argument/2 or Ash.Query.get_argument/2 (or any of the other get_argument functio...
New
ryanwinchester
apply_graft/2 doesn’t rewrite an add_many sub-workflow’s deps on an add step. Grafted jobs cancel with “upstream job was deleted” Version...
New

Other Trending Topics Top

mudasobwa
I am happy to introduce the very α version of the new programming language compiled to BEAM. Welcome Cure. It has literally three kille...
New
marciok
Hi there! We created Gust: A task orchestrator inspired by Airflow. For those who have never heard about Aiflow, it’s a Python-based wor...
New
jimsynz
Beam Bots (or just BB for short) is a framework for building fault-tolerant robotics applications in Elixir using familiar OTP patterns. ...
New
Dmk
Xamal is a deployment tool for Elixir apps that deploys native releases to bare metal servers over SSH. It’s a port of GitHub - basecamp/...
New
Damirados
Hello everyone. After busy few months I am happy to announce v0.1.0 of Emerge &amp; Solve. They are GUI (Emerge) and State management (S...
New
netoum
Corex is an accessible, unstyled UI component library for Phoenix that integrates Zag.js state machines using Vanilla JavaScript and Live...
New

We're in Beta

About us Mission Statement

Options

Thread Display Mode




Thread Preview

Skip Thread Previews