Class: Async::Container::Process::Instance

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

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!, #ready!, #reloading!, #restarting!, #send

Methods inherited from Notify::Client

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

Constructor Details

#initialize(io) ⇒ Instance

Returns a new instance of Instance.



43
44
45
46
47
 
# File 'lib/async/container/process.rb', line 43

def initialize(io)
  super
  
  @name = nil
end

Class Method Details

.for(process) ⇒ Object 



32
33
34
35
36
37
38
39
40
41
 
# File 'lib/async/container/process.rb', line 32

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

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



59
60
61
62
63
64
65
66
67
 
# File 'lib/async/container/process.rb', line 59

def exec(*arguments, ready: true, **options)
  if ready
    self.ready!(status: "(exec)") if ready
  else
    self.before_spawn(arguments, options)
  end
  
  ::Process.exec(*arguments, options)
end

#name ⇒ Object 



55
56
57
 
# File 'lib/async/container/process.rb', line 55

def name
  @name
end

#name=(value) ⇒ Object 



49
50
51
52
53
 
# File 'lib/async/container/process.rb', line 49

def name= value
  if @name = value
    ::Process.setproctitle(@name)
  end
end