123456789_123456789_123456789_123456789_123456789_

Class: Puma::Cluster::WorkerHandle

Do not use. This class is for internal use only.
Relationships & Source Files
Inherits: Object
Defined in: lib/puma/cluster/worker_handle.rb

Overview

This class represents a worker process from the perspective of the puma master process. It contains information about the process and its health and it exposes methods to control the process via IPC. It does not include the actual logic executed by the worker process itself. For that, see Worker.

Constant Summary

Class Method Summary

Instance Attribute Summary

Instance Method Summary

Constructor Details

.new(idx, pid, phase, options) ⇒ WorkerHandle

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 16

def initialize(idx, pid, phase, options)
  @index = idx
  @pid = pid
  @phase = phase
  @stage = :started
  @signal = "TERM"
  @options = options
  @first_term_sent = nil
  @started_at = Time.now
  @last_checkin = Time.now
  @last_status = {}
  @term = false
  @worker_max = Array.new WORKER_MAX_KEYS.length, 0
end

Instance Attribute Details

#booted?Boolean (readonly)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 36

def booted?
  @stage == :booted
end

#index (readonly)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 31

attr_reader :index, :pid, :phase, :signal, :last_checkin, :last_status, :started_at

#last_checkin (readonly)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 31

attr_reader :index, :pid, :phase, :signal, :last_checkin, :last_status, :started_at

#last_status (readonly)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 31

attr_reader :index, :pid, :phase, :signal, :last_checkin, :last_status, :started_at

#phase (rw)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 31

attr_reader :index, :pid, :phase, :signal, :last_checkin, :last_status, :started_at

#phase=(value) (rw)

Version:

  • 5.0.0

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 34

attr_writer :pid, :phase

#pid (rw)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 31

attr_reader :index, :pid, :phase, :signal, :last_checkin, :last_status, :started_at

#pid=(value) (rw)

Version:

  • 5.0.0

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 34

attr_writer :pid, :phase

#signal (readonly)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 31

attr_reader :index, :pid, :phase, :signal, :last_checkin, :last_status, :started_at

#started_at (readonly)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 31

attr_reader :index, :pid, :phase, :signal, :last_checkin, :last_status, :started_at

#term?Boolean (readonly)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 53

def term?
  @term
end

Instance Method Details

#boot!

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 44

def boot!
  @last_checkin = Time.now
  @stage = :booted
end

#hup

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 121

def hup
  Process.kill "HUP", @pid
rescue Errno::ESRCH
end

#kill

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 116

def kill
  @signal = 'KILL'
  term
end

#ping!(status)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 57

def ping!(status)
  hsh = {}
  k, v = nil, nil
  status.tr('}{"', '').strip.split(", ") do |kv|
    cntr = 0
    kv.split(':') do |t|
      if cntr == 0
        k = t
        cntr = 1
      else
        v = t
      end
    end
    hsh[k.to_sym] = v.to_i
  end

  # check stat max values, we can't signal workers to reset the max values,
  # so we do so here
  WORKER_MAX_KEYS.each_with_index do |key, idx|
    next unless hsh[key]

    if hsh[key] < @worker_max[idx]
      hsh[key] = @worker_max[idx]
    else
      @worker_max[idx] = hsh[key]
    end
  end
  @last_checkin = Time.now
  @last_status = hsh
end

#ping_timeout

See Also:

Version:

  • 5.0.0

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 95

def ping_timeout
  @last_checkin +
    (booted? ?
      @options[:worker_timeout] :
      @options[:worker_boot_timeout]
    )
end

#reset_max

Resets max values to zero. Called whenever Puma::Cluster#stats is called

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 89

def reset_max
  WORKER_MAX_KEYS.length.times { |idx| @worker_max[idx] = 0 }
end

#term (readonly)

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 103

def term
  begin
    if @first_term_sent && (Time.now - @first_term_sent) > @options[:worker_shutdown_timeout]
      @signal = "KILL"
    else
      @term ||= true
      @first_term_sent ||= Time.now
    end
    Process.kill @signal, @pid if @pid
  rescue Errno::ESRCH
  end
end

#term!

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 49

def term!
  @term = true
end

#uptime

[ GitHub ]

  
# File 'lib/puma/cluster/worker_handle.rb', line 40

def uptime
  Time.now - started_at
end