Мне нужно мое приложение erlang для чтения и записи через именованный канал.
Открытие именованного канала в виде файла завершится ошибкой с eisdir.
Я написал следующий модуль, но он хрупок и во многих отношениях кажется неправильным. Также это не удается прочитать через некоторое время. Есть ли способ сделать его более ... элегантным?
-module(port_forwarder).
-export([start/2, forwarder/2]).
-include("logger.hrl").
start(From, To)->
spawn(fun() -> forwarder(From, To) end).
forwarder(FromFile, ToFile) ->
To = open_port({spawn,"/bin/cat > " ++ ToFifo},
[binary, out, eof,{packet, 4}]),
From = open_port({spawn,"/bin/cat " ++ FromFifo},
[binary, in, eof, {packet, 4}]),
forwarder(From, To, nil).
forwarder(From, To, Pid) ->
receive
{Manager, {command, Bin}} ->
?ERROR("Sending : ~p", [Bin]),
To ! {self(), {command, Bin}},
forwarder(From, To, Manager);
{From ,{data,Data}} ->
Pid ! {self(), {data, Data}},
forwarder(From, To, Pid);
E ->
?ERROR("Quitting, first message not understood : ~p", [E])
end.
Как вы могли заметить, он имитирует формат порта в том виде, в котором он принимает или возвращает.
Я хочу, чтобы он заменил код C, который будет читать другие концы каналов и запускаться из отладчика.