perl can_read возвращает дескриптор, когда нечего читать - PullRequest
Новая
       20

perl can_read возвращает дескриптор, когда нечего читать

5 голосов
/ 24 мая 2011

В приведенном ниже коде я пытаюсь выполнить простую операцию с хвостом файла. Предположим, что foo.txt полностью пуст. Я ожидаю, что первый can_read () заблокирует, но это не так. Также не могут вызовы can_read в блоке sysreadline () или ожидание. Вместо этого происходит следующее: первый can_read немедленно возвращает дескриптор файла foo.txt, а первый can_read в sysreadline делает то же самое. Затем sysread ничего не возвращает, потому что нечего читать, что приводит к занятому ожиданию внутри sysreadline. Как это может быть? Я знаю, что выбор может закончиться рано из-за сигнала или закрытого дескриптора файла, но я не вижу никакой возможности для этого здесь. Фактически, когда текст появляется (с новой строкой) в файле foo.txt, он печатается. Я не понимаю, почему код не блокируется бесконечно, как первый can_read, когда нечего читать. Кроме того, что вы теряете процессор, вы не можете подключать несколько файлов одновременно, потому что вы всегда будете застревать в первом занятом ожидании. Я чувствую, что я должен упускать из виду что-то простое здесь ...

Это perl 5.8.8 



#!/usr/bin/perl -w
use strict;
use IO::Select;
use IO::Handle; 
use Symbol qw(qualify_to_ref); 

open my $inf, "<", "foo.txt" or die "hey! Can't open foo.txt!\n";
my $sel = IO::Select->new();
$sel->add($inf);

while(my @ready = $sel->can_read()){

    foreach my $handle (@ready){
    my $line = sysreadline($handle);
    print $line;
    }

}

##
## deal with buffering for select. from perl cookbook 7.23
sub sysreadline {
    my($handle, $timeout) = @_;
    $handle = qualify_to_ref($handle, caller( ));
    my $infinitely_patient = (@_ == 1 || $timeout new( );
    $selector->add($handle);
    my $line = "";
SLEEP:
    until (at_eol($line)) {
        unless ($infinitely_patient) {
            return $line if time( ) > ($start_time + $timeout);
        }
        # sleep only 1 second before checking again
        next SLEEP unless $selector->can_read(1.0);
INPUT_READY:
        while ($selector->can_read(0.0)) {
            my $was_blocking = $handle->blocking(0);
CHAR:       while (sysread($handle, my $nextbyte, 1)) {
                $line .= $nextbyte;
        ##print "next: [$nextbyte]\n";
                last CHAR if $nextbyte eq "\n";
            }
            $handle->blocking($was_blocking);
            # if incomplete line, keep trying
            next SLEEP unless at_eol($line);
            last INPUT_READY;
        }
    }
    return $line;
}
sub at_eol($) { $_[0] =~ /\n\z/ }

1 Ответ

7 голосов
/ 24 мая 2011

Возврат из select означает «чтение не будет блокироваться (т.е. ждать вечно, чтобы произошло какое-то внешнее событие)», а не «данные доступны». Чтение файлов с диска никогда не блокируется, оно сразу возвращает 0 в EOF.

Так что, вероятно, вам лучше использовать File :: Tail , который предлагает @TLP.

...