Class: CapistranoMulticonfigParallel::ChildProcess

Inherits:
Object
  • Object
show all
Includes:
BaseActorHelper
Defined in:
lib/capistrano_multiconfig_parallel/celluloid/child_process.rb

Overview

class that is used to execute the capistrano tasks and it is invoked by the celluloid worker

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from BaseActorHelper

included

Instance Attribute Details

#actor ⇒ Object

Returns the value of attribute actor.



7
8
9
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 7

def actor
  @actor
end

#exit_status ⇒ Object

Returns the value of attribute exit_status.



7
8
9
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 7

def exit_status
  @exit_status
end

#job ⇒ Object

Returns the value of attribute job.



7
8
9
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 7

def job
  @job
end

#job_id ⇒ Object

Returns the value of attribute job_id.



7
8
9
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 7

def job_id
  @job_id
end

#options ⇒ Object

Returns the value of attribute options.



7
8
9
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 7

def options
  @options
end

#pid ⇒ Object

Returns the value of attribute pid.



7
8
9
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 7

def pid
  @pid
end

#process ⇒ Object

Returns the value of attribute process.



7
8
9
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 7

def process
  @process
end

Instance Method Details

#async_exception_handler(*data) ⇒ Object 



113
114
115
116
117
118
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 113

def async_exception_handler(*data)
  log_to_file "Child process for worker #{@job_id} async_exception_handler  disconnected due to error #{data.inspect}"
  io_callback('stderr', data)
  @exit_status = 1
  check_exit_status
end

#check_exit_status ⇒ Object 



58
59
60
61
62
63
64
65
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 58

def check_exit_status
  return if @exit_status.blank?
  @timer.cancel
  @job.exit_status = @exit_status
  print_error_if_exist
  log_to_file("worker #{@job_id} startsnotify finished with exit status #{@exit_status.inspect}")
  @actor.async.notify_finished(@exit_status)
end

#io_callback(io, data) ⇒ Object 



125
126
127
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 125

def io_callback(io, data)
  log_to_file("#{io.upcase} ---- #{data}", job_id: @job_id)
end

#on_exit(status) ⇒ Object 



107
108
109
110
111
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 107

def on_exit(status)
  log_to_file "Child process for worker #{@job_id} on_exit  disconnected due to error #{status.inspect}"
  @exit_status = status.exitstatus
  check_exit_status
end

#on_input_stdin(data) ⇒ Object 



94
95
96
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 94

def on_input_stdin(data)
  io_callback('stdin', data)
end

#on_pid(pid) ⇒ Object 



90
91
92
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 90

def on_pid(pid)
  @pid ||= pid
end

#on_read_stderr(data) ⇒ Object 



102
103
104
105
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 102

def on_read_stderr(data)
  @job.save_stderr_error(data) if development_debug?
  io_callback('stderr', data)
end

#on_read_stdout(data) ⇒ Object 



98
99
100
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 98

def on_read_stdout(data)
  io_callback('stdout', data)
end

#print_error_if_exist ⇒ Object 



67
68
69
70
71
72
73
74
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 67

def print_error_if_exist
  return unless development_debug?
  [@job.stderr_buffer].each do |buffer|
    buffer.rewind
    data = buffer.read
    log_output_error(nil, 'stderr', "Child process for worker #{@job_id} died for reason: #{data}") if data.present?
  end
end

#process_finalizer ⇒ Object 



53
54
55
56
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 53

def process_finalizer
  EM.stop if EM.reactor_running?
  terminate
end

#run_event_machine ⇒ Object 



37
38
39
40
41
42
43
44
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 37

def run_event_machine
  EM.run do
    EM.next_tick do
      start_async_deploy
    end
    setup_periodic_timer
  end
end

#setup_attributes ⇒ Object 



24
25
26
27
28
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 24

def setup_attributes
  @actor = @options.fetch(:actor, nil)
  @job_id = @job.id
  @exit_status = nil
end

#setup_em_error_handler ⇒ Object 



30
31
32
33
34
35
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 30

def setup_em_error_handler
  EM.error_handler do|exception|
    log_error(exception, job_id: @job_id, output: 'stderr')
    EM.stop
  end
end

#setup_periodic_timer ⇒ Object 



46
47
48
49
50
51
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 46

def setup_periodic_timer
  @timer = EM::PeriodicTimer.new(0.1) do
    check_exit_status
    @timer.cancel if @exit_status.present?
  end
end

#start_async_deploy ⇒ Object 



76
77
78
79
80
81
82
83
84
85
86
87
88
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 76

def start_async_deploy
  RightScale::RightPopen.popen3_async(
    @cmd,
    target: self,
    environment: @options.fetch(:environment, nil),
    pid_handler: :on_pid,
    input: :on_input_stdin,
    stdout_handler: :on_read_stdout,
    stderr_handler: :on_read_stderr,
    watch_handler: :watch_handler,
    async_exception_handler: :async_exception_handler,
    exit_handler: :on_exit)
end

#start_running ⇒ Object 



18
19
20
21
22
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 18

def start_running
  setup_attributes
  run_event_machine
  setup_em_error_handler
end

#watch_handler(process) ⇒ Object 



120
121
122
123
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 120

def watch_handler(process)
  @process ||= process
  check_exit_status
end

#work(job, cmd, options = {}) ⇒ Object 



11
12
13
14
15
16
 
# File 'lib/capistrano_multiconfig_parallel/celluloid/child_process.rb', line 11

def work(job, cmd, options = {})
  @options = options
  @job = job
  @cmd = cmd
  start_running
end