¿Cómo hago una lectura de IPC sin bloqueo en Windows?

Question

Tengo un script Perl que usa una herramienta externa (cleartool) para reunir información sobre una lista de archivos. Quiero usar IPC para evitar genere un nuevo proceso para cada archivo:

use IPC::Open2; 
my ($cin, $cout); 
my $child = open2($cout, $cin, 'cleartool'); 

comandos que devuelven esquemas eléctricos funcionan bien. p.ej.

print $cin "describe -short $file\n"; 
my $description = <$cout>; 

comandos que devuelven varios líneas me tienen en un callejón sin salida para la forma de consumir toda la respuesta sin quedar atrapado por un bloqueo de lectura:

print $cin "lshistory $file\n"; 
# read and process $cout... 

He tratado de establecer el gestor de archivo de sin bloqueo lee a través de fcntl:

use Fcntl; 
my $flags = ''; 
fcntl($cout, F_GETFL, $flags); 
$flags |= O_NONBLOCK; 
fcntl($cout, F_SETFL, $flags); 

pero Fcntl muere con el mensaje "Su proveedor no ha definido Fcntl macro F_GETFL."

He intentado usar IO :: Handle para establecer $cout->blocking(0) pero eso falla (devuelve undef y establece $! en "Error desconocido").

He intentado utilizar select para determinar si hay datos disponibles antes de intentar leer:

my $rfd = ''; 
vec($rfd, fileno($cout), 1) = 1; 
while (select($rfd, undef, undef, 0) >= 0) { 
    my $n = read($cout, $buffer, 1024); 
    print "Read $n bytes\n"; 
    # do something with $buffer... 
} 

pero que cuelga, sin leer nada. ¿Alguien sabe cómo hacer que esto funcione (en Windows)?

Answer 1

select only works on sockets en Windows. Parece que IPC :: OpenX usa manejadores de archivos normales, por lo que no podrá usar select con los identificadores que crea.

Si no necesita el tiempo de espera/detección de actividad que selecciona, puede configurar los controladores para que sean no bloqueantes y solo lean o escriban como lo hace normalmente.

Si necesita un control más matizado, IPC::Run puede funcionar bien para usted.

También puede consultar la creación de un socketpair y usar esos identificadores con los procesos secundarios. Los perls más nuevos (5.8 y superiores) admiten la emulación socketpair en Windows utilizando sockets TCP.

Si intenta clonar STDOUT y STDERR para un programa que se ejecuta sin una consola (es decir, se inicia con wperl, en lugar de perl), no podrá obtener datos a través de STDIO.

En la práctica, esto ha sido un gran dolor para mí en varios proyectos. Lo que encontré que funcionó mejor fue escribir el proceso hijo para conectarse al servidor principal a través de TCP. Si no controla los procesos secundarios, consulte IPC::Run o socketpair.

Answer 2

IO no bloqueante es difícil en Windows. En este caso, se puede enviar la salida de cleartool a un archivo normal, y para utilizar seek a restablecer el indicador EF en el archivo cada vez que fuera leído del archivo:

my($cin, $cout); 
my $somefile = "some/file"; 
open($cin, "| cleartool > $somefile"); 
open($cout, '<', $somefile); 

... 

print $cin "$command_for_cleartool\n"; 
# if necessary, wait until cleartool finishes with new output 
seek $cout, 0, 1;  # clear eof condition from previous read 
my @cleartool_output = <$cout>; # capture recent output 
... process output ... 

Aunque esto probablemente no va a funcionar que bien si cleartool almacena su salida.

Answer 3

Otro kludge es usar sysread con un tamaño de búfer grande o improbable.

print $cin "$command_for_cleartool\n"; 
    my ($description, $maxlen, $buffer) = ("", 65336); 
    while (my $n = sysread $cout, $buffer, $maxlen) { 
     $description .= $buffer; 
     last if $n < $maxlen; 
    } 
    ... do something with $description ... 

sysread colgará si hay exactamente 0 bytes de entrada en espera de ser leído. Entonces, el código anterior se bloqueará si cleartool produce exactamente algún múltiplo de 65336 bytes. Si conoce un buen límite superior en el tamaño de la salida del programa, puede usar ese valor para $maxlen arriba. De lo contrario, podría elegir un número grande e improbable y rezar ...