Refactor Async.logger -> Console.logger.

Author: ioquatix

examples/container.rb

@@ -4,15 +4,15 @@
 require '../lib/async/container/controller'
 require '../lib/async/container/forked'
 
-Async.logger.debug!
+Console.logger.debug!
 
-Async.logger.debug(self, "Starting up...")
+Console.logger.debug(self, "Starting up...")
 
 controller = Async::Container::Controller.new do |container|
-	Async.logger.debug(self, "Setting up container...")
+	Console.logger.debug(self, "Setting up container...")
 
 	container.run(count: 1, restart: true) do
-		Async.logger.debug(self, "Child process started.")
+		Console.logger.debug(self, "Child process started.")
 
 		while true
 			sleep 1
@@ -22,12 +22,12 @@
 			end
 		end
 	ensure
-		Async.logger.debug(self, "Child process exiting:", $!)
+		Console.logger.debug(self, "Child process exiting:", $!)
 	end
 end
 
 begin
 	controller.run
 ensure
-	Async.logger.debug(controller, "Parent process exiting:", $!)
+	Console.logger.debug(controller, "Parent process exiting:", $!)
 end

guides/getting-started/README.md

@@ -24,7 +24,7 @@ A container represents a set of child processes (or threads) which are doing wor
 ``` ruby
 require 'async/container'
 
-Async.logger.debug!
+Console.logger.debug!
 
 container = Async::Container.new
 
@@ -34,9 +34,9 @@ container.async do |task|
 	task.logger.debug "Waking up!"
 end
 
-Async.logger.debug "Waiting for container..."
+Console.logger.debug "Waiting for container..."
 container.wait
-Async.logger.debug "Finished."
+Console.logger.debug "Finished."
 ```
 
 ## Controllers
@@ -46,13 +46,13 @@ The controller provides the life-cycle management for one or more containers of
 ``` ruby
 require 'async/container'
 
-Async.logger.debug!
+Console.logger.debug!
 
 class Controller < Async::Container::Controller
 	def setup(container)
 		container.async do |task|
 			while true
-				Async.logger.debug("Sleeping...")
+				Console.logger.debug("Sleeping...")
 				task.sleep(1)
 			end
 		end

lib/async/container/controller.rb

@@ -122,9 +122,9 @@ def restart
 				if @container
 					@notify&.restarting!
 
-					Async.logger.debug(self) {"Restarting container..."}
+					Console.logger.debug(self) {"Restarting container..."}
 				else
-					Async.logger.debug(self) {"Starting container..."}
+					Console.logger.debug(self) {"Starting container..."}
 				end
 
 				container = self.create_container
@@ -138,9 +138,9 @@ def restart
 				end
 
 				# Wait for all child processes to enter the ready state.
-				Async.logger.debug(self, "Waiting for startup...")
+				Console.logger.debug(self, "Waiting for startup...")
 				container.wait_until_ready
-				Async.logger.debug(self, "Finished startup.")
+				Console.logger.debug(self, "Finished startup.")
 
 				if container.failed?
 					@notify&.error!($!.to_s)
@@ -154,7 +154,7 @@ def restart
 				old_container = @container
 				@container = container
 
-				Async.logger.debug(self, "Stopping old container...")
+				Console.logger.debug(self, "Stopping old container...")
 				old_container&.stop
 				@notify&.ready!
 			rescue
@@ -168,7 +168,7 @@ def restart
 			def reload
 				@notify&.reloading!
 
-				Async.logger.info(self) {"Reloading container: #{@container}..."}
+				Console.logger.info(self) {"Reloading container: #{@container}..."}
 
 				begin
 					self.setup(@container)
@@ -177,9 +177,9 @@ def reload
 				end
 
 				# Wait for all child processes to enter the ready state.
-				Async.logger.debug(self, "Waiting for startup...")
+				Console.logger.debug(self, "Waiting for startup...")
 				@container.wait_until_ready
-				Async.logger.debug(self, "Finished startup.")
+				Console.logger.debug(self, "Finished startup.")
 
 				if @container.failed?
 					@notify.error!("Container failed!")
@@ -215,7 +215,7 @@ def run
 							begin
 								handler.call
 							rescue SetupError => error
-								Async.logger.error(self) {error}
+								Console.logger.error(self) {error}
 							end
 						else
 							raise

lib/async/container/generic.rb

@@ -119,7 +119,7 @@ def status?(flag)
 			# @returns [Boolean] The children all became ready.
 			def wait_until_ready
 				while true
-					Async.logger.debug(self) do |buffer|
+					Console.logger.debug(self) do |buffer|
 						buffer.puts "Waiting for ready:"
 						@state.each do |child, state|
 							buffer.puts "\t#{child.class}: #{state.inspect}"
@@ -141,7 +141,7 @@ def stop(timeout = true)
 				@group.stop(timeout)
 
 				if @group.running?
-					Async.logger.warn(self) {"Group is still running after stopping it!"}
+					Console.logger.warn(self) {"Group is still running after stopping it!"}
 				end
 			ensure
 				@running = true
@@ -155,7 +155,7 @@ def spawn(name: nil, restart: false, key: nil, &block)
 				name ||= UNNAMED
 
 				if mark?(key)
-					Async.logger.debug(self) {"Reusing existing child for #{key}: #{name}"}
+					Console.logger.debug(self) {"Reusing existing child for #{key}: #{name}"}
 					return false
 				end
 
@@ -176,10 +176,10 @@ def spawn(name: nil, restart: false, key: nil, &block)
 						end
 
 						if status.success?
-							Async.logger.info(self) {"#{child} exited with #{status}"}
+							Console.logger.info(self) {"#{child} exited with #{status}"}
 						else
 							@statistics.failure!
-							Async.logger.error(self) {status}
+							Console.logger.error(self) {status}
 						end
 
 						if restart
@@ -189,7 +189,7 @@ def spawn(name: nil, restart: false, key: nil, &block)
 						end
 					end
 				# ensure
-				# 	Async.logger.error(self) {$!} if $!
+				# 	Console.logger.error(self) {$!} if $!
 				end.resume
 
 				return true

lib/async/container/group.rb

@@ -78,7 +78,7 @@ def wait
 			# Interrupt all running processes.
 			# This resumes the controlling fiber with an instance of {Interrupt}.
 			def interrupt
-				Async.logger.debug(self, "Sending interrupt to #{@running.size} running processes...")
+				Console.logger.debug(self, "Sending interrupt to #{@running.size} running processes...")
 				@running.each_value do |fiber|
 					fiber.resume(Interrupt)
 				end
@@ -87,7 +87,7 @@ def interrupt
 			# Terminate all running processes.
 			# This resumes the controlling fiber with an instance of {Terminate}.
 			def terminate
-				Async.logger.debug(self, "Sending terminate to #{@running.size} running processes...")
+				Console.logger.debug(self, "Sending terminate to #{@running.size} running processes...")
 				@running.each_value do |fiber|
 					fiber.resume(Terminate)
 				end

lib/async/container/notify/pipe.rb

@@ -38,7 +38,7 @@ def self.open!(environment = ENV)
 						self.new(::IO.for_fd(descriptor.to_i))
 					end
 				rescue Errno::EBADF => error
-					Async.logger.error(self) {error}
+					Console.logger.error(self) {error}
 
 					return nil
 				end

lib/async/container/process.rb

@@ -91,7 +91,7 @@ def self.fork(**options)
 						rescue Interrupt
 							# Graceful exit.
 						rescue Exception => error
-							Async.logger.error(self) {error}
+							Console.logger.error(self) {error}
 
 							exit!(1)
 						end
@@ -177,7 +177,7 @@ def wait
 					end
 
 					if @status.nil?
-						Async.logger.warn(self) {"Process #{@pid} is blocking, has it exited?"}
+						Console.logger.warn(self) {"Process #{@pid} is blocking, has it exited?"}
 						_, @status = ::Process.wait2(@pid)
 					end
 				end

lib/async/container/thread.rb

@@ -24,8 +24,6 @@
 require_relative 'error'
 require_relative 'notify/pipe'
 
-require 'async/logger'
-
 module Async
 	module Container
 		# Represents a running child thread from the point of view of the parent container.
@@ -207,7 +205,7 @@ def to_s
 			# Invoked by the @waiter thread to indicate the outcome of the child thread.
 			def finished(error = nil)
 				if error
-					Async.logger.error(self) {error}
+					Console.logger.error(self) {error}
 				end
 
 				@status = Status.new(error)