class Mmtrix::Agent::CrossAppMonitor
Constants
- CONTENT_LENGTH_HEADER_KEY
- MMTRIX_APPDATA_HEADER
- MMTRIX_ID_HEADER
- MMTRIX_ID_HEADER_KEY
- MMTRIX_TXN_HEADER
- MMTRIX_TXN_HEADER_KEY
Public Instance Methods
build_payload(state, timings, content_length)
click to toggle source
# File lib/mmtrix/agent/cross_app_monitor.rb, line 123 def build_payload(state, timings, content_length) payload = [ Mmtrix::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(Mmtrix::JSONWrapper.dump(payload)) end
clear_client_cross_app_id(state)
click to toggle source
# File lib/mmtrix/agent/cross_app_monitor.rb, line 56 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/mmtrix/agent/cross_app_monitor.rb, line 66 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/mmtrix/agent/cross_app_monitor.rb, line 81 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/mmtrix/agent/cross_app_monitor.rb, line 71 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/mmtrix/agent/cross_app_monitor.rb, line 76 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/mmtrix/agent/cross_app_monitor.rb, line 162 def content_length_from_request(request) request[CONTENT_LENGTH_HEADER_KEY] || -1 end
cross_app_enabled?()
click to toggle source
# File lib/mmtrix/agent/cross_app_monitor.rb, line 106 def cross_app_enabled? Mmtrix::Agent::CrossAppTracing.cross_app_enabled? end
decoded_id(request)
click to toggle source
# File lib/mmtrix/agent/cross_app_monitor.rb, line 155 def decoded_id(request) encoded_id = request[MMTRIX_ID_HEADER_KEY] return "" if encoded_id.nil? obfuscator.deobfuscate(encoded_id) end
hash_transaction_name(identifier)
click to toggle source
# File lib/mmtrix/agent/cross_app_monitor.rb, line 166 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/mmtrix/agent/cross_app_monitor.rb, line 86 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/mmtrix/agent/cross_app_monitor.rb, line 23 def on_finished_configuring(events) register_event_listeners(events) end
path_hash(txn_name, seed)
click to toggle source
# File lib/mmtrix/agent/cross_app_monitor.rb, line 170 def path_hash(txn_name, seed) rotated = ((seed << 1) | (seed >> 31)) & 0xffffffff app_name = Mmtrix::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/mmtrix/agent/cross_app_monitor.rb, line 30 def register_event_listeners(events) Mmtrix::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 = Mmtrix::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 = Mmtrix::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/mmtrix/agent/cross_app_monitor.rb, line 52 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/mmtrix/agent/cross_app_monitor.rb, line 60 def save_referring_transaction_info(state, request_headers) txn_header = request_headers[MMTRIX_TXN_HEADER_KEY] or return txn_info = deserialize_header(txn_header, MMTRIX_TXN_HEADER) state.referring_transaction_info = txn_info end
set_metrics(id, timings)
click to toggle source
# File lib/mmtrix/agent/cross_app_monitor.rb, line 150 def set_metrics(id, timings) metric_name = "ClientApplication/#{id}/all" Mmtrix::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/mmtrix/agent/cross_app_monitor.rb, line 119 def set_response_headers(state, response_headers, timings, content_length) response_headers[MMTRIX_APPDATA_HEADER] = build_payload(state, timings, content_length) end
set_transaction_attributes(state)
click to toggle source
# File lib/mmtrix/agent/cross_app_monitor.rb, line 135 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/mmtrix/agent/cross_app_monitor.rb, line 102 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/mmtrix/agent/cross_app_monitor.rb, line 111 def trusts?(request) id = decoded_id(request) split_id = id.match(/(\d+)#\d+/) return false if split_id.nil? Mmtrix::Agent.config[:trusted_account_ids].include?(split_id.captures.first.to_i) end