Contents

# https://newrelic.atlassian.net/browse/RUBY-669

class PipeManagerTest < Test::Unit::TestCase
  def setup
    @listener = NewRelic::Agent::PipeChannelManager.listener
  end

  def teardown
    @listener.stop
  end
  
  def test_old_pipes_are_cleaned_up_after_timeout
    @listener.timeout = 1
    NewRelic::Agent::PipeChannelManager.register_report_channel(:timeout_test)
    sleep 2
    @listener.start
    sleep 0.5 # give the thread some time to start, and clean things up
    assert_nil NewRelic::Agent::PipeChannelManager.channels[:timeout_test]
  end

  def test_pipes_are_regularly_checked_for_freshness
    @listener.select_timeout = 1
    @listener.timeout = 2
    NewRelic::Agent::PipeChannelManager.register_report_channel(:select_test)
    
    sleep 1.5
    @listener.start
    assert NewRelic::Agent::PipeChannelManager.channels[:select_test]
    
    sleep 1.5
    assert_nil NewRelic::Agent::PipeChannelManager.channels[:select_test]
  end
end

Version data entries

27 entries across 27 versions & 4 rubygems

Version	Path
newrelic_rpm-3.5.4.34	test/multiverse/suites/agent_only/pipe_manager_test.rb
newrelic_rpm-3.5.4.33	test/multiverse/suites/agent_only/pipe_manager_test.rb
newrelic_rpm-3.5.4.31.beta	test/multiverse/suites/agent_only/pipe_manager_test.rb
newrelic_rpm-3.5.4.29.beta	test/multiverse/suites/agent_only/pipe_manager_test.rb
ghazel-newrelic_rpm-3.5.4	test/multiverse/suites/agent_only/pipe_manager_test.rb
newrelic_rpm-3.5.3.25	test/multiverse/suites/agent_only/pipe_manager_test.rb
newrelic_rpm-3.5.3.24	test/multiverse/suites/agent_only/pipe_manager_test.rb