Top Level Namespace
Defined Under Namespace
Classes: Add, Analyze, Array, Build, Command, Commands, Commit, Dev, Doc, Environment, File, Gemspec, Git, Hash, Internet, MSBuild, Nuget, Project, Projects, Publish, Pull, Push, Setup, String, Svn, Tasks, Test, Text, Timer, Update, Wix
Constant Summary collapse
- PROJECT =
Project.new()
- COMMANDS =
Commands.new
- MSBUILD =
MSBuild.new
- TIMER =
Timer.new
- NUNIT =
FileList.new('bin/**/*.Test.dll','bin/**/*.Tests.dll')
- SOURCE =
FileList.new('LICENSE','README','README.md',"Gemfile")
- SLN_FILES =
FileList.new('*.sln','*/*.sln','*/*/*.sln')
- NUGET_FILES =
FileList.new('**/*.nuspec')
- WXS_FILES =
FileList.new('**/*.wxs')
- BUFFER_SIZE =
1024
- PROJECTS =
Projects.new
- RAKE_DEFAULT_EXISTS =
File.exists?('rake.default')
Instance Method Summary collapse
-
#run_with_timeout(directory, command, timeout, tick) ⇒ Object
The following code is based on code originally copied from gist.github.com/lpar/1032297 Gist title: lpar/timeout.rb.
- #run_with_timeout2(directory, command, timeout) ⇒ Object
Instance Method Details
#run_with_timeout(directory, command, timeout, tick) ⇒ Object
The following code is based on code originally copied from gist.github.com/lpar/1032297 Gist title: lpar/timeout.rb
Runs a specified shell command in a separate thread. If it exceeds the given timeout in seconds, kills it. Returns any output produced by the command (stdout or stderr) as a String. Uses Kernel.select to wait up to the tick length (in seconds) between checks on the command’s status
If you’ve got a cleaner way of doing this, I’d be interested to see it. If you think you can do it with Ruby’s Timeout module, think again.
16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 |
# File 'lib/base/timeout.rb', line 16 def run_with_timeout(directory,command, timeout, tick) output = '' exit_code=1 begin # Start task in another thread, which spawns a process stdin, stderrout, thread = Open3.popen2e(command, :chdir=>directory) # Get the pid of the spawned process pid = thread[:pid] start = Time.now while (Time.now - start) < timeout and thread.alive? # Wait up to `tick` seconds for output/error data Kernel.select([stderrout], nil, nil, tick) # Try to read the data begin output << stderrout.read_nonblock(BUFFER_SIZE) rescue IO::WaitReadable # A read would block, so loop around for another select rescue EOFError # Command has completed, not really an error... break end end # Give Ruby time to clean up the other thread sleep 1 if thread.alive? # We need to kill the process, because killing the thread leaves # the process alive but detached, annoyingly enough. Process.kill("TERM", pid) else exit_code=thread.value sleep 1 end ensure stdin.close if stdin stderrout.close if stderrout end return [output,exit_code] end |
#run_with_timeout2(directory, command, timeout) ⇒ Object
60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 |
# File 'lib/base/timeout.rb', line 60 def run_with_timeout2(directory,command,timeout) # stdout, stderr pipes rout, wout = IO.pipe rerr, werr = IO.pipe output='' error='' exit_code=1 pid = Process.spawn(command, :chdir => directory, :out => wout, :err => werr) begin Timeout.timeout(timeout) do exit_code = Process.wait2(pid) output = rout.readlines.join("\n") error = rerr.readlines.join("\n") end rescue Proces.kill('TERM',pid) output = output + 'timeout occurred.' ensure rout.close rerr.close end [output,exit_code] end |