Object
# File lib/openshift-origin-node/utils/upgrade_progress.rb, line 53 def complete?(marker) File.exists?(marker_path(marker)) end
# File lib/openshift-origin-node/utils/upgrade_progress.rb, line 63 def done globs = %(.upgrade_complete*) globs.each do |glob| Dir.glob(File.join(gear_home, 'app-root', 'runtime', glob)).each do |entry| FileUtils.rm_f(entry) end end end
# File lib/openshift-origin-node/utils/upgrade_progress.rb, line 49 def incomplete?(marker) not complete?(marker) end
# File lib/openshift-origin-node/utils/upgrade_progress.rb, line 77 def log(message) @buffer << message message end
# File lib/openshift-origin-node/utils/upgrade_progress.rb, line 57 def mark_complete(marker) IO.write(marker_path(marker), '') log "Marking step #{marker} complete" @steps[marker][:status] = :complete end
# File lib/openshift-origin-node/utils/upgrade_progress.rb, line 73 def marker_path(marker) File.join(gear_home, 'app-root', 'runtime', ".upgrade_complete_#{marker}") end
# File lib/openshift-origin-node/utils/upgrade_progress.rb, line 82 def report @buffer.join("\n") end
# File lib/openshift-origin-node/utils/upgrade_progress.rb, line 19 def step(name) unless @steps.has_key?(name) @steps[name] = { :status => complete?(name) ? :complete : :incomplete, :errors => [], :context => {} } end step = @steps[name] if incomplete?(name) begin yield(step[:context], step[:errors]) rescue OpenShift::Runtime::Utils::ShellExecutionException => e step[:errors] << "Unhandled shell exception performing step: #{e.message}\nreturn code: #{e.rc}\nstdout: #{e.stdout}\nstderr: #{e.stderr}" raise e rescue => e step[:errors] << "Unhandled exception performing step: #{e.message}\n#{e.backtrace.join("\n")}" raise e end if not step[:errors].empty? raise "Errors encountered executing step #{name}" end mark_complete(name) end end
Generated with the Darkfish Rdoc Generator 2.