Sha256: 61c472b55b87acdc4a00f7805831303f493c8646aa55d131ee9573ff2b2fe062
Contents?: true
Size: 1.42 KB
Versions: 14
Compression:
Stored size: 1.42 KB
Contents
module Climatic
module Processes
module Synchronous
def execute
self.exit_status = nil
self.last_pid = nil
self.process_state = :running
self.start_time = Time.now
Open3.popen3(command) do |stdin, stdout, stderr, wait_thread|
stdin.close
self.last_pid = wait_thread.pid
begin
monitored_streams = [stdout, stderr]
loop do
begin
readables, writables = IO.select(monitored_streams)
writables.each(&:close)
readables.each do |io|
begin
buffer = ''
buffer << io.read_nonblock(1) while buffer[-1] != "\n"
report buffer, io == stdout
rescue IO::WaitReadable
next
rescue EOFError => e
monitored_streams.delete io
monitored_streams.empty? ? raise(e) : next
end
end
rescue EOFError
report "End of process #{wait_thread.value.pid}"
break
end
end
rescue Errno::EAGAIN
retry
end
self.exit_status = wait_thread.value
return self.exit_status
end
ensure
self.end_time = Time.now
self.process_state = :terminated
end
end
end
end
Version data entries
14 entries across 14 versions & 1 rubygems