Class: Roundhouse::Launcher

Inherits:
Object
  • Object
show all
Includes:
Actor, Util
Defined in:
lib/roundhouse/launcher.rb

Overview

The Launcher is a very simple Actor whose job is to start, monitor and stop the core Actors in Roundhouse. If any of these actors die, the Roundhouse process exits immediately.

Constant Summary

Constants included from Util

Util::EXPIRY

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Util

#fire_event, #hostname, #identity, #logger, #process_nonce, #redis, #want_a_hertz_donut?, #watchdog

Methods included from ExceptionHandler

#handle_exception

Methods included from Actor

included

Constructor Details

#initialize(options) ⇒ Launcher

Returns a new instance of Launcher.



19
20
21
22
23
24
25
26
27
 
# File 'lib/roundhouse/launcher.rb', line 19

def initialize(options)
  @condvar = Celluloid::Condition.new
  @manager = Roundhouse::Manager.new_link(@condvar, options)
  @poller = Roundhouse::Scheduled::Poller.new_link
  @fetcher = Roundhouse::Fetcher.new_link(@manager, options)
  @manager.fetcher = @fetcher
  @done = false
  @options = options
end

Instance Attribute Details

#fetcher ⇒ Object (readonly)

Returns the value of attribute fetcher.



17
18
19
 
# File 'lib/roundhouse/launcher.rb', line 17

def fetcher
  @fetcher
end

#manager ⇒ Object (readonly)

Returns the value of attribute manager.



17
18
19
 
# File 'lib/roundhouse/launcher.rb', line 17

def manager
  @manager
end

#poller ⇒ Object (readonly)

Returns the value of attribute poller.



17
18
19
 
# File 'lib/roundhouse/launcher.rb', line 17

def poller
  @poller
end

Instance Method Details

#actor_died(actor, reason) ⇒ Object 



29
30
31
32
33
34
35
36
 
# File 'lib/roundhouse/launcher.rb', line 29

def actor_died(actor, reason)
  # https://github.com/mperham/sidekiq/issues/2057#issuecomment-66485477
  return if @done || !reason

  Roundhouse.logger.warn("Roundhouse died due to the following error, cannot recover, process exiting")
  handle_exception(reason)
  exit(1)
end

#run ⇒ Object 



38
39
40
41
42
43
44
45
 
# File 'lib/roundhouse/launcher.rb', line 38

def run
  watchdog('Launcher#run') do
    manager.async.start
    poller.async.poll(true)

    start_heartbeat
  end
end

#stop ⇒ Object 



47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
 
# File 'lib/roundhouse/launcher.rb', line 47

def stop
  watchdog('Launcher#stop') do
    logger.debug 'Stopping launcher'
    @done = true
    Roundhouse::Fetcher.done!
    fetcher.terminate if fetcher.alive?
    poller.terminate if poller.alive?

    manager.async.stop(:shutdown => true, :timeout => @options[:timeout])
    @condvar.wait
    manager.terminate

    # Requeue everything in case there was a worker who grabbed work while stopped
    # This call is a no-op in Roundhouse but necessary for Roundhouse Pro.
    Roundhouse::Fetcher.strategy.bulk_requeue([], @options)

    stop_heartbeat
  end
end