mirror of
https://github.com/puma/puma.git
synced 2022-11-09 13:48:40 -05:00
de632261ac
* Rename Puma::Cluster::{Worker => WorkerHandle}
This class represents a worker from the perspective of the puma master
process. It provides methods for controlling the process, but doesn't
contain the logic actually executed by the worker.
In preparation for creating a new class that encapsulates the worker
logic, we're renaming this one to WorkerHandle.
* Extract Puma::Cluster::WorkerHandle to a separate file
* Move worker functionality to new class
Before, all functionality of the worker processes was defined in the
Cluster class. In preparation for making it possible to start worker
processes outside of the context of a Cluster instance, we move the
worker functionality into a new class.
This has the additional benefit of delineating exactly the dependencies
of the worker processes, namely the Launcher, options hash, and the
pipes used for inter-process communication.
* Extract nakayoshi_gc to Puma::Util
* Add comment to describe Puma::Cluster::WorkerHandle
* Remove options from Worker constructor
The instance varaible @options can be derived from the @launcher
83 lines
2 KiB
Ruby
83 lines
2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
module Puma
|
|
class Cluster < Runner
|
|
# 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 Puma::Cluster::Worker.
|
|
class WorkerHandle
|
|
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
|
|
end
|
|
|
|
attr_reader :index, :pid, :phase, :signal, :last_checkin, :last_status, :started_at
|
|
|
|
# @version 5.0.0
|
|
attr_writer :pid, :phase
|
|
|
|
def booted?
|
|
@stage == :booted
|
|
end
|
|
|
|
def boot!
|
|
@last_checkin = Time.now
|
|
@stage = :booted
|
|
end
|
|
|
|
def term?
|
|
@term
|
|
end
|
|
|
|
def ping!(status)
|
|
@last_checkin = Time.now
|
|
require 'json'
|
|
@last_status = JSON.parse(status, symbolize_names: true)
|
|
end
|
|
|
|
# @see Puma::Cluster#check_workers
|
|
# @version 5.0.0
|
|
def ping_timeout
|
|
@last_checkin +
|
|
(booted? ?
|
|
@options[:worker_timeout] :
|
|
@options[:worker_boot_timeout]
|
|
)
|
|
end
|
|
|
|
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
|
|
|
|
def kill
|
|
@signal = 'KILL'
|
|
term
|
|
end
|
|
|
|
def hup
|
|
Process.kill "HUP", @pid
|
|
rescue Errno::ESRCH
|
|
end
|
|
end
|
|
end
|
|
end
|