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.tl_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

5 entries across 5 versions & 1 rubygems

Version	Path
newrelic_rpm-3.9.4.245	test/performance/suites/thread_profiling.rb
newrelic_rpm-3.9.3.241	test/performance/suites/thread_profiling.rb
newrelic_rpm-3.9.2.239	test/performance/suites/thread_profiling.rb
newrelic_rpm-3.9.1.236	test/performance/suites/thread_profiling.rb
newrelic_rpm-3.9.0.229	test/performance/suites/thread_profiling.rb