class NewRelic::Agent::CrossAppMonitor
Constants
- CONTENT_LENGTH_HEADER_KEY
- NEWRELIC_APPDATA_HEADER
- NEWRELIC_ID_HEADER
- NEWRELIC_ID_HEADER_KEY
- NEWRELIC_TXN_HEADER
- NEWRELIC_TXN_HEADER_KEY
Public Instance Methods
build_payload(state, timings, content_length)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 122 def build_payload(state, timings, content_length) payload = [ NewRelic::Agent.config[:cross_process_id], timings.transaction_name, timings.queue_time_in_seconds.to_f, timings.app_time_in_seconds.to_f, content_length, state.request_guid ] payload = obfuscator.obfuscate(NewRelic::JSONWrapper.dump(payload)) end
clear_client_cross_app_id(state)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 55 def clear_client_cross_app_id(state) state.client_cross_app_id = nil end
client_referring_transaction_guid(state)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 65 def client_referring_transaction_guid(state) info = state.referring_transaction_info or return nil return info[0] end
client_referring_transaction_path_hash(state)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 80 def client_referring_transaction_path_hash(state) info = state.referring_transaction_info or return nil return info[3].is_a?(String) && info[3] end
client_referring_transaction_record_flag(state)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 70 def client_referring_transaction_record_flag(state) info = state.referring_transaction_info or return nil return info[1] end
client_referring_transaction_trip_id(state)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 75 def client_referring_transaction_trip_id(state) info = state.referring_transaction_info or return nil return info[2].is_a?(String) && info[2] end
content_length_from_request(request)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 161 def content_length_from_request(request) request[CONTENT_LENGTH_HEADER_KEY] || -1 end
cross_app_enabled?()
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 105 def cross_app_enabled? NewRelic::Agent::CrossAppTracing.cross_app_enabled? end
decoded_id(request)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 154 def decoded_id(request) encoded_id = request[NEWRELIC_ID_HEADER_KEY] return "" if encoded_id.nil? obfuscator.deobfuscate(encoded_id) end
hash_transaction_name(identifier)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 165 def hash_transaction_name(identifier) Digest::MD5.digest(identifier).unpack("@12N").first & 0xffffffff end
insert_response_header(state, request_headers, response_headers)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 85 def insert_response_header(state, request_headers, response_headers) unless state.client_cross_app_id.nil? txn = state.current_transaction unless txn.nil? txn.freeze_name_and_execute_if_not_ignored do timings = state.timings content_length = content_length_from_request(request_headers) set_response_headers(state, response_headers, timings, content_length) set_metrics(state.client_cross_app_id, timings) end end clear_client_cross_app_id(state) end end
on_finished_configuring(events)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 22 def on_finished_configuring(events) register_event_listeners(events) end
path_hash(txn_name, seed)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 169 def path_hash(txn_name, seed) rotated = ((seed << 1) | (seed >> 31)) & 0xffffffff app_name = NewRelic::Agent.config.app_names.first identifier = "#{app_name};#{txn_name}" sprintf("%08x", rotated ^ hash_transaction_name(identifier)) end
register_event_listeners(events)
click to toggle source
Expected sequence of events:
:before_call will save our cross application request id to the thread :after_call will write our response headers/metrics and clean up the thread
# File lib/new_relic/agent/cross_app_monitor.rb, line 29 def register_event_listeners(events) NewRelic::Agent.logger. debug("Wiring up Cross Application Tracing to events after finished configuring") events.subscribe(:before_call) do |env| #THREAD_LOCAL_ACCESS if should_process_request(env) state = NewRelic::Agent::TransactionState.tl_get save_client_cross_app_id(state, env) save_referring_transaction_info(state, env) set_transaction_attributes(state) end end events.subscribe(:after_call) do |env, (_status_code, headers, _body)| #THREAD_LOCAL_ACCESS state = NewRelic::Agent::TransactionState.tl_get insert_response_header(state, env, headers) end end
save_client_cross_app_id(state, request_headers)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 51 def save_client_cross_app_id(state, request_headers) state.client_cross_app_id = decoded_id(request_headers) end
save_referring_transaction_info(state, request_headers)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 59 def save_referring_transaction_info(state, request_headers) txn_header = request_headers[NEWRELIC_TXN_HEADER_KEY] or return txn_info = deserialize_header(txn_header, NEWRELIC_TXN_HEADER) state.referring_transaction_info = txn_info end
set_metrics(id, timings)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 149 def set_metrics(id, timings) metric_name = "ClientApplication/#{id}/all" NewRelic::Agent.record_metric(metric_name, timings.app_time_in_seconds) end
set_response_headers(state, response_headers, timings, content_length)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 118 def set_response_headers(state, response_headers, timings, content_length) response_headers[NEWRELIC_APPDATA_HEADER] = build_payload(state, timings, content_length) end
set_transaction_attributes(state)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 134 def set_transaction_attributes(state) # We expect to get the before call to set the id (if we have it) before # this, and then write our custom parameter when the transaction starts return unless txn = state.current_transaction if state.client_cross_app_id txn.attributes.add_intrinsic_attribute(:client_cross_process_id, state.client_cross_app_id) end referring_guid = client_referring_transaction_guid(state) if referring_guid txn.attributes.add_intrinsic_attribute(:referring_transaction_guid, referring_guid) end end
should_process_request(request_headers)
click to toggle source
# File lib/new_relic/agent/cross_app_monitor.rb, line 101 def should_process_request(request_headers) return cross_app_enabled? && trusts?(request_headers) end
trusts?(request)
click to toggle source
Expects an ID of format “12#345”, and will only accept that!
# File lib/new_relic/agent/cross_app_monitor.rb, line 110 def trusts?(request) id = decoded_id(request) split_id = id.match(/(\d+)#\d+/) return false if split_id.nil? NewRelic::Agent.config[:trusted_account_ids].include?(split_id.captures.first.to_i) end