Class: Chukan::LocalProcess

Inherits:
Object
  • Object
show all
Defined in:
lib/chukan.rb

Direct Known Subclasses

RemoteProcess

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(*cmdline) ⇒ LocalProcess

Returns a new instance of LocalProcess.



120
121
122
123
124
125
126
127
 
# File 'lib/chukan.rb', line 120

def initialize(*cmdline)
	@cmdline = cmdline.map {|x| x.to_s }
	@status = nil
	@shortname = cmdline.join(' ').split(/\s/)
	@shortname[0] = File.basename(@shortname[0])
	@shortname = @shortname.join(' ')[0, 12]
	start
end

Instance Attribute Details

#cmdline ⇒ Object (readonly)

Returns the value of attribute cmdline.



129
130
131
 
# File 'lib/chukan.rb', line 129

def cmdline
  @cmdline
end

#pid ⇒ Object (readonly)

Returns the value of attribute pid.



131
132
133
 
# File 'lib/chukan.rb', line 131

def pid
  @pid
end

#status ⇒ Object (readonly)

Returns the value of attribute status.



132
133
134
 
# File 'lib/chukan.rb', line 132

def status
  @status
end

#stderr ⇒ Object (readonly)

Returns the value of attribute stderr.



130
131
132
 
# File 'lib/chukan.rb', line 130

def stderr
  @stderr
end

#stdin ⇒ Object (readonly)

Returns the value of attribute stdin.



130
131
132
 
# File 'lib/chukan.rb', line 130

def stdin
  @stdin
end

#stdout ⇒ Object (readonly)

Returns the value of attribute stdout.



130
131
132
 
# File 'lib/chukan.rb', line 130

def stdout
  @stdout
end

Instance Method Details

#hup ⇒ Object 



168
169
170
 
# File 'lib/chukan.rb', line 168

def hup
	signal(:SIGHUP)
end

#join ⇒ Object 



134
135
136
137
138
139
140
141
142
143
144
145
 
# File 'lib/chukan.rb', line 134

def join
	@status = Process.waitpid2(@pid)[1]
	@stdout_reader.join
	@stderr_reader.join
	@killer.killed
	reason = @status.inspect
	if m = reason.match(/\,([^\>]*)\>/)
		reason = m[1]
	end
	$stderr.puts "#{@msg_prefix}#{reason}"
	@status
end

#kill ⇒ Object 



160
161
162
 
# File 'lib/chukan.rb', line 160

def kill
	signal(:SIGKILL)
end

#set_display(shortname) ⇒ Object 



172
173
174
175
176
177
178
179
180
181
 
# File 'lib/chukan.rb', line 172

def set_display(shortname)
	if shortname.length <= 12
		@msg_prefix[0..-1] = "[%-12s %6d] " % [shortname, @pid]
	elsif shortname.length < 19
		@msg_prefix[0..-1] = "[%-19s] " % [shortname]
	else
		@msg_prefix[0..-1] = "[#{shortname}] "
	end
	self
end

#signal(sig) ⇒ Object 



155
156
157
158
 
# File 'lib/chukan.rb', line 155

def signal(sig)
	Process.kill(sig, @pid) rescue nil
	self
end

#stderr_join(pattern, &block) ⇒ Object 



151
152
153
 
# File 'lib/chukan.rb', line 151

def stderr_join(pattern, &block)
	io_join(@stderr, pattern, &block)
end

#stdout_join(pattern, &block) ⇒ Object 



147
148
149
 
# File 'lib/chukan.rb', line 147

def stdout_join(pattern, &block)
	io_join(@stdout, pattern, &block)
end

#term ⇒ Object 



164
165
166
 
# File 'lib/chukan.rb', line 164

def term
	signal(:SIGTERM)
end