Sha256: a65783b23a3041ede518422ff69e5444c391784bbb784fea26ffa88d8fcbb997
Contents?: true
Size: 1.99 KB
Versions: 15
Compression:
Stored size: 1.99 KB
Contents
# encoding: utf-8
# This file is distributed under New Relic's license terms.
# See https://github.com/newrelic/rpm/blob/master/LICENSE for complete details.
class ThreadProfiling < Performance::TestCase
def recurse(n, final)
if n == 0
final.call
else
recurse(n-1, final)
end
end
def block
@mutex.synchronize do
@cvar.wait(@mutex)
end
end
def setup
require 'new_relic/agent/threading/backtrace_service'
@nthreads = 16
@mutex = Mutex.new
@cvar = ConditionVariable.new
@threadq = Queue.new
@threads = []
@nthreads.times do
@threads << Thread.new do
@threadq << self
transaction_state = NewRelic::Agent::TransactionState.get
def transaction_state.in_request_transaction?; true; end
recurse(50, method(:block))
end
end
# Ensure that all threads have had a chance to start up
started_count = 0
while started_count < @nthreads do
@threadq.pop
started_count += 1
end
@service = NewRelic::Agent::Threading::BacktraceService.new
@worker_loop = @service.worker_loop
def @worker_loop.run; end # we want to drive it manually
end
def teardown
@cvar.broadcast
@threads.each(&:join)
end
def test_gather_backtraces(timer)
@service.subscribe(NewRelic::Agent::Threading::BacktraceService::ALL_TRANSACTIONS)
timer.measure do
(iterations / 10).times do
@service.poll
end
end
@service.unsubscribe(NewRelic::Agent::Threading::BacktraceService::ALL_TRANSACTIONS)
end
def test_gather_backtraces_subscribed(timer)
@service.subscribe('eagle')
timer.measure do
(iterations / 10).times do
t0 = Time.now.to_f
@service.poll
payload = {
:name => 'eagle',
:start_timestamp => t0,
:duration => Time.now.to_f-t0,
:thread => @threads.sample
}
@service.on_transaction_finished(payload)
end
end
@service.unsubscribe('eagle')
end
end
Version data entries
15 entries across 15 versions & 1 rubygems