Class: ParallelServer::Prefork

Inherits:
Object
  • Object
show all
Defined in:
lib/parallel_server/prefork.rb

Defined Under Namespace

Classes: Child, Conversation

Constant Summary collapse

DEFAULT_MIN_PROCESSES = 
5
DEFAULT_MAX_PROCESSES = 
20
DEFAULT_MAX_THREADS = 
1
DEFAULT_STANDBY_THREADS = 
5
DEFAULT_MAX_IDLE = 
10
DEFAULT_MAX_USE = 
1000
DEFAULT_WATCHDOG_TIMER = 
600
DEFAULT_WATCHDOG_SIGNAL = 
'TERM'

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(host = nil, port, opts = {}) ⇒ Prefork #initialize(socket, opts = {}) ⇒ Prefork #initialize(sockets, opts = {}) ⇒ Prefork

Returns a new instance of Prefork.

Overloads:

  • #initialize(host = nil, port, opts = {}) ⇒ Prefork

    Options Hash (opts):

    • :min_processes (Integer) — default: 5 —

      minimum processes

    • :max_processes (Integer) — default: 20 —

      maximum processes

    • :max_idle (Integer) — default: 10 —

      child process exits if max_idle seconds is expired

    • :max_use (Integer) — default: 1000 —

      child process exits if it is connected max_use times.

    • :max_threads (Integer) — default: 1 —

      maximum threads per process

    • :standby_threads (Integer) — default: 5 —

      keep free processes or threads

    • :listen_backlog (Integer) — default: nil —

      listen backlog

    • :watchdog_timer (Integer) — default: 600 —

      watchdog timer

    • :watchdog_signal (Integer) — default: 'TERM' —

      this signal is sent when watchdog timer expired.

    • :on_start (#call) — default: nil —

      object#call() is invoked when child process start. This is called in child process.

    • :on_reload (#call) — default: nil —

      object#call(hash) is invoked when reload. This is called in child process.

    • :on_child_start (#call) — default: nil —

      object#call(pid) is invoked when child process exit. This is call in parent process.

    • :on_child_exit (#call) — default: nil —

      object#call(pid, status) is invoked when child process exit. This is call in parent process.

  • #initialize(socket, opts = {}) ⇒ Prefork

    Options Hash (opts):

    • :min_processes (Integer) — default: 5 —

      minimum processes

    • :max_processes (Integer) — default: 20 —

      maximum processes

    • :max_idle (Integer) — default: 10 —

      child process exits if max_idle seconds is expired

    • :max_use (Integer) — default: 1000 —

      child process exits if it is connected max_use times.

    • :max_threads (Integer) — default: 1 —

      maximum threads per process

    • :standby_threads (Integer) — default: 5 —

      keep free processes or threads

    • :listen_backlog (Integer) — default: nil —

      listen backlog

    • :watchdog_timer (Integer) — default: 600 —

      watchdog timer

    • :watchdog_signal (Integer) — default: 'TERM' —

      this signal is sent when watchdog timer expired.

    • :on_start (#call) — default: nil —

      object#call() is invoked when child process start. This is called in child process.

    • :on_reload (#call) — default: nil —

      object#call(hash) is invoked when reload. This is called in child process.

    • :on_child_start (#call) — default: nil —

      object#call(pid) is invoked when child process exit. This is call in parent process.

    • :on_child_exit (#call) — default: nil —

      object#call(pid, status) is invoked when child process exit. This is call in parent process.

  • #initialize(sockets, opts = {}) ⇒ Prefork

    Options Hash (opts):

    • :min_processes (Integer) — default: 5 —

      minimum processes

    • :max_processes (Integer) — default: 20 —

      maximum processes

    • :max_idle (Integer) — default: 10 —

      child process exits if max_idle seconds is expired

    • :max_use (Integer) — default: 1000 —

      child process exits if it is connected max_use times.

    • :max_threads (Integer) — default: 1 —

      maximum threads per process

    • :standby_threads (Integer) — default: 5 —

      keep free processes or threads

    • :listen_backlog (Integer) — default: nil —

      listen backlog

    • :watchdog_timer (Integer) — default: 600 —

      watchdog timer

    • :watchdog_signal (Integer) — default: 'TERM' —

      this signal is sent when watchdog timer expired.

    • :on_start (#call) — default: nil —

      object#call() is invoked when child process start. This is called in child process.

    • :on_reload (#call) — default: nil —

      object#call(hash) is invoked when reload. This is called in child process.

    • :on_child_start (#call) — default: nil —

      object#call(pid) is invoked when child process exit. This is call in parent process.

    • :on_child_exit (#call) — default: nil —

      object#call(pid, status) is invoked when child process exit. This is call in parent process.



44
45
46
47
48
49
50
51
52
53
 
# File 'lib/parallel_server/prefork.rb', line 44

def initialize(*args)
  @sockets, @host, @port, @opts = parse_args(*args)
  set_variables_from_opts
  @from_child = {}             # IO(r) => pid
  @to_child = {}               # IO(r) => IO(w)
  @child_status = {}           # IO(r) => Hash
  @children = []               # pid
  @loop = true
  @sockets_created = false
end

Instance Attribute Details

#child_status ⇒ Object (readonly)

Returns the value of attribute child_status.



16
17
18
 
# File 'lib/parallel_server/prefork.rb', line 16

def child_status
  @child_status
end

Instance Method Details

#detach_children ⇒ void 



107
108
109
110
111
112
113
 
# File 'lib/parallel_server/prefork.rb', line 107

def detach_children
  t = Time.now + 5
  talk_to_children(detach: true)
  while Time.now < t && @child_status.values.any?{|s| s[:status] == :run}
    watch_children
  end
end

#reload(host = nil, port, opts = {}) ⇒ void #reload(socket, opts = {}) ⇒ void #reload(sockets, opts = {}) ⇒ void

This method returns an undefined value.

Overloads:

  • #reload(host = nil, port, opts = {}) ⇒ void

    Options Hash (opts):

    • :min_processes (Integer) — default: 5 —

      minimum processes

    • :max_processes (Integer) — default: 20 —

      maximum processes

    • :max_idle (Integer) — default: 10 —

      child process exits if max_idle seconds is expired

    • :max_use (Integer) — default: 1000 —

      child process exits if it is connected max_use times.

    • :max_threads (Integer) — default: 1 —

      maximum threads per process

    • :standby_threads (Integer) — default: 5 —

      keep free processes or threads

    • :listen_backlog (Integer) — default: nil —

      listen backlog

    • :watchdog_timer (Integer) — default: 600 —

      watchdog timer

    • :watchdog_signal (Integer) — default: 'TERM' —

      this signal is sent when watchdog timer expired.

    • :on_start (#call) — default: nil —

      object#call() is invoked when child process start. This is called in child process.

    • :on_reload (#call) — default: nil —

      object#call(hash) is invoked when reload. This is called in child process.

    • :on_child_start (#call) — default: nil —

      object#call(pid) is invoked when child process exit. This is call in parent process.

    • :on_child_exit (#call) — default: nil —

      object#call(pid, status) is invoked when child process exit. This is call in parent process.

  • #reload(socket, opts = {}) ⇒ void

    Options Hash (opts):

    • :min_processes (Integer) — default: 5 —

      minimum processes

    • :max_processes (Integer) — default: 20 —

      maximum processes

    • :max_idle (Integer) — default: 10 —

      child process exits if max_idle seconds is expired

    • :max_use (Integer) — default: 1000 —

      child process exits if it is connected max_use times.

    • :max_threads (Integer) — default: 1 —

      maximum threads per process

    • :standby_threads (Integer) — default: 5 —

      keep free processes or threads

    • :listen_backlog (Integer) — default: nil —

      listen backlog

    • :watchdog_timer (Integer) — default: 600 —

      watchdog timer

    • :watchdog_signal (Integer) — default: 'TERM' —

      this signal is sent when watchdog timer expired.

    • :on_start (#call) — default: nil —

      object#call() is invoked when child process start. This is called in child process.

    • :on_reload (#call) — default: nil —

      object#call(hash) is invoked when reload. This is called in child process.

    • :on_child_start (#call) — default: nil —

      object#call(pid) is invoked when child process exit. This is call in parent process.

    • :on_child_exit (#call) — default: nil —

      object#call(pid, status) is invoked when child process exit. This is call in parent process.

  • #reload(sockets, opts = {}) ⇒ void

    Options Hash (opts):

    • :min_processes (Integer) — default: 5 —

      minimum processes

    • :max_processes (Integer) — default: 20 —

      maximum processes

    • :max_idle (Integer) — default: 10 —

      child process exits if max_idle seconds is expired

    • :max_use (Integer) — default: 1000 —

      child process exits if it is connected max_use times.

    • :max_threads (Integer) — default: 1 —

      maximum threads per process

    • :standby_threads (Integer) — default: 5 —

      keep free processes or threads

    • :listen_backlog (Integer) — default: nil —

      listen backlog

    • :watchdog_timer (Integer) — default: 600 —

      watchdog timer

    • :watchdog_signal (Integer) — default: 'TERM' —

      this signal is sent when watchdog timer expired.

    • :on_start (#call) — default: nil —

      object#call() is invoked when child process start. This is called in child process.

    • :on_reload (#call) — default: nil —

      object#call(hash) is invoked when reload. This is called in child process.

    • :on_child_start (#call) — default: nil —

      object#call(pid) is invoked when child process exit. This is call in parent process.

    • :on_child_exit (#call) — default: nil —

      object#call(pid, status) is invoked when child process exit. This is call in parent process.



91
92
93
 
# File 'lib/parallel_server/prefork.rb', line 91

def reload(*args)
  @reload_args = parse_args(*args)
end

#start {|sock, addr, child| ... } ⇒ void

This method returns an undefined value.

Yields:

  • (sock, addr, child)

Yield Parameters:



60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
 
# File 'lib/parallel_server/prefork.rb', line 60

def start(&block)
  raise 'block required' unless block
  @block = block
  unless @sockets
    @sockets = create_server_socket(@host, @port, @listen_backlog)
    @sockets_created = true
  end
  @reload_args = nil
  while @loop
    do_reload if @reload_args
    watch_children
    adjust_children
  end
ensure
  @sockets.each{|s| s.close rescue nil} if @sockets && @sockets_created
  @to_child.values.each{|s| s.close rescue nil}
  @to_child.clear
  Timeout.timeout(1){wait_all_children} rescue Thread.new{wait_all_children}
end

#stop ⇒ void 



96
97
98
 
# File 'lib/parallel_server/prefork.rb', line 96

def stop
  @loop = false
end

#stop! ⇒ void 



101
102
103
104
 
# File 'lib/parallel_server/prefork.rb', line 101

def stop!
  Process.kill 'TERM', *@children rescue nil
  @loop = false
end