Class: Flydata::Helper::Scheduler

Inherits:
Object
  • Object
show all
Includes:
FlydataCore::Logger
Defined in:
lib/flydata/helper/scheduler.rb

Constant Summary collapse

RUN_INTERVAL =

second

1.0

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(helper_conf, server) ⇒ Scheduler

Returns a new instance of Scheduler.



10
11
12
13
14
15
 
# File 'lib/flydata/helper/scheduler.rb', line 10

def initialize(helper_conf, server)
  @stop_flag = ServerEngine::BlockingFlag.new
  @server = server
  self.logger = server.logger
  reload(helper_conf)
end

Instance Attribute Details

#helper_conf ⇒ Object (readonly)

Returns the value of attribute helper_conf.



17
18
19
 
# File 'lib/flydata/helper/scheduler.rb', line 17

def helper_conf
  @helper_conf
end

#server ⇒ Object (readonly)

Returns the value of attribute server.



17
18
19
 
# File 'lib/flydata/helper/scheduler.rb', line 17

def server
  @server
end

Instance Method Details

#join ⇒ Object 



59
60
61
62
63
64
65
66
 
# File 'lib/flydata/helper/scheduler.rb', line 59

def join
  log_debug("join")
  stop
  if @thread
    @thread.join
    @thread = nil
  end
end

#reload(helper_conf) ⇒ Object 



46
47
48
49
50
 
# File 'lib/flydata/helper/scheduler.rb', line 46

def reload(helper_conf)
  log_info("reload")
  @helper_conf = helper_conf
  update_scheduled_actions
end

#run ⇒ Object 



25
26
27
28
29
30
31
32
33
34
 
# File 'lib/flydata/helper/scheduler.rb', line 25

def run
  until @stop_flag.set?
    run_once
  end
rescue => e
  log_error("unexpected error during running. error:#{e}\n" + e.backtrace.join("\n"))
  retry unless @stop_flag.wait_for_set(5.0)
ensure
  log_debug("finish running")
end

#running? ⇒ Boolean

For debug

Returns:

  • (Boolean) 


70
71
72
 
# File 'lib/flydata/helper/scheduler.rb', line 70

def running?
  !!(@thread and @thread.alive?)
end

#scheduled_actions ⇒ Object 



74
75
76
 
# File 'lib/flydata/helper/scheduler.rb', line 74

def scheduled_actions
  @scheduled_actions.dup
end

#shutdown ⇒ Object 



52
53
54
55
56
57
 
# File 'lib/flydata/helper/scheduler.rb', line 52

def shutdown
  log_info("shutdown")
  stop
  join
  self
end

#start ⇒ Object 



19
20
21
22
23
 
# File 'lib/flydata/helper/scheduler.rb', line 19

def start
  log_info("start")
  @thread = Thread.new(&method(:run))
  self
end

#stop ⇒ Object 



41
42
43
44
 
# File 'lib/flydata/helper/scheduler.rb', line 41

def stop
  log_info("stop")
  @stop_flag.set!
end

#wake ⇒ Object 



36
37
38
39
 
# File 'lib/flydata/helper/scheduler.rb', line 36

def wake
  log_debug("wake")
  @stop_flag.reset!
end