Sha256: 228d670a09e5429aefd08064ac80ce416c46340eb7706e5e9b4bd865168ebb6c
Contents?: true
Size: 1.91 KB
Versions: 5
Compression:
Stored size: 1.91 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.
require 'newrelic_rpm'
require 'multiverse_helpers'
class HarvestTimestampsTest < Minitest::Test
include MultiverseHelpers
setup_and_teardown_agent
def test_resets_metric_data_timestamps_after_forking
freeze_time
t1 = advance_time 10
NewRelic::Agent.after_fork
t2 = advance_time 10
trigger_metric_data_post
metric_data_post = $collector.calls_for('metric_data').first
start_ts, end_ts = metric_data_post[1..2]
assert_equal(t1.to_f, start_ts)
assert_equal(t2.to_f, end_ts)
end
def test_start_timestamp_maintained_on_harvest_failure
t0 = freeze_time.to_f
NewRelic::Agent.after_fork
$collector.stub('metric_data', {}, 503)
t1 = advance_time(10).to_f
trigger_metric_data_post
first_post = last_metric_data_post
$collector.reset
t2 = advance_time(10).to_f
trigger_metric_data_post
second_post = last_metric_data_post
assert_equal([t0, t1], first_post[1..2])
assert_equal([t0, t2], second_post[1..2])
end
def test_timestamps_updated_even_if_filling_metric_id_cache_fails
t0 = freeze_time.to_f
NewRelic::Agent.after_fork
# Induce a failure in filling the metric ID cache by handing back a bogus
# response to the first metric_data post.
$collector.stub('metric_data', [[[[]]]], 200)
t1 = advance_time(10).to_f
trigger_metric_data_post
first_post = last_metric_data_post
$collector.reset
t2 = advance_time(10).to_f
trigger_metric_data_post
second_post = last_metric_data_post
assert_equal([t0, t1], first_post[1..2])
assert_equal([t1, t2], second_post[1..2])
end
def trigger_metric_data_post
NewRelic::Agent.agent.send(:transmit_data)
end
def last_metric_data_post
$collector.calls_for('metric_data').last
end
end
Version data entries
5 entries across 5 versions & 1 rubygems