Class: NewRelic::Agent::Commands::AgentCommandRouter
- Inherits:
-
Object
- Object
- NewRelic::Agent::Commands::AgentCommandRouter
show all
- Defined in:
- lib/new_relic/agent/commands/agent_command_router.rb
Defined Under Namespace
Classes: AgentCommandError
Constant Summary
collapse
- SUCCESS_RESULT =
NewRelic::EMPTY_HASH
- ERROR_KEY =
'error'
Instance Attribute Summary collapse
Instance Method Summary
collapse
Constructor Details
Returns a new instance of AgentCommandRouter.
[View source]
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 22
def initialize(event_listener = nil)
@handlers = Hash.new { |*| proc { |cmd| self.unrecognized_agent_command(cmd) } }
@backtrace_service = Threading::BacktraceService.new(event_listener)
@thread_profiler_session = ThreadProfilerSession.new(@backtrace_service)
@handlers['start_profiler'] = proc { |cmd| thread_profiler_session.handle_start_command(cmd) }
@handlers['stop_profiler'] = proc { |cmd| thread_profiler_session.handle_stop_command(cmd) }
if event_listener event_listener.subscribe(:before_shutdown, &method(:on_before_shutdown))
end
end
|
Instance Attribute Details
permalink
#backtrace_service ⇒ Object
Returns the value of attribute backtrace_service.
20
21
22
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 20
def backtrace_service
@backtrace_service
end
|
permalink
#handlers ⇒ Object
Returns the value of attribute handlers.
18
19
20
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 18
def handlers
@handlers
end
|
permalink
#thread_profiler_session ⇒ Object
Returns the value of attribute thread_profiler_session.
20
21
22
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 20
def thread_profiler_session
@thread_profiler_session
end
|
Instance Method Details
permalink
#call_handler_for(agent_command) ⇒ Object
[View source]
128
129
130
131
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 128
def call_handler_for(agent_command)
handler = select_handler(agent_command)
handler.call(agent_command)
end
|
permalink
#check_for_and_handle_agent_commands ⇒ Object
[View source]
42
43
44
45
46
47
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 42
def check_for_and_handle_agent_commands
commands = get_agent_commands
results = invoke_commands(commands)
new_relic_service.agent_command_results(results) unless results.empty?
end
|
permalink
#error(err) ⇒ Object
[View source]
124
125
126
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 124
def error(err)
{ERROR_KEY => err.message}
end
|
permalink
#get_agent_commands ⇒ Object
[View source]
88
89
90
91
92
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 88
def get_agent_commands
commands = new_relic_service.get_agent_commands
NewRelic::Agent.logger.debug("Received get_agent_commands = #{commands.inspect}")
commands.map { |collector_command| AgentCommand.new(collector_command) }
end
|
permalink
#harvest! ⇒ Object
[View source]
55
56
57
58
59
60
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 55
def harvest!
profiles = []
profiles += harvest_from_thread_profiler_session
log_profiles(profiles)
profiles
end
|
permalink
#harvest_from_thread_profiler_session ⇒ Object
[View source]
70
71
72
73
74
75
76
77
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 70
def harvest_from_thread_profiler_session
if self.thread_profiler_session.ready_to_harvest?
self.thread_profiler_session.stop(true)
[self.thread_profiler_session.harvest]
else
[]
end
end
|
permalink
#invoke_command(agent_command) ⇒ Object
[View source]
107
108
109
110
111
112
113
114
115
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 107
def invoke_command(agent_command)
begin
call_handler_for(agent_command)
return success
rescue AgentCommandError => e
NewRelic::Agent.logger.debug(e)
error(e)
end
end
|
permalink
#invoke_commands(agent_commands) ⇒ Object
[View source]
94
95
96
97
98
99
100
101
102
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 94
def invoke_commands(agent_commands)
results = {}
agent_commands.each do |agent_command|
results[agent_command.id.to_s] = invoke_command(agent_command)
end
results
end
|
permalink
#log_profiles(profiles) ⇒ Object
[View source]
79
80
81
82
83
84
85
86
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 79
def log_profiles(profiles)
if profiles.empty?
::NewRelic::Agent.logger.debug('No thread profiles with data found to send.')
else
profile_descriptions = profiles.map { |p| p.to_log_description }
::NewRelic::Agent.logger.debug("Sending thread profiles [#{profile_descriptions.join(', ')}]")
end
end
|
permalink
#merge!(*args) ⇒ Object
We don’t currently support merging thread profiles that failed to send back into the AgentCommandRouter, so we just no-op this method. Same with reset! - we don’t support asynchronous cancellation of a running thread profile currently.
[View source]
66
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 66
def merge!(*args); end
|
permalink
#new_relic_service ⇒ Object
[View source]
38
39
40
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 38
def new_relic_service
NewRelic::Agent.instance.service
end
|
permalink
#on_before_shutdown(*args) ⇒ Object
[View source]
49
50
51
52
53
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 49
def on_before_shutdown(*args)
if self.thread_profiler_session.running?
self.thread_profiler_session.stop(true)
end
end
|
[View source]
68
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 68
def reset!; end
|
permalink
#select_handler(agent_command) ⇒ Object
[View source]
133
134
135
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 133
def select_handler(agent_command)
@handlers[agent_command.name]
end
|
[View source]
120
121
122
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 120
def success
SUCCESS_RESULT
end
|
permalink
#unrecognized_agent_command(agent_command) ⇒ Object
[View source]
137
138
139
|
# File 'lib/new_relic/agent/commands/agent_command_router.rb', line 137
def unrecognized_agent_command(agent_command)
NewRelic::Agent.logger.debug("Unrecognized agent command #{agent_command.inspect}")
end
|