mirror of
https://github.com/puma/puma.git
synced 2022-11-09 13:48:40 -05:00
Do not close the pipe sockets when retrying
This commit is contained in:
parent
28d181bfe8
commit
74ea16df7f
1 changed files with 10 additions and 2 deletions
|
@ -18,7 +18,9 @@ module Puma
|
||||||
@sockets = [@ready]
|
@sockets = [@ready]
|
||||||
end
|
end
|
||||||
|
|
||||||
def run
|
private
|
||||||
|
|
||||||
|
def run_internal
|
||||||
sockets = @sockets
|
sockets = @sockets
|
||||||
|
|
||||||
while true
|
while true
|
||||||
|
@ -95,6 +97,12 @@ module Puma
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
end
|
||||||
|
|
||||||
|
public
|
||||||
|
|
||||||
|
def run
|
||||||
|
run_internal
|
||||||
ensure
|
ensure
|
||||||
@trigger.close
|
@trigger.close
|
||||||
@ready.close
|
@ready.close
|
||||||
|
@ -104,7 +112,7 @@ module Puma
|
||||||
@thread = Thread.new {
|
@thread = Thread.new {
|
||||||
while true
|
while true
|
||||||
begin
|
begin
|
||||||
run
|
run_internal
|
||||||
break
|
break
|
||||||
rescue StandardError => e
|
rescue StandardError => e
|
||||||
STDERR.puts "Error in reactor loop escaped: #{e.message} (#{e.class})"
|
STDERR.puts "Error in reactor loop escaped: #{e.message} (#{e.class})"
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue