proc_open() i zapis do procesu, Problem z lame i pipami. Opcje

[carbolymer]

Składnia lame.exe:

Kod

E:\Pulpit\stream>lame -h
LAME 32bits version 3.98.2 (http://www.mp3dev.org/)

usage: lame [options] <infile> [outfile]

    <infile> and/or <outfile> can be "-", which means stdin/stdout.

Mam problem z konwertowaniem mp3. Używam lame, ale zamiast standardowego odczytu z pliku i zapisu do pliku, wolę użyć proc_open i pipe'y (uchwyty do plików, czy jakkolwiek to sie tłumaczy). Gdy podam zamiast wejścia - plik, wszystko działa jak trzeba:

[PHP] pobierz, plaintext 
<?php
$sCommand = 'lame.exe '.$sFile.' -'
?>
[PHP] pobierz, plaintext 

I otrzymuje na w $sPipe[1] poprawnie zakodowane dane.

Gdy podam zamiast wyjścia - plik, też działa jak trzeba:

[PHP] pobierz, plaintext 
<?php
$sCommand = 'lame.exe --mp3input - song.mp3';
?>
[PHP] pobierz, plaintext 

W stdin ląduje poprawnie piosenka, a w pliku song.mp3 są poprawne dane.

Ale, (jak zawsze, coś gdzieś musi polec) gdy wrzuce jako wejscie i wyjście stdin i stdout:

[PHP] pobierz, plaintext 
<?php
$sCommand = 'lame.exe --mp3input - -';
$iCount = 0;
$iSentCount = 0;
$sFile = 'E:SharedDnB & BreakcoreKubrak-Obiebozza.mp3';
 
$aDescriptor = array(
    0 => array("pipe", "r"),
    1 => array("pipe", "w"),
    2 => array("file", "./encoder_error.txt", "a")
);
$rProcess = proc_open($sCommand, $aDescriptor, $aPipes);
if(is_resource($rProcess))
{
    $rFile = fopen($sFile,'r');
    while(!feof($rFile))
    {
        $sData = fread($rFile,8192);
        $iWrittenCount += fwrite($aPipes[0], $sData);
        $iSentCount += strlen($sData);
        echo $iSentCount."\n";
    }
 
    echo "\n odczytano: ".$iSentCount." bajtow";
    echo "\n zapisano:  ".$iWrittenCount." bajtow";
    fclose($aPipes[0]);
    fclose($rFile);
}else throw new Exception('Nie otwarto procesu');
 
while(!feof($aPipes[1]))
    $sReturned .= fread($aPipes[1],8192);
 
echo "\n otrzymano: ".strlen($sReturned)." bajtow";
proc_close($rProcess);
?>
[PHP] pobierz, plaintext 

Zacina się przy pierwszym wykonaniu pętli na fwrite(). Tzn. nie idzie dalej.
Gdy umieszczę fwrite poza pętlą - to samo. Gdy zapiszę jedną paczkę danych odczytuje i zapisuje 8192 bajty, otrzymuje: 7914. (czyli niby ok).

Jakiś pomysł ? Najprawdopodobniej jest to wina lame, ale rozgryźć tego nie potrafię.

Zawartość encoder_error.txt:

Kod

ID3v2 found. Be aware that the ID3 tag is currently lost when transcoding.
LAME 3.98.2 32bits (http://www.mp3dev.org/)
CPU features: MMX (ASM used), SSE (ASM used), SSE2
Using polyphase lowpass filter, transition band: 16538 Hz - 17071 Hz
Encoding <stdin> to <stdout>
Encoding as 44.1 kHz j-stereo MPEG-1 Layer III (11x) 128 kbps qval=3
Error writing mp3 output

Ten post edytował carbolymer 1.06.2009, 23:58:39

[ucho]

Spójrz na http://pl2.php.net/manual/en/function.proc-open.php#89338
Być może będziesz musiał ustawić wejście i wyjście na nieblokujące, i wykonywać na zmianę zapis/odczyt do pipe - pomimo tego, że pewnie nie odczytasz ani bajta póki lame nie skończy działać.

[erix]

AFAIK, to podobnie, jak przy odpalaniu ffmpeg. Ja korzystam z czegoś takiego (znalezione ):

[PHP] pobierz, plaintext 
<?php
# util to grab console app output
function runExternal( $cmd, &$code ) {
 
    $descriptorspec = array(
        0 => array("pipe", "r"),  // stdin is a pipe that the child will read from
        1 => array("pipe", "w"),  // stdout is a pipe that the child will write to
        2 => array("pipe", "w") // stderr is a file to write to
    );
    
    $pipes= array();
    $process = proc_open($cmd, $descriptorspec, $pipes);
 
    $output= "";
 
    if (!is_resource($process)) return false;
 
    #close child's input imidiately
    fclose($pipes[0]);
 
    stream_set_blocking($pipes[1],false);
    stream_set_blocking($pipes[2],false);
 
    $todo= array($pipes[1],$pipes[2]);
 
    while( true ) {
        $read= array();
        if( !feof($pipes[1]) ) $read[]= $pipes[1];
        if( !feof($pipes[2]) ) $read[]= $pipes[2];
 
        if (!$read) break;
 
        $ready= stream_select($read, $write=NULL, $ex= NULL, 2);
 
        if ($ready === false) {
            break; #should never happen - something died
        }
 
        foreach ($read as $r) {
            $s= fread($r,1024);
            $output.= $s;
        }
    }
 
    fclose($pipes[1]);
    fclose($pipes[2]);
 
    $code= proc_close($process);
 
    return $output;
}
?>
[PHP] pobierz, plaintext 

[carbolymer]

Nie można ustawiać dla proc_open wejścia i wyjścia na nieblokujące. Próbowałem z ustawianiem bufora, nic, gdy użyję takiej konfiguracji deskryptora:

[PHP] pobierz, plaintext 
<?php
$aDescriptor = array(
                    0 => array("pipe", "r"),
                    1 => array("file", "./semaphore.mp3","w"),
                    2 => array("file", "./encoder_error.txt", "w")
?>
[PHP] pobierz, plaintext 

dane lądują w semaphore.mp3.
Nie mam pojęcia w jakiej kolejności powinienem odczytywać dane, aby odbywało się to płynnie. Gdy próbowałem po fwrite użyć stream_get_contents() (lub fread() ) zacinało się na tej funkcji.

Za wszelkie pomysły lub sugestie będę wdzięczny.

[erix]

Nie można ustawiać dla proc_open wejścia i wyjścia na nieblokujące.

A próbowałeś? Ja tego gotowca znalazłem gdzieś w Sieci i działa bez żadnych błędów przy ffmpeg, przy lame podejrzewam, że również.

[carbolymer]

Próbowałem. Bez różnicy czy ustawie na blokujące, czy nie, zachowuje sie jak blokujące.