Fire on_booted after server starts

History.md

@@ -5,6 +5,7 @@
 
 * Bugfixes
   * Cleanup daemonization in rc.d script (#2409)
+  * Fire `on_booted` after server starts
 
 * Refactor
   * Extract req/resp methods to new request.rb from server.rb (#2419)

lib/puma/cluster.rb

@@ -395,9 +395,9 @@ def run
         stop
       end
 
-      @launcher.events.fire_on_booted!
-
       begin
+        booted = false
+
         while @status == :run
           begin
             if @phased_restart
@@ -438,6 +438,10 @@ def run
                 when "p"
                   w.ping!(result.sub(/^\d+/,'').chomp)
                   @launcher.events.fire(:ping!, w)
+                  if !booted && @workers.none? {|worker| worker.last_status.empty?}
+                    @launcher.events.fire_on_booted!
+                    booted = true
+                  end
                 end
               else
                 log "! Out-of-sync worker list, no #{pid} worker"

lib/puma/cluster/worker.rb

@@ -103,23 +103,25 @@ def run
           return
         end
 
-        Thread.new(@worker_write) do |io|
-          Puma.set_thread_name "stat payload"
-
-          while true
-            sleep Const::WORKER_CHECK_INTERVAL
-            begin
-              require 'json'
-              io << "p#{Process.pid}#{server.stats.to_json}\n"
-            rescue IOError
-              Thread.current.purge_interrupt_queue if Thread.current.respond_to? :purge_interrupt_queue
-              break
+        while restart_server.pop
+          server_thread = server.run
+          stat_thread ||= Thread.new(@worker_write) do |io|
+            Puma.set_thread_name "stat payload"
+
+            while true
+              begin
+                require 'json'
+                io << "p#{Process.pid}#{server.stats.to_json}\n"
+              rescue IOError
+                Thread.current.purge_interrupt_queue if Thread.current.respond_to? :purge_interrupt_queue
+                break
+              end
+              sleep Const::WORKER_CHECK_INTERVAL
             end
           end
+          server_thread.join
         end
 
-        server.run.join while restart_server.pop
-
         # Invoke any worker shutdown hooks so they can prevent the worker
         # exiting until any background operations are completed
         @launcher.config.run_hooks :before_worker_shutdown, index, @launcher.events

lib/puma/single.rb

@@ -55,10 +55,11 @@ def run
       log "Use Ctrl-C to stop"
       redirect_io
 
+      server_thread = server.run
       @launcher.events.fire_on_booted!
 
       begin
-        server.run.join
+        server_thread.join
       rescue Interrupt
         # Swallow it
       end

test/test_cli.rb

@@ -133,8 +133,6 @@ def test_control_clustered
 
     assert_equal 2, status["workers"]
 
-    # wait until the first status ping has come through
-    sleep 6
     s = UNIXSocket.new @tmp_path
     s << "GET /stats HTTP/1.0\r\n\r\n"
     body = s.read
@@ -144,6 +142,7 @@ def test_control_clustered
   ensure
     if UNIX_SKT_EXIST && HAS_FORK
       cli.launcher.stop
+      t.join
 
       done = nil
       until done
@@ -152,7 +151,6 @@ def test_control_clustered
         done = log[/ - Goodbye!/]
       end
 
-      t.join
       $debugging_hold = false
     end
   end