AD
'Beagle' интересніе ребята
Size: a a a
2019 July 03
c🦊
'Beagle' интересніе ребята
Так это Texas Instruments
2019 July 04
DR
суть в том что процесс закрывается после приема данных сразу
Если по памяти написал, то в Pastebin точно есть ошибка
DR
def listener(parent_pid, socket) do
{:ok, data} = :gen_udp.open(socket,0)
send(parent_pid, {self(), data})
listener
end
#@
def listener(parent_pid, socket) do
{:ok, data} = :gen_udp.recv(socket,0)
send(parent_pid, {self(), data})
listener(parent_pid, socket)
end
{:ok, data} = :gen_udp.recv(socket,0)
send(parent_pid, {self(), data})
listener(parent_pid, socket)
end
#@
Вот правильная версия
DR
def listener(parent_pid, socket) do
{:ok, data} = :gen_udp.recv(socket,0)
send(parent_pid, {self(), data})
listener(parent_pid, socket)
end
{:ok, data} = :gen_udp.recv(socket,0)
send(parent_pid, {self(), data})
listener(parent_pid, socket)
end
Вот исправленная версия: https://gist.github.com/liveforeverx/6cf03c1f748f8b7d3eb97b098f81e5a2
#@
Благодарю
DR
def listener(parent_pid, socket) do
{:ok, data} = :gen_udp.recv(socket,0)
send(parent_pid, {self(), data})
listener(parent_pid, socket)
end
{:ok, data} = :gen_udp.recv(socket,0)
send(parent_pid, {self(), data})
listener(parent_pid, socket)
end
Но, если Вы в Elixir-е новый, то очень рекомендую прочитать вот эту главу: https://elixir-lang.org/getting-started/mix-otp/genserver.html и вот эту: https://elixir-lang.org/getting-started/mix-otp/supervisor-and-application.html
DR
Благодарю
И переделать с использованием супервизора и GenServer-а.
DR
Благодарю
И даже если решите не использовать GenServer, то рекомендую использовать либо Core https://github.com/fishcakez/core либо хотя бы proc_lib http://erlang.org/doc/man/proc_lib.html а не просто spawn.
DR
Благодарю
Добавил версию, где не нужно копировать данные между процессами и сообщения получаются сразу в том же процессе (через active, once и получение сообщения) - можно легко модифицировать, чтобы в том же процессе работать с несколькими сокетами.
#@
Большое спасибо, чуть позже сяду разбираться
DR
Большое спасибо, чуть позже сяду разбираться
https://gist.github.com/liveforeverx/6cf03c1f748f8b7d3eb97b098f81e5a2 - я накидал примеров.
DR
Большое спасибо, чуть позже сяду разбираться
Второй вариант с одним процессом, а не с двумя. Третий пример, как это сделать через GenServer, четвёртый пример, как открыть два сокета в одном процессе.
#@
Такой нюанс, почему то прилетают пакеты с разных портов, не только с 19000
#@
19100
19910
19910
#@
Странно, ведь указан конкретный порт для прослушки
#@
И еще. Что бы вернуть данные в start, мне кажется, не правильно будет просто returнуть это из receive_loop, ведь она вызывается рекурсивно
#@
Нужно использовать буфер?