Início / unix / Perguntas / 559235
Accepted
Ole Tange
Asked: 2019-12-28 22:16:22 +0800 CST

Leia STDIN com tempo limite

  • 772

Eu quero ler STDIN, mas no máximo por 5 segundos. Depois disso, quero processar os dados que li até agora.

selectparece ser feito exatamente para isso: Aguarde até que haja entrada ou até o tempo limite.

Se houver entrada, devo apenas ler esse não-bloqueio.

Então eu assumi que isso funcionaria:

#!/usr/bin/perl -w

use strict;
use Fcntl;

open(my $in, "<&", "STDIN") or die;
my $buf = "";
my $readsize = 10;

# Make $in non-blocking
fcntl($in, &F_SETFL, fcntl($in, &F_GETFL, 0) | &O_NONBLOCK);
while(not eof($in)) {
    my $starttime = time();
    my $rin = my $win = my $ein = '';
    vec($rin, fileno($in),  1) = 1;
    while(time() < $starttime + 5 and length $buf < $readsize) {
        # Wait up to 5 seconds for input                                                               
        select($rin, $win, $ein, $starttime + 5 - time());
        # Read everything that is available in the inputbuffer                                         
        while(read($in,$buf,$readsize,length $buf)) {}
    }
    print "B:",$buf;
    $buf = "";
}

Quando executado como:

(echo block1;sleep 1; echo block1; sleep 6;echo block2)|
  perl nonblockstdin.pl

os blocos são mesclados. Eles deveriam ter sido dois blocos porque o bloco2 começa 6 segundos depois.

O que estou fazendo errado?

perl

2 respostas

  1. Best Answer

    Alguns dos problemas:

    • A configuração O_NONBLOCKafeta a descrição do arquivo aberto, não apenas o descritor do arquivo. Por exemplo, se você executar that-script; cat, verá cat: -: Resource temporarily unavailable, pois cato stdin de stdin se tornou não bloqueante
    • se você usar E/S sem bloqueio, a read()chamada do sistema retornará com um erro EAGAIN se não houver entrada no momento e eof estiver definido. perl's eof()chama read()e implica fazer E/S em buffer. Você realmente não pode usá-lo para E/S sem bloqueio. No seu exemplo, o primeiro block1é lido e eof(), em seguida, select()aguarda durante sleep 1e o segundo block1é lido, read()retornando os dois block1s.

    Aqui, seria melhor usar o bloqueio de E/S e usar alarm(), por exemplo, o tempo limite. Se estiver usando E/S sem bloqueio e select(), não use eof()e use sysread()em vez de read()e certifique-se de limpar o O_NONBLOCKsinalizador na saída se tiver sido definido anteriormente (ainda é uma má idéia definir O_NONBLOCKem stdin, pois esse stdin pode ser compartilhado com outros processos ).

    • 1

  2. Seguindo as sugestões de Stephane, cheguei a isso, que até agora parece funcionar.

    #!/usr/bin/perl -w                                                                                                                                   

use strict;

my $timeout = 2;
my $buf = "";
my $blocksize = 30;
my $readsize;
my $nread;
my $buflen;
my $alarm;
my $eof;

open(my $in, "<&", "STDIN") or die;

do {
    eval {
        local $SIG{ALRM} = sub { die "alarm\n" }; # NB: \n required                                                                                  
        alarm $timeout;
        # Add upto the next full block                                                                                                               
        $readsize = $blocksize - (length $buf) % $blocksize;
        do {
            $nread = sysread $in, $buf, $readsize, length $buf;
            $readsize -= $nread;
        } while($nread and $readsize);
        alarm 0;
    };
    if ($@) {
        die unless $@ eq "alarm\n";   # propagate unexpected errors                                                                                  
        $alarm = 1;
    } else {
        $alarm = 0;
    }
    print "B:$buf<\n";
    $buf = "";
    $eof = not ($nread or $alarm);
} while(not $eof);
    • 0

relate perguntas