Log caller if blocked on wait.

Author: ioquatix

lib/async/container/forked.rb

@@ -235,7 +235,7 @@ def restart!
 				# @returns [::Process::Status] The process exit status.
 				def wait(timeout = 0.1)
 					if @pid && @status.nil?
-						Console.debug(self, "Waiting for process to exit...", pid: @pid)
+						Console.debug(self, "Waiting for process to exit...", child: {process_id: @pid}, timeout: timeout)
 
 						_, @status = ::Process.wait2(@pid, ::Process::WNOHANG)
 
@@ -245,7 +245,7 @@ def wait(timeout = 0.1)
 							_, @status = ::Process.wait2(@pid, ::Process::WNOHANG)
 
 							if @status.nil?
-								Console.warn(self) {"Process #{@pid} is blocking, sending kill signal..."}
+								Console.warn(self, "Process is blocking, sending kill signal...", child: {process_id: @pid}, caller: caller_locations, timeout: timeout)
 								self.kill!
 
 								# Wait for the process to exit:
@@ -254,7 +254,7 @@ def wait(timeout = 0.1)
 						end
 					end
 
-					Console.debug(self, "Process exited.", pid: @pid, status: @status)
+					Console.debug(self, "Process exited.", child: {process_id: @pid, status: @status})
 
 					return @status
 				end

lib/async/container/threaded.rb

@@ -222,17 +222,19 @@ def restart!
 				# @returns [Status]
 				def wait(timeout = 0.1)
 					if @waiter
-						Console.debug(self, "Waiting for thread to exit...", timeout: timeout)
+						Console.debug(self, "Waiting for thread to exit...", child: {thread_id: @thread.object_id}, timeout: timeout)
 
 						unless @waiter.join(timeout)
-							Console.warn(self) {"Thread #{@thread} is blocking, sending kill signal..."}
+							Console.warn(self, "Thread is blocking, sending kill signal...", child: {thread_id: @thread.object_id}, caller: caller_locations, timeout: timeout)
 							self.kill!
 							@waiter.join
 						end
 
 						@waiter = nil
 					end
 
+					Console.debug(self, "Thread exited.", child: {thread_id: @thread.object_id, status: @status})
+					
 					return @status
 				end
 

releases.md

@@ -1,5 +1,9 @@
 # Releases
 
+## Unreleased
+
+  - Log caller and timeout when waiting on a child instance to exit, if it blocks.
+
 ## v0.27.0
 
   - Increased default interrupt timeout and terminate timeout to 10 seconds each.