Class: DRbQS::Server::TaskHistory

Inherits:
History
  • Object
show all
Defined in:
lib/drbqs/server/history.rb

Constant Summary

Constants included from Misc

Misc::STRINGS_FOR_KEY

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods inherited from History

#each, #events, #number_of_events, #size

Methods included from Misc

create_logger, create_uri, output_error, process_running_normally?, random_key, time_to_history_string, time_to_history_string2

Constructor Details

#initialize ⇒ TaskHistory

Returns a new instance of TaskHistory.



36
37
38
39
 
# File 'lib/drbqs/server/history.rb', line 36

def initialize
  super
  @finished_task_number = 0
end

Instance Attribute Details

#finished_task_number ⇒ Object (readonly)

Returns the value of attribute finished_task_number.



34
35
36
 
# File 'lib/drbqs/server/history.rb', line 34

def finished_task_number
  @finished_task_number
end

Instance Method Details

#log_strings ⇒ Object 



48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
 
# File 'lib/drbqs/server/history.rb', line 48

def log_strings
  s = ''
  each do |task_id, events|
    s << "Task #{task_id}\n"
    events.each do |ev|
      case ev[1]
      when :add
        s << "  #{time_to_history_string(ev[0])}\t#{ev[1]}"
        s << "\t" << ev[2].to_s if ev[2]
        s << "\n"
      when :requeue, :hook
        s << "  #{time_to_history_string(ev[0])}\t#{ev[1]}\n"
      when :calculate, :result
        s << "  #{time_to_history_string(ev[0])}\t#{ev[1]} (node #{ev[2]})\n"
      end
    end
  end
  s
end

#set(id, *args) ⇒ Object 



41
42
43
44
45
46
 
# File 'lib/drbqs/server/history.rb', line 41

def set(id, *args)
  if args[0] == :result
    @finished_task_number += 1
  end
  super(id, *args)
end