Module: Arborist::Monitor::DefaultCallbacks

Included in:
RunContext
Defined in:
lib/arborist/monitor.rb

Overview

The module that contains the default logic for invoking an external program to do the work of a Monitor.

Instance Method Summary collapse

Instance Method Details

#exec_arguments(nodes) ⇒ Object

Given one or more nodes, return an Array of arguments that should be appended to the external command.



57
58
59
 
# File 'lib/arborist/monitor.rb', line 57

def exec_arguments( nodes )
	return []
end

#exec_input(nodes, io) ⇒ Object

Write the specified nodes as serialized data to the given io.



63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
# File 'lib/arborist/monitor.rb', line 63

def exec_input( nodes, io )
	return if io.closed?

	nodes.each do |(identifier, data)|
		self.log.debug "Serializing node properties for %s" % [ identifier ]
		prop_map = data.collect do |key, val|
			val = val.join( ',' ) if val.is_a?( Array )
			"%s=%s" % [ key, Shellwords.escape(val) ]
		end

		self.log.debug "  writing %d properties to %p" % [ prop_map.size, io ]
		io.puts "%s %s" % [ identifier, prop_map.join(' ') ]
		self.log.debug "  wrote the node to FD %d" % [ io.fileno ]
	end

	self.log.debug "done writing to FD %d" % [ io.fileno ]
end

#handle_results(pid, out, err) ⇒ Object

Return the results of running the external command



83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
 
# File 'lib/arborist/monitor.rb', line 83

def handle_results( pid, out, err )
	err.flush
	err.close
	self.log.debug "Closed child's stderr."

    # identifier key1=val1 key2=val2
	results = out.each_line.with_object({}) do |line, accum|
		identifier, attributes = line.split( ' ', 2 )
		attrhash = Shellwords.shellsplit( attributes ).each_with_object({}) do |pair, hash|
			key, val = pair.split( '=', 2 )
			hash[ key ] = val
		end

		accum[ identifier ] = attrhash
	end
	out.close

	self.log.debug "Waiting on PID %d" % [ pid ]
	Process.waitpid( pid )

	return results
end