mirror of
https://github.com/fnproject/fn.git
synced 2022-10-28 21:29:17 +03:00
Client build fixes (#305)
* Some client build fixes. * Removed tests dir, was for Titan.
This commit is contained in:
38
clients/utils.rb
Normal file
38
clients/utils.rb
Normal file
@@ -0,0 +1,38 @@
|
||||
require 'open3'
|
||||
|
||||
class ExecError < StandardError
|
||||
attr_accessor :exit_status, :last_line
|
||||
|
||||
def initialize(exit_status, last_line)
|
||||
super("Error on cmd. #{exit_status}")
|
||||
self.exit_status = exit_status
|
||||
self.last_line = last_line
|
||||
end
|
||||
end
|
||||
|
||||
def stream_exec(cmd)
|
||||
puts "Executing cmd: #{cmd}"
|
||||
exit_status = nil
|
||||
last_line = ""
|
||||
Open3.popen2e(cmd) do |stdin, stdout_stderr, wait_thread|
|
||||
Thread.new do
|
||||
stdout_stderr.each {|l|
|
||||
puts l
|
||||
# Save last line for error checking
|
||||
last_line = l
|
||||
}
|
||||
end
|
||||
|
||||
# stdin.puts 'ls'
|
||||
# stdin.close
|
||||
|
||||
exit_status = wait_thread.value
|
||||
raise ExecError.new(exit_status, last_line) if exit_status.exitstatus != 0
|
||||
end
|
||||
return exit_status
|
||||
end
|
||||
|
||||
def exec(cmd)
|
||||
puts "Executing: #{cmd}"
|
||||
puts `#{cmd}`
|
||||
end
|
||||
Reference in New Issue
Block a user