Class: Async::Container::Forked::Child::Instance

Inherits:
Notify::Pipe show all
Defined in:
lib/async/container/forked.rb

Overview

Represents a running child process from the point of view of the child process.

Constant Summary

Constants inherited from Notify::Pipe

Notify::Pipe::NOTIFY_PIPE

Class Method Summary collapse

Instance Method Summary collapse

Methods inherited from Notify::Pipe

#before_spawn, open!, #send

Methods inherited from Notify::Client

#error!, #healthy!, #ready!, #reloading!, #restarting!, #status!, #stopping!

Constructor Details

#initialize(io) ⇒ Instance

Initialize the child process instance.



41
42
43
44
45
 
# File 'lib/async/container/forked.rb', line 41

def initialize(io)
	super
	
	@name = nil
end

Class Method Details

.for(process) ⇒ Object

Wrap an instance around the Process instance from within the forked child.



27
28
29
30
31
32
33
34
35
36
 
# File 'lib/async/container/forked.rb', line 27

def self.for(process)
	instance = self.new(process.out)
	
	# The child process won't be reading from the channel:
	process.close_read
	
	instance.name = process.name
	
	return instance
end

Instance Method Details

#as_json ⇒ Object

Generate a hash representation of the process.



50
51
52
53
54
55
 
# File 'lib/async/container/forked.rb', line 50

def as_json(...)
	{
		process_id: ::Process.pid,
		name: @name,
	}
end

#exec(*arguments, ready: true, **options) ⇒ Object

Replace the current child process with a different one. Forwards arguments and options to Process.exec. This method replaces the child process with the new executable, thus this method never returns.



85
86
87
88
89
90
91
92
93
94
95
 
# File 'lib/async/container/forked.rb', line 85

def exec(*arguments, ready: true, **options)
	# Always set up the notification pipe to be inherited by the exec'd process.
	# This prevents the pipe from closing, which would trigger hang prevention and SIGKILL.
	self.before_spawn(arguments, options)
	
	if ready
		self.ready!(status: "(exec)")
	end
	
	::Process.exec(*arguments, **options)
end

#name ⇒ Object 



75
76
77
 
# File 'lib/async/container/forked.rb', line 75

def name
	@name
end

#name=(value) ⇒ Object

Set the process title to the specified value.



67
68
69
70
71
72
 
# File 'lib/async/container/forked.rb', line 67

def name= value
	@name = value
	
	# This sets the process title to an empty string if the name is nil:
	::Process.setproctitle(@name.to_s)
end

#to_json ⇒ Object

Generate a JSON representation of the process.



60
61
62
 
# File 'lib/async/container/forked.rb', line 60

def to_json(...)
	as_json.to_json(...)
end