mirror of
https://github.com/ruby/ruby.git
synced 2022-11-09 12:17:21 -05:00
49 lines
1.1 KiB
Ruby
49 lines
1.1 KiB
Ruby
|
require 'rake/private_reader'
|
||
|
|
|
||
|
|
module Rake
|
||
|
|
|
||
|
|
class ThreadHistoryDisplay # :nodoc: all
|
||
|
|
include Rake::PrivateReader
|
||
|
|
|
||
|
|
private_reader :stats, :items, :threads
|
||
|
|
|
||
|
|
def initialize(stats)
|
||
|
|
@stats = stats
|
||
|
|
@items = { :_seq_ => 1 }
|
||
|
|
@threads = { :_seq_ => "A" }
|
||
|
|
end
|
||
|
|
|
||
|
|
def show
|
||
|
|
puts "Job History:"
|
||
|
|
stats.each do |stat|
|
||
|
|
stat[:data] ||= {}
|
||
|
|
rename(stat, :thread, threads)
|
||
|
|
rename(stat[:data], :item_id, items)
|
||
|
|
rename(stat[:data], :new_thread, threads)
|
||
|
|
rename(stat[:data], :deleted_thread, threads)
|
||
|
|
printf("%8d %2s %-20s %s\n",
|
||
|
|
(stat[:time] * 1_000_000).round,
|
||
|
|
stat[:thread],
|
||
|
|
stat[:event],
|
||
|
|
stat[:data].map { |k,v| "#{k}:#{v}" }.join(" "))
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
private
|
||
|
|
|
||
|
|
def rename(hash, key, renames)
|
||
|
|
if hash && hash[key]
|
||
|
|
original = hash[key]
|
||
|
|
value = renames[original]
|
||
|
|
unless value
|
||
|
|
value = renames[:_seq_]
|
||
|
|
renames[:_seq_] = renames[:_seq_].succ
|
||
|
|
renames[original] = value
|
||
|
|
end
|
||
|
|
hash[key] = value
|
||
|
|
end
|
||
|
|
end
|
||
|
|
end
|
||
|
|
|
||
|
|
end
|