Class: PhusionPassenger::AdminTools::ControlProcess

Inherits:
Object
  • Object
show all
Defined in:
lib/phusion_passenger/admin_tools/control_process.rb

Defined Under Namespace

Classes: Instance

Instance Attribute Summary collapse

Class Method Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(path) ⇒ ControlProcess

Returns a new instance of ControlProcess.



64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 64

def initialize(path)
  @path = path
  if File.exist?("#{path}/control_process.pid")
    data = File.read("#{path}/control_process.pid").strip
    if data.empty?
      raise ArgumentError, "'#{path}' is not a valid control process directory."
    else
      @pid = data.to_i
    end
  else
    path =~ /passenger.(\d+)\Z/
    @pid = $1.to_i
  end
  if !AdminTools.process_is_alive?(@pid)
    raise ArgumentError, "There is no control process with PID #{@pid}."
  end
end

Instance Attribute Details

#path ⇒ Object

Returns the value of attribute path.



39
40
41
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 39

def path
  @path
end

#pid ⇒ Object

Returns the value of attribute pid.



40
41
42
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 40

def pid
  @pid
end

Class Method Details

.for_pid(pid) ⇒ Object 



60
61
62
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 60

def self.for_pid(pid)
  return list(false).find { |c| c.pid == pid }
end

.list(clean_stale = true) ⇒ Object 



42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 42

def self.list(clean_stale = true)
  results = []
  Dir["#{AdminTools.tmpdir}/passenger.*"].each do |dir|
    next if dir !~ /passenger.(\d+)\Z/
    begin
      results << ControlProcess.new(dir)
    rescue ArgumentError
      # Stale Passenger temp folder. Clean it up if instructed.
      if clean_stale
        puts "*** Cleaning stale folder #{dir}"
        FileUtils.chmod_R(0700, dir) rescue nil
        FileUtils.rm_rf(dir)
      end
    end
  end
  return results
end

Instance Method Details

#backtraces ⇒ Object 



89
90
91
92
93
94
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 89

def backtraces
  connect do |channel|
    channel.write("backtraces")
    return channel.read_scalar
  end
end

#domains ⇒ Object 



103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 103

def domains
  doc = REXML::Document.new(xml)
  
  domains = []
  doc.elements.each("info/domains/domain") do |domain|
    instances = []
    d = {
      :name => domain.elements["name"].text,
      :instances => instances
    }
    domain.elements.each("instances/instance") do |instance|
      i = Instance.new
      instance.elements.each do |element|
        if i.respond_to?("#{element.name}=")
          if Instance::INT_PROPERTIES.include?(element.name.to_sym)
            value = element.text.to_i
          else
            value = element.text
          end
          i.send("#{element.name}=", value)
        end
      end
      instances << i
    end
    domains << d
  end
  return domains
end

#instances ⇒ Object 



132
133
134
135
136
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 132

def instances
  return domains.map do |domain|
    domain[:instances]
  end.flatten
end

#status ⇒ Object 



82
83
84
85
86
87
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 82

def status
  connect do |channel|
    channel.write("status")
    return channel.read_scalar
  end
end

#xml ⇒ Object 



96
97
98
99
100
101
 
# File 'lib/phusion_passenger/admin_tools/control_process.rb', line 96

def xml
  connect do |channel|
    channel.write("status_xml")
    return channel.read_scalar
  end
end