Sha256: 2aab2f14ffaedb4ef87dd906f4834623dcf9749725ab7471604c6491fea1b2ce
Contents?: true
Size: 1.96 KB
Versions: 28
Compression:
Stored size: 1.96 KB
Contents
##
## This is Rails framework specific tracking mechanism, they are moved to multiple files for separate tracking
##
#require 'agent/am_objectholder'
#require 'socket'
#module ManageEngine
# class APMInstrumenter
# @t =nil;
# def initialize
# @obj=ManageEngine::APMObjectHolder.instance
# end
#
# def doSubscribe
# @obj=ManageEngine::APMObjectHolder.instance
# @obj.log.debug "[ instrumenter ] [ Subscriber for Agent ]"
# @subscriber = ActiveSupport::Notifications.subscribe do |name, start, finish, id, payload|
# if(ManageEngine::APMObjectHolder.instance.config.agent_enabled)
# #rt = (finish-start).to_i
# ManageEngine::APMWorker.getInstance.start
# ManageEngine::APMObjectHolder.instance.log.debug "[ Notifications for Agent ] #{Thread.current} #{id} #{name} - #{payload[:path]}"
# #trace= caller;
# #puts ">>> Threadlocal var : #{Thread.current[:apminsight]}"
# if name=="sql.active_record"
# #Thread.current[:apminsight] = "#{Thread.current[:apminsight]} + #{payload[:sql]}"
# if payload[:name] != "SCHEMA"
# @obj.log.debug ">>>>>>>> SQL: #{payload[:sql]}"
# end
# @obj.log.debug "~~~~~ SQL Payload: #{payload}"
# end
# id = "#{Thread.current}"
# stats = Hash.new
# stats["name"] = name;
# stats["start"] = start.to_f * 1000;
# stats["end"] = finish.to_f * 1000;
# stats["id"] = id;
# stats["payload"] = payload;
# if (name=="sql.active_record" && (finish.to_f - start.to_f)>=(ManageEngine::APMObjectHolder.instance.config.sql_trace_t).to_f)
# stats["trace"] = caller(20); # Taking stacktrace of depth 20
# end
# stats["ctime"] =ManageEngine::APMObjectHolder.instance.util.currenttimemillis;
# ManageEngine::APMObjectHolder.instance.collector.updateTransaction(id,stats);
# else
# ActiveSupport::Notifications.unsubscribe @subscriber
# @obj.log.info "[ instrumenter ] [ RETURNING NO METRICS] "
# end
# end
# end
#
# def doUnSubscribe
# ActiveSupport::Notifications.unsubscribe @subscriber
# end
#
#end #class
#end#module
Version data entries
28 entries across 28 versions & 2 rubygems