Sha256: d76c5590e9583a0474e3c530e1b6f4031817ccccaafa7f4392f7eb95bc56e917
Contents?: true
Size: 1.18 KB
Versions: 15
Compression:
Stored size: 1.18 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.
# https://newrelic.atlassian.net/browse/RUBY-669
require 'multiverse_helpers'
class PipeManagerTest < MiniTest::Unit::TestCase
include MultiverseHelpers
setup_and_teardown_agent
def after_setup
@listener = NewRelic::Agent::PipeChannelManager.listener
end
def after_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
15 entries across 15 versions & 1 rubygems