elang:port_close - закрывать stdin перед stdout

Столкнулся с необычной проблемой.

Ситуация: пи�?у декодер mp3->raw с помощью вызова mpg123 через порты.

Decoder = open_port({spawn, "mpg123 -s -"}, [binary]),

Логика простая - мне нужно получать сырые данные в реальном времени (именно в реальном, не быстрее), поэтому я постепенно скармливаю в порт mp3-данные и так же постепенно читаю из него декодированные данные. На этапе открытия-декодирования всё ок. Проблемы начинаются при попытке закрытия порта.

Обычно логика должна работать так: входящий поток для mpg123 закрывается. mpg123 думает. что файл закончился и флу�?ит наружу остаток данных (данные идут кадрами, поэтому внутри mpg123 есть неболь�?ой буфер с предыдущим, нераскодированным до конца куском, т.е. с половиной кадра).
Соответственно, если вначале закрыть ему stdin, то в момент закрытия в stdout придёт остав�?ийся кусок данных. Если закрыть stdout, а потом stdin, то mpg123 падает с примерно следущей о�?ибкой:

[audio.c:596] error: Error in writing audio (Broken pipe?)!
[mpg123.c:583] error: Deep trouble! Cannot flush to my output anymore!

Что, впринципе, понятно.

Так вот. port_close, похоже, работает именно так - вначале закрывается stdout порта, а потом stdin. Соответственно, часть данных mpg123 непофлу�?ила и они потерялись для меня.

Перерыл документацию, но способа закрыть отдельно потоки внутри порта не на�?ел.
Что делать?

Более чем работоспособны. Проверено уже много раз, в том числе и с mpg123. Надо попробовать более традиционным способом работать с ними: подключить библиотеку к драйверу порта, данные пересылать не через стандартные потоки, а через сам порт (port_command). Как в эрланговской документации описано. Сделать специальные команды для инициализации библиотеки и настройки параметров декодирования. Ну и для flush тоже отдельную команду.
В общем случае все равно не получится только stdin и stdout обойтись.

> В общем случае все равно не получится только stdin и stdout обойтись.

Я бы и рад какой-то боль�?ий контроль получить, но как? С горя полез по исходникам искать реализацию port_* -комманд и не на�?ёл :(

Т.е. я правильно понимаю, что �?татный механизм предназначен только для простых случаев, а что-то боль�?ее требует написание своих драйверов порта?

Так мне не библиотека нужна была, а просто запущенный в под�?елле бинарник, который я могу как-то контролировать (писать-читать в его stdin/stdout и посылать сигналы).

�?звиняюсь, что пропал...

Луч�?е покажу код :)

Я порождаю декодер

Decoder = open_port({spawn, "mpg123 -s -"}, [binary]),

Потом я туда пи�?у данные

port_command(Decoder, Data)

�? жду декодированные данные

receive
{Decoder, {data, Buf}} ->
%io:format("Decoded data received of length: ~p~n", [length(binary_to_list(Buf))]),
file:write(Output, Buf),
loop(Decoder, Output);
{decoder, eof} ->
io:format("Eof reached. Switching to next file~n"),
loop(Decoder, Output);

.....

Вот port_command умеет только писать данные, но не умеет закрывать stdin запущенной программы (т.е. не могу туда отправить eof). А мне это надо. �? хотелось без написания промежуточной программы-драйвера порта, потому что имеющийся функционал меня почти устраивает :)