☰

STDIN 읽기 및 시간 초과 설정

tag-icon • tag-icon perl
STDIN 읽기 및 시간 초과 설정

STDIN을 읽고 싶지만 5초를 넘지 않아야 합니다. 그런 다음 지금까지 읽은 데이터를 처리하고 싶습니다.

select정확히 이것을 위해 설계된 것 같습니다. 입력이 있거나 시간 초과될 때까지 기다리십시오.

입력이 있는 경우에만 비차단 콘텐츠를 읽어야 합니다.

그래서 나는 이것이 효과가 있을 것이라고 생각합니다:

#!/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 = "";
}

다음과 같이 실행하면:

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

이 블록은 서로 병합됩니다. 블록 2는 6초 후에 시작되므로 두 블록이어야 합니다.

내가 뭘 잘못했나요?

답변1

몇 가지 문제:

  • 설정은 O_NONBLOCK파일 설명자뿐만 아니라 열린 파일의 설명에도 영향을 줍니다. 예를 들어, 를 실행하면 stdin이 비차단이 되는 것을 that-script; cat볼 수 있습니다.cat: -: Resource temporarily unavailablecat
  • 비차단 I/O를 사용하는 경우 read()이때 입력이 없고 eof가 설정된 경우 시스템 호출은 EAGAIN 오류를 반환합니다. 호출은 버퍼링된 I/O 수행을 의미 perl하지 않습니다. 실제로 비차단 I/O에는 사용할 수 없습니다. 귀하의 예에서 첫 번째 는 read 이고 waited 이고 두 번째 는 read 이며 두 s를 모두 반환합니다.eof()read()block1eof()select()sleep 1block1read()block1

예를 들어 여기서는 I/O 차단 및 시간 초과를 사용하는 것이 더 좋습니다 alarm(). 비차단 I/O를 사용하고 select()대신 eof()사용하는 경우, 종료 시 플래그가 미리 설정되어 있으면 이를 지워야 합니다(stdin에서 설정하는 것은 stdin sysread()이 공유된 다른 프로세스와 상호 작용할 수 있으므로 여전히 나쁜 생각입니다).read()O_NONBLOCKO_NONBLOCK

답변2

Stephen의 제안을 바탕으로 이것을 생각해 냈고 지금까지는 효과가 있는 것 같습니다.

#!/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);

관련 정보