More logging.

Author: ioquatix

lib/async/container/forked.rb

@@ -260,7 +260,6 @@ def wait(timeout = 0.1)
 				end
 			end
 
-			
 			# Start a named child process and execute the provided block in it.
 			# @parameter name [String] The name (title) of the child process.
 			# @parameter block [Proc] The block to execute in the child process.

lib/async/container/generic.rb

@@ -179,10 +179,13 @@ def spawn(name: nil, restart: false, key: nil, health_check_timeout: nil, &block
 
 				fiber do
 					while @running
-						child = self.start(name, &block)
+						Console.info(self, "Starting child...", child: {key: key, name: name, restart: restart, health_check_timeout: health_check_timeout}, statistics: @statistics)
 
+						child = self.start(name, &block)
 						state = insert(key, child)
 
+						Console.info(self, "Started child.", child: child, spawn: {key: key, restart: restart, health_check_timeout: health_check_timeout}, statistics: @statistics)
+						
 						# If a health check is specified, we will monitor the child process and terminate it if it does not update its state within the specified time.
 						if health_check_timeout
 							age_clock = state[:age] = Clock.start

lib/async/container/group.rb

@@ -183,7 +183,7 @@ def stop(graceful = true, interrupt_timeout: INTERRUPT_TIMEOUT, terminate_timeou
 					self.wait_for_exit(clock, interrupt_timeout)
 				end
 
-				if terminate_timeout
+				if terminate_timeout and self.any?
 					clock = Async::Clock.start
 
 					# If the children are still running, terminate them:
@@ -231,8 +231,8 @@ def wait_for(channel)
 			protected
 
 			def wait_for_children(duration = nil)
-				# This log is a big noisy and doesn't really provide a lot of useful information.
-				# Console.debug(self, "Waiting for children...", duration: duration, running: @running)
+				# This log is a bit noisy and doesn't really provide a lot of useful information:
+				Console.debug(self, "Waiting for children...", duration: duration, running: @running)
 
 				unless @running.empty?
 					# Maybe consider using a proper event loop here:

lib/async/container/statistics.rb

@@ -56,6 +56,24 @@ def << other
 				@restarts += other.restarts
 				@failures += other.failures
 			end
+			
+			# Generate a hash representation of the statistics.
+			#
+			# @returns [Hash] The statistics as a hash.
+			def as_json(...)
+				{
+					spawns: @spawns,
+					restarts: @restarts,
+					failures: @failures,
+				}
+			end
+			
+			# Generate a JSON representation of the statistics.
+			#
+			# @returns [String] The statistics as JSON.
+			def to_json(...)
+				as_json.to_json(...)
+			end
 		end
 	end
 end

releases.md

@@ -1,5 +1,10 @@
 # Releases
 
+## Unreleased
+
+  - Add log for starting child, including container statistics.
+  - Don't try to (log) "terminate 0 child processes" if there are none.
+
 ## v0.27.2
 
   - More logging, especially around failure cases.