Limit czasu w popen działa, ale popen w limicie czasu nie działa?

Question

Najłatwiej wyjaśnić w kodzie:

require 'timeout' 

puts "this block will properly kill the sleep after a second" 

IO.popen("sleep 60") do |io| 
    begin 
    Timeout.timeout(1) do 
     while (line=io.gets) do 
     output += line 
     end 
    end 
    rescue Timeout::Error => ex 
    Process.kill 9, io.pid 
    puts "timed out: this block worked correctly" 
    end 
end 

puts "but this one blocks for >1 minute" 

begin 
    pid = 0 
    Timeout.timeout(1) do 
    IO.popen("sleep 60") do |io| 
     pid = io.pid 
     while (line=io.gets) do 
     output += line 
     end 
    end 
    end 
rescue Timeout::Error => ex 
    puts "timed out: the exception gets thrown, but much too late" 
end 

Moja umysłowy model dwóch bloków jest identyczna:

Więc, co mi brakuje?

edytuj: drmaciver zasugerował na Twitterze, że w pierwszym przypadku z jakiegoś powodu gniazdo rury przechodzi w tryb bez blokowania, ale w drugim nie. Nie mogę wymyślić żadnego powodu, dla którego by to się stało, ani nie mogę wymyślić, jak zdobyć flagi deskryptora, ale jest to przynajmniej wiarygodna odpowiedź? Pracując nad tą możliwością.

Answer 1

Aha, subtelny.

Istnieje klauzula ukryta, blokująca ensure na końcu bloku popen IO # w drugim przypadku. Limit czasu :: Błąd to podniesiony podniesiony w odpowiednim czasie, ale nie można go wykonać, dopóki wykonanie nie powróci z domyślnej klauzuli ensure.

Under the hood, IO.popen(cmd) { |io| ... } robi coś takiego:

def my_illustrative_io_popen(cmd, &block) 
    begin 
    pio = IO.popen(cmd) 
    block.call(pio)  # This *is* interrupted... 
    ensure 
    pio.close   # ...but then control goes here, which blocks on cmd's termination 
    end 

i IO # blisko połączenie jest naprawdę bardziej lub mniej pclose(3), który blokuje cię waitpid(2) aż wyjść spanie dziecka.

Można to sprawdzić tak:

#!/usr/bin/env ruby 

require 'timeout' 

BEGIN { $BASETIME = Time.now.to_i } 

def xputs(msg) 
    puts "%4.2f: %s" % [(Time.now.to_f - $BASETIME), msg] 
end 

begin 
    Timeout.timeout(3) do 
    begin 
     xputs "popen(sleep 10)" 
     pio = IO.popen("sleep 10") 
     sleep 100      # or loop over pio.gets or whatever 
    ensure 
     xputs "Entering ensure block" 
     #Process.kill 9, pio.pid  # <--- This would solve your problem! 
     pio.close 
     xputs "Leaving ensure block" 
    end 
    end 
rescue Timeout::Error => ex 
    xputs "rescuing: #{ex}" 
end 

Więc co można zrobić?

Będziesz musiał to zrobić w sposób jawny, ponieważ tłumacz nie ujawnia sposobu na przesłonięcie logiki IO # popen ensure. Możesz użyć powyższego kodu jako szablonu początkowego i odkomentować na przykład linię kill().

Answer 2

W pierwszym bloku przekroczono limit czasu dla dziecka, zabijając go i przekazując kontrolę rodzicowi. W drugim bloku limit czasu jest podniesiony w rodzicu. Dziecko nigdy nie otrzymuje sygnału.

Zobacz io.chttps://github.com/ruby/ruby/blob/trunk/io.c#L6021 i timeout.rbhttps://github.com/ruby/ruby/blob/trunk/lib/timeout.rb#L51