Updated puma example using shared socket.

Author: ioquatix

examples/puma/application.rb

@@ -4,30 +4,40 @@
 require "async/container"
 require "console"
 
+require "io/endpoint/host_endpoint"
+require "io/endpoint/bound_endpoint"
+
 # Console.logger.debug!
 
 class Application < Async::Container::Controller
+	def endpoint
+		IO::Endpoint.tcp("0.0.0.0", 9292)
+	end
+	
+	def bound_socket
+		bound = endpoint.bound
+		
+		bound.sockets.each do |socket|
+			socket.listen(Socket::SOMAXCONN)
+		end
+		
+		return bound
+	end
+	
 	def setup(container)
+		@bound = bound_socket
+		
 		container.spawn(name: "Web", restart: true) do |instance|
-			# Replace the current process with Puma:
-			# instance.exec("bundle", "exec", "puma", "-C", "puma.rb", ready: false)
+			env = ENV.to_h
 
-			# Manage a child process of puma / puma workers:
-			pid = ::Process.spawn("puma", "-C", "puma.rb")
-			
-			instance.ready!
-			
-			begin
-				status = ::Process.wait2(pid)
-			rescue Async::Container::Hangup
-				Console.warn(self, "Restarting puma...")
-				::Process.kill("USR1", pid)
-				retry
-			ensure
-				::Process.kill("TERM", pid)
+			@bound.sockets.each_with_index do |socket, index|
+				env["PUMA_INHERIT_#{index}"] = "#{socket.fileno}:tcp://0.0.0.0:9292"
 			end
+			
+			instance.exec(env, "bundle", "exec", "puma", "-C", "puma.rb", ready: false)
 		end
 	end
 end
 
-Application.new.run
+application = Application.new
+application.run

examples/puma/gems.locked

@@ -19,6 +19,7 @@ GEM
     fiber-local (1.1.0)
       fiber-storage
     fiber-storage (1.0.0)
+    io-endpoint (0.14.0)
     io-event (1.7.5)
     json (2.9.1)
     nio4r (2.7.4)
@@ -32,6 +33,7 @@ PLATFORMS
 
 DEPENDENCIES
   async-container!
+  io-endpoint
   puma
   rack (~> 3)
 

examples/puma/gems.rb

@@ -1,6 +1,7 @@
 source "https://rubygems.org"
 
 gem "async-container", path: "../.."
+gem "io-endpoint"
 
 gem "puma"
 gem "rack", "~> 3"