| // Copyright (C) 2017 The Android Open Source Project |
| // |
| // Licensed under the Apache License, Version 2.0 (the "License"); |
| // you may not use this file except in compliance with the License. |
| // You may obtain a copy of the License at |
| // |
| // http://www.apache.org/licenses/LICENSE-2.0 |
| // |
| // Unless required by applicable law or agreed to in writing, software |
| // distributed under the License is distributed on an "AS IS" BASIS, |
| // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| // See the License for the specific language governing permissions and |
| // limitations under the License. |
| |
| #include <gtest/gtest.h> |
| |
| #include "src/StatsLogProcessor.h" |
| #include "src/stats_log_util.h" |
| #include "tests/statsd_test_util.h" |
| |
| #include <vector> |
| |
| namespace android { |
| namespace os { |
| namespace statsd { |
| |
| #ifdef __ANDROID__ |
| |
| namespace { |
| |
| StatsdConfig CreateDurationMetricConfig_NoLink_AND_CombinationCondition( |
| DurationMetric::AggregationType aggregationType, bool addExtraDimensionInCondition, |
| bool hashStringInReport) { |
| StatsdConfig config; |
| config.add_allowed_log_source("AID_ROOT"); // LogEvent defaults to UID of root. |
| *config.add_atom_matcher() = CreateStartScheduledJobAtomMatcher(); |
| *config.add_atom_matcher() = CreateFinishScheduledJobAtomMatcher(); |
| *config.add_atom_matcher() = CreateSyncStartAtomMatcher(); |
| *config.add_atom_matcher() = CreateSyncEndAtomMatcher(); |
| *config.add_atom_matcher() = CreateScreenTurnedOnAtomMatcher(); |
| *config.add_atom_matcher() = CreateScreenTurnedOffAtomMatcher(); |
| |
| auto scheduledJobPredicate = CreateScheduledJobPredicate(); |
| auto dimensions = scheduledJobPredicate.mutable_simple_predicate()->mutable_dimensions(); |
| dimensions->set_field(android::util::SCHEDULED_JOB_STATE_CHANGED); |
| dimensions->add_child()->set_field(2); // job name field. |
| |
| auto screenIsOffPredicate = CreateScreenIsOffPredicate(); |
| |
| auto isSyncingPredicate = CreateIsSyncingPredicate(); |
| auto syncDimension = isSyncingPredicate.mutable_simple_predicate()->mutable_dimensions(); |
| *syncDimension = CreateAttributionUidAndTagDimensions(android::util::SYNC_STATE_CHANGED, |
| {Position::FIRST}); |
| if (addExtraDimensionInCondition) { |
| syncDimension->add_child()->set_field(2 /* name field*/); |
| } |
| |
| config.set_hash_strings_in_metric_report(hashStringInReport); |
| *config.add_predicate() = scheduledJobPredicate; |
| *config.add_predicate() = screenIsOffPredicate; |
| *config.add_predicate() = isSyncingPredicate; |
| auto combinationPredicate = config.add_predicate(); |
| combinationPredicate->set_id(StringToId("CombinationPredicate")); |
| combinationPredicate->mutable_combination()->set_operation(LogicalOperation::AND); |
| addPredicateToPredicateCombination(screenIsOffPredicate, combinationPredicate); |
| addPredicateToPredicateCombination(isSyncingPredicate, combinationPredicate); |
| |
| auto metric = config.add_duration_metric(); |
| metric->set_bucket(FIVE_MINUTES); |
| metric->set_id(StringToId("scheduledJob")); |
| metric->set_what(scheduledJobPredicate.id()); |
| metric->set_condition(combinationPredicate->id()); |
| metric->set_aggregation_type(aggregationType); |
| auto dimensionWhat = metric->mutable_dimensions_in_what(); |
| dimensionWhat->set_field(android::util::SCHEDULED_JOB_STATE_CHANGED); |
| dimensionWhat->add_child()->set_field(2); // job name field. |
| *metric->mutable_dimensions_in_condition() = CreateAttributionUidAndTagDimensions( |
| android::util::SYNC_STATE_CHANGED, {Position::FIRST}); |
| return config; |
| } |
| |
| } // namespace |
| |
| /* |
| The following test has the following input. |
| |
| { 10000000002 10000000002 (8)9999[I], [S], job0[S], 1[I], } |
| { 10000000010 10000000010 (7)111[I], App1[S], 222[I], GMSCoreModule1[S], 222[I], GMSCoreModule2[S], ReadEmail[S], 1[I], } |
| { 10000000011 10000000011 (29)1[I], } |
| { 10000000040 10000000040 (29)2[I], } |
| { 10000000050 10000000050 (7)111[I], App1[S], 222[I], GMSCoreModule1[S], 222[I], GMSCoreModule2[S], ReadEmail[S], 0[I], } |
| { 10000000101 10000000101 (8)9999[I], [S], job0[S], 0[I], } |
| { 10000000102 10000000102 (29)1[I], } |
| { 10000000200 10000000200 (7)111[I], App1[S], 222[I], GMSCoreModule1[S], 222[I], GMSCoreModule2[S], ReadEmail[S], 1[I], } |
| { 10000000201 10000000201 (8)9999[I], [S], job2[S], 1[I], } |
| { 10000000400 10000000400 (7)111[I], App1[S], 222[I], GMSCoreModule1[S], 222[I], GMSCoreModule2[S], ReadDoc[S], 1[I], } |
| { 10000000401 10000000401 (7)333[I], App2[S], 222[I], GMSCoreModule1[S], 555[I], GMSCoreModule2[S], ReadEmail[S], 1[I], } |
| { 10000000450 10000000450 (29)2[I], } |
| { 10000000500 10000000500 (8)9999[I], [S], job2[S], 0[I], } |
| { 10000000600 10000000600 (8)8888[I], [S], job2[S], 1[I], } |
| { 10000000650 10000000650 (29)1[I], } |
| { 309999999999 309999999999 (7)111[I], App1[S], 222[I], GMSCoreModule1[S], 222[I], GMSCoreModule2[S], ReadDoc[S], 0[I], } |
| { 310000000100 310000000100 (29)2[I], } |
| { 310000000300 310000000300 (7)111[I], App1[S], 222[I], GMSCoreModule1[S], 222[I], GMSCoreModule2[S], ReadEmail[S], 0[I], } |
| { 310000000600 310000000600 (8)8888[I], [S], job1[S], 1[I], } |
| { 310000000640 310000000640 (29)1[I], } |
| { 310000000650 310000000650 (29)2[I], } |
| { 310000000700 310000000700 (7)333[I], App2[S], 222[I], GMSCoreModule1[S], 555[I], GMSCoreModule2[S], ReadEmail[S], 0[I], } |
| { 310000000850 310000000850 (8)8888[I], [S], job2[S], 0[I], } |
| { 310000000900 310000000900 (8)8888[I], [S], job1[S], 0[I], } |
| */ |
| TEST(DimensionInConditionE2eTest, TestDurationMetric_NoLink_AND_CombinationCondition) { |
| for (const bool hashStringInReport : { true, false }) { |
| for (bool isDimensionInConditionSubSetOfConditionTrackerDimension : { true, false }) { |
| for (auto aggregationType : {DurationMetric::MAX_SPARSE, DurationMetric::SUM}) { |
| ConfigKey cfgKey; |
| auto config = CreateDurationMetricConfig_NoLink_AND_CombinationCondition( |
| aggregationType, isDimensionInConditionSubSetOfConditionTrackerDimension, |
| hashStringInReport); |
| int64_t bucketStartTimeNs = 10000000000; |
| int64_t bucketSizeNs = |
| TimeUnitToBucketSizeInMillis( |
| config.duration_metric(0).bucket()) * 1000000LL; |
| |
| auto processor = CreateStatsLogProcessor( |
| bucketStartTimeNs, bucketStartTimeNs, config, cfgKey); |
| EXPECT_EQ(processor->mMetricsManagers.size(), 1u); |
| EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid()); |
| |
| std::vector<AttributionNodeInternal> attributions1 = { |
| CreateAttribution(111, "App1"), CreateAttribution(222, "GMSCoreModule1"), |
| CreateAttribution(222, "GMSCoreModule2")}; |
| |
| std::vector<AttributionNodeInternal> attributions2 = { |
| CreateAttribution(333, "App2"), CreateAttribution(222, "GMSCoreModule1"), |
| CreateAttribution(555, "GMSCoreModule2")}; |
| |
| std::vector<std::unique_ptr<LogEvent>> events; |
| |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + 11)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + 40)); |
| |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + 102)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + 450)); |
| |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + 650)); |
| events.push_back(CreateScreenStateChangedEvent( |
| android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + bucketSizeNs + 100)); |
| |
| events.push_back(CreateScreenStateChangedEvent( |
| android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + bucketSizeNs + 640)); |
| events.push_back(CreateScreenStateChangedEvent( |
| android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + bucketSizeNs + 650)); |
| |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(9999, "")}, "job0", bucketStartTimeNs + 2)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(9999, "")}, "job0",bucketStartTimeNs + 101)); |
| |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(9999, "")}, "job2", bucketStartTimeNs + 201)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(9999, "")}, "job2",bucketStartTimeNs + 500)); |
| |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(8888, "")}, "job2", bucketStartTimeNs + 600)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(8888, "")}, "job2", |
| bucketStartTimeNs + bucketSizeNs + 850)); |
| |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(8888, "")}, "job1", |
| bucketStartTimeNs + bucketSizeNs + 600)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(8888, "")}, "job1", |
| bucketStartTimeNs + bucketSizeNs + 900)); |
| |
| events.push_back(CreateSyncStartEvent(attributions1, "ReadEmail", |
| bucketStartTimeNs + 10)); |
| events.push_back(CreateSyncEndEvent(attributions1, "ReadEmail", |
| bucketStartTimeNs + 50)); |
| |
| events.push_back(CreateSyncStartEvent(attributions1, "ReadEmail", |
| bucketStartTimeNs + 200)); |
| events.push_back(CreateSyncEndEvent(attributions1, "ReadEmail", |
| bucketStartTimeNs + bucketSizeNs + 300)); |
| |
| events.push_back(CreateSyncStartEvent(attributions1, "ReadDoc", |
| bucketStartTimeNs + 400)); |
| events.push_back(CreateSyncEndEvent(attributions1, "ReadDoc", |
| bucketStartTimeNs + bucketSizeNs - 1)); |
| |
| events.push_back(CreateSyncStartEvent(attributions2, "ReadEmail", |
| bucketStartTimeNs + 401)); |
| events.push_back(CreateSyncEndEvent(attributions2, "ReadEmail", |
| bucketStartTimeNs + bucketSizeNs + 700)); |
| |
| sortLogEventsByTimestamp(&events); |
| |
| for (const auto& event : events) { |
| processor->OnLogEvent(event.get()); |
| } |
| |
| ConfigMetricsReportList reports; |
| vector<uint8_t> buffer; |
| processor->onDumpReport(cfgKey, bucketStartTimeNs + 2 * bucketSizeNs + 1, false, |
| true, ADB_DUMP, &buffer); |
| EXPECT_TRUE(buffer.size() > 0); |
| EXPECT_TRUE(reports.ParseFromArray(&buffer[0], buffer.size())); |
| backfillDimensionPath(&reports); |
| backfillStringInReport(&reports); |
| backfillStartEndTimestamp(&reports); |
| |
| EXPECT_EQ(reports.reports_size(), 1); |
| EXPECT_EQ(reports.reports(0).metrics_size(), 1); |
| StatsLogReport::DurationMetricDataWrapper metrics; |
| sortMetricDataByDimensionsValue( |
| reports.reports(0).metrics(0).duration_metrics(), &metrics); |
| if (aggregationType == DurationMetric::SUM) { |
| EXPECT_EQ(metrics.data_size(), 4); |
| auto data = metrics.data(0); |
| EXPECT_EQ(data.dimensions_in_what().field(), |
| android::util::SCHEDULED_JOB_STATE_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), |
| 2); // job name field |
| EXPECT_EQ(data.dimensions_in_what().value_tuple(). |
| dimensions_value(0).value_str(), |
| "job0"); // job name |
| ValidateAttributionUidAndTagDimension( |
| data.dimensions_in_condition(), |
| android::util::SYNC_STATE_CHANGED, 111, "App1"); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 40 - 11); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| |
| |
| data = metrics.data(1); |
| EXPECT_EQ(data.dimensions_in_what().field(), |
| android::util::SCHEDULED_JOB_STATE_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), |
| 2); // job name field |
| EXPECT_EQ(data.dimensions_in_what().value_tuple(). |
| dimensions_value(0).value_str(), |
| "job1"); // job name |
| ValidateAttributionUidAndTagDimension( |
| data.dimensions_in_condition(), |
| android::util::SYNC_STATE_CHANGED, 333, "App2"); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 10); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| |
| data = metrics.data(2); |
| EXPECT_EQ(data.dimensions_in_what().field(), |
| android::util::SCHEDULED_JOB_STATE_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), |
| 2); // job name field |
| EXPECT_EQ(data.dimensions_in_what().value_tuple(). |
| dimensions_value(0).value_str(), |
| "job2"); // job name |
| ValidateAttributionUidAndTagDimension( |
| data.dimensions_in_condition(), |
| android::util::SYNC_STATE_CHANGED, 111, "App1"); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 450 - 201 + bucketSizeNs - 650); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), 100); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| |
| data = metrics.data(3); |
| EXPECT_EQ(data.dimensions_in_what().field(), |
| android::util::SCHEDULED_JOB_STATE_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), |
| 2); // job name field |
| EXPECT_EQ(data.dimensions_in_what().value_tuple(). |
| dimensions_value(0).value_str(), |
| "job2"); // job name |
| ValidateAttributionUidAndTagDimension( |
| data.dimensions_in_condition(), |
| android::util::SYNC_STATE_CHANGED, 333, "App2"); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 450 - 401 + bucketSizeNs - 650); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), 100 + 650 - 640); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| } else { |
| EXPECT_EQ(metrics.data_size(), 4); |
| auto data = metrics.data(0); |
| EXPECT_EQ(data.dimensions_in_what().field(), |
| android::util::SCHEDULED_JOB_STATE_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), |
| 2); // job name field |
| EXPECT_EQ(data.dimensions_in_what().value_tuple(). |
| dimensions_value(0).value_str(), |
| "job0"); // job name |
| ValidateAttributionUidAndTagDimension( |
| data.dimensions_in_condition(), |
| android::util::SYNC_STATE_CHANGED, 111, "App1"); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 40 - 11); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| |
| data = metrics.data(1); |
| EXPECT_EQ(data.dimensions_in_what().field(), |
| android::util::SCHEDULED_JOB_STATE_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), |
| 2); // job name field |
| EXPECT_EQ(data.dimensions_in_what().value_tuple(). |
| dimensions_value(0).value_str(), |
| "job1"); // job name |
| ValidateAttributionUidAndTagDimension( |
| data.dimensions_in_condition(), |
| android::util::SYNC_STATE_CHANGED, 333, "App2"); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 10); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| |
| data = metrics.data(2); |
| EXPECT_EQ(data.dimensions_in_what().field(), |
| android::util::SCHEDULED_JOB_STATE_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), |
| 2); // job name field |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).value_str(), |
| "job2"); // job name |
| ValidateAttributionUidAndTagDimension( |
| data.dimensions_in_condition(), |
| android::util::SYNC_STATE_CHANGED, 111, "App1"); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 450 - 201); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), bucketSizeNs - 650 + 100); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| |
| data = metrics.data(3); |
| EXPECT_EQ(data.dimensions_in_what().field(), |
| android::util::SCHEDULED_JOB_STATE_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), |
| 2); // job name field |
| EXPECT_EQ(data.dimensions_in_what().value_tuple(). |
| dimensions_value(0).value_str(), |
| "job2"); // job name |
| ValidateAttributionUidAndTagDimension( |
| data.dimensions_in_condition(), |
| android::util::SYNC_STATE_CHANGED, 333, "App2"); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 450 - 401); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), bucketSizeNs - 650 + 110); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| } |
| } |
| } |
| } |
| } |
| |
| namespace { |
| |
| StatsdConfig CreateDurationMetricConfig_Link_AND_CombinationCondition( |
| DurationMetric::AggregationType aggregationType, bool addExtraDimensionInCondition) { |
| StatsdConfig config; |
| config.add_allowed_log_source("AID_ROOT"); // LogEvent defaults to UID of root. |
| *config.add_atom_matcher() = CreateStartScheduledJobAtomMatcher(); |
| *config.add_atom_matcher() = CreateFinishScheduledJobAtomMatcher(); |
| *config.add_atom_matcher() = CreateSyncStartAtomMatcher(); |
| *config.add_atom_matcher() = CreateSyncEndAtomMatcher(); |
| *config.add_atom_matcher() = CreateScreenTurnedOnAtomMatcher(); |
| *config.add_atom_matcher() = CreateScreenTurnedOffAtomMatcher(); |
| |
| auto scheduledJobPredicate = CreateScheduledJobPredicate(); |
| auto dimensions = scheduledJobPredicate.mutable_simple_predicate()->mutable_dimensions(); |
| *dimensions = CreateAttributionUidDimensions( |
| android::util::SCHEDULED_JOB_STATE_CHANGED, {Position::FIRST}); |
| dimensions->add_child()->set_field(2); // job name field. |
| |
| auto isSyncingPredicate = CreateIsSyncingPredicate(); |
| auto syncDimension = isSyncingPredicate.mutable_simple_predicate()->mutable_dimensions(); |
| *syncDimension = CreateAttributionUidDimensions( |
| android::util::SYNC_STATE_CHANGED, {Position::FIRST}); |
| if (addExtraDimensionInCondition) { |
| syncDimension->add_child()->set_field(2 /* name field*/); |
| } |
| |
| auto screenIsOffPredicate = CreateScreenIsOffPredicate(); |
| |
| *config.add_predicate() = scheduledJobPredicate; |
| *config.add_predicate() = screenIsOffPredicate; |
| *config.add_predicate() = isSyncingPredicate; |
| auto combinationPredicate = config.add_predicate(); |
| combinationPredicate->set_id(StringToId("CombinationPredicate")); |
| combinationPredicate->mutable_combination()->set_operation(LogicalOperation::AND); |
| addPredicateToPredicateCombination(screenIsOffPredicate, combinationPredicate); |
| addPredicateToPredicateCombination(isSyncingPredicate, combinationPredicate); |
| |
| auto metric = config.add_duration_metric(); |
| metric->set_bucket(FIVE_MINUTES); |
| metric->set_id(StringToId("scheduledJob")); |
| metric->set_what(scheduledJobPredicate.id()); |
| metric->set_condition(combinationPredicate->id()); |
| metric->set_aggregation_type(aggregationType); |
| *metric->mutable_dimensions_in_what() = CreateAttributionUidDimensions( |
| android::util::SCHEDULED_JOB_STATE_CHANGED, {Position::FIRST}); |
| |
| auto links = metric->add_links(); |
| links->set_condition(isSyncingPredicate.id()); |
| *links->mutable_fields_in_what() = |
| CreateAttributionUidDimensions( |
| android::util::SCHEDULED_JOB_STATE_CHANGED, {Position::FIRST}); |
| *links->mutable_fields_in_condition() = |
| CreateAttributionUidDimensions(android::util::SYNC_STATE_CHANGED, {Position::FIRST}); |
| return config; |
| } |
| |
| } // namespace |
| |
| TEST(DimensionInConditionE2eTest, TestDurationMetric_Link_AND_CombinationCondition) { |
| for (bool isFullLink : {true, false}) { |
| for (auto aggregationType : {DurationMetric::SUM, DurationMetric::MAX_SPARSE}) { |
| ConfigKey cfgKey; |
| auto config = CreateDurationMetricConfig_Link_AND_CombinationCondition( |
| aggregationType, !isFullLink); |
| int64_t bucketStartTimeNs = 10000000000; |
| int64_t bucketSizeNs = |
| TimeUnitToBucketSizeInMillis(config.duration_metric(0).bucket()) * 1000000LL; |
| |
| auto processor = CreateStatsLogProcessor( |
| bucketStartTimeNs, bucketStartTimeNs, config, cfgKey); |
| EXPECT_EQ(processor->mMetricsManagers.size(), 1u); |
| EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid()); |
| |
| std::vector<AttributionNodeInternal> attributions1 = { |
| CreateAttribution(111, "App1"), CreateAttribution(222, "GMSCoreModule1"), |
| CreateAttribution(222, "GMSCoreModule2")}; |
| |
| std::vector<AttributionNodeInternal> attributions2 = { |
| CreateAttribution(333, "App2"), CreateAttribution(222, "GMSCoreModule1"), |
| CreateAttribution(555, "GMSCoreModule2")}; |
| |
| std::vector<AttributionNodeInternal> attributions3 = { |
| CreateAttribution(444, "App3"), CreateAttribution(222, "GMSCoreModule1"), |
| CreateAttribution(555, "GMSCoreModule2")}; |
| |
| std::vector<std::unique_ptr<LogEvent>> events; |
| |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + 55)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + 120)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + 121)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + 450)); |
| |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + 501)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + bucketSizeNs + 100)); |
| |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(111, "App1")}, "job1", bucketStartTimeNs + 1)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(111, "App1")}, "job1",bucketStartTimeNs + 101)); |
| |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(333, "App2")}, "job2", bucketStartTimeNs + 201)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(333, "App2")}, "job2",bucketStartTimeNs + 500)); |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(333, "App2")}, "job2", bucketStartTimeNs + 600)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(333, "App2")}, "job2", |
| bucketStartTimeNs + bucketSizeNs + 850)); |
| |
| events.push_back( |
| CreateStartScheduledJobEvent({CreateAttribution(444, "App3")}, "job3", |
| bucketStartTimeNs + bucketSizeNs - 2)); |
| events.push_back( |
| CreateFinishScheduledJobEvent({CreateAttribution(444, "App3")}, "job3", |
| bucketStartTimeNs + bucketSizeNs + 900)); |
| |
| events.push_back(CreateSyncStartEvent(attributions1, "ReadEmail", |
| bucketStartTimeNs + 50)); |
| events.push_back(CreateSyncEndEvent(attributions1, "ReadEmail", |
| bucketStartTimeNs + 110)); |
| |
| events.push_back(CreateSyncStartEvent(attributions2, "ReadEmail", |
| bucketStartTimeNs + 300)); |
| events.push_back(CreateSyncEndEvent(attributions2, "ReadEmail", |
| bucketStartTimeNs + bucketSizeNs + 700)); |
| events.push_back(CreateSyncStartEvent(attributions2, "ReadDoc", |
| bucketStartTimeNs + 400)); |
| events.push_back(CreateSyncEndEvent(attributions2, "ReadDoc", |
| bucketStartTimeNs + bucketSizeNs - 1)); |
| |
| events.push_back(CreateSyncStartEvent(attributions3, "ReadDoc", |
| bucketStartTimeNs + 550)); |
| events.push_back(CreateSyncEndEvent(attributions3, "ReadDoc", |
| bucketStartTimeNs + 800)); |
| events.push_back(CreateSyncStartEvent(attributions3, "ReadDoc", |
| bucketStartTimeNs + bucketSizeNs - 1)); |
| events.push_back(CreateSyncEndEvent(attributions3, "ReadDoc", |
| bucketStartTimeNs + bucketSizeNs + 700)); |
| |
| sortLogEventsByTimestamp(&events); |
| |
| for (const auto& event : events) { |
| processor->OnLogEvent(event.get()); |
| } |
| |
| ConfigMetricsReportList reports; |
| vector<uint8_t> buffer; |
| processor->onDumpReport(cfgKey, bucketStartTimeNs + 2 * bucketSizeNs + 1, false, |
| true, ADB_DUMP, &buffer); |
| EXPECT_TRUE(buffer.size() > 0); |
| EXPECT_TRUE(reports.ParseFromArray(&buffer[0], buffer.size())); |
| backfillDimensionPath(&reports); |
| backfillStringInReport(&reports); |
| backfillStartEndTimestamp(&reports); |
| |
| EXPECT_EQ(reports.reports_size(), 1); |
| EXPECT_EQ(reports.reports(0).metrics_size(), 1); |
| StatsLogReport::DurationMetricDataWrapper metrics; |
| sortMetricDataByDimensionsValue( |
| reports.reports(0).metrics(0).duration_metrics(), &metrics); |
| |
| if (aggregationType == DurationMetric::SUM) { |
| EXPECT_EQ(metrics.data_size(), 3); |
| auto data = metrics.data(0); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 111); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 101 - 55); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| |
| data = metrics.data(1); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 333); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 450 - 300 + bucketSizeNs - 600); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), 100); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| |
| data = metrics.data(2); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 444); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 1); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), 100); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| } else { |
| EXPECT_EQ(metrics.data_size(), 3); |
| auto data = metrics.data(0); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 111); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 101 - 55); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| |
| data = metrics.data(1); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 333); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 450 - 300); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), bucketSizeNs - 600 + 100); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| |
| data = metrics.data(2); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 444); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 101); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| } |
| } |
| } |
| } |
| |
| namespace { |
| |
| StatsdConfig CreateDurationMetricConfig_PartialLink_AND_CombinationCondition( |
| DurationMetric::AggregationType aggregationType, bool hashStringInReport) { |
| StatsdConfig config; |
| config.add_allowed_log_source("AID_ROOT"); // LogEvent defaults to UID of root. |
| *config.add_atom_matcher() = CreateStartScheduledJobAtomMatcher(); |
| *config.add_atom_matcher() = CreateFinishScheduledJobAtomMatcher(); |
| *config.add_atom_matcher() = CreateSyncStartAtomMatcher(); |
| *config.add_atom_matcher() = CreateSyncEndAtomMatcher(); |
| *config.add_atom_matcher() = CreateScreenTurnedOnAtomMatcher(); |
| *config.add_atom_matcher() = CreateScreenTurnedOffAtomMatcher(); |
| |
| auto scheduledJobPredicate = CreateScheduledJobPredicate(); |
| auto dimensions = scheduledJobPredicate.mutable_simple_predicate()->mutable_dimensions(); |
| *dimensions = CreateAttributionUidDimensions( |
| android::util::SCHEDULED_JOB_STATE_CHANGED, {Position::FIRST}); |
| dimensions->add_child()->set_field(2); // job name field. |
| |
| auto isSyncingPredicate = CreateIsSyncingPredicate(); |
| auto syncDimension = isSyncingPredicate.mutable_simple_predicate()->mutable_dimensions(); |
| *syncDimension = CreateAttributionUidDimensions( |
| android::util::SYNC_STATE_CHANGED, {Position::FIRST}); |
| syncDimension->add_child()->set_field(2 /* name field*/); |
| |
| auto screenIsOffPredicate = CreateScreenIsOffPredicate(); |
| |
| config.set_hash_strings_in_metric_report(hashStringInReport); |
| *config.add_predicate() = scheduledJobPredicate; |
| *config.add_predicate() = screenIsOffPredicate; |
| *config.add_predicate() = isSyncingPredicate; |
| auto combinationPredicate = config.add_predicate(); |
| combinationPredicate->set_id(StringToId("CombinationPredicate")); |
| combinationPredicate->mutable_combination()->set_operation(LogicalOperation::AND); |
| addPredicateToPredicateCombination(screenIsOffPredicate, combinationPredicate); |
| addPredicateToPredicateCombination(isSyncingPredicate, combinationPredicate); |
| |
| auto metric = config.add_duration_metric(); |
| metric->set_bucket(FIVE_MINUTES); |
| metric->set_id(StringToId("scheduledJob")); |
| metric->set_what(scheduledJobPredicate.id()); |
| metric->set_condition(combinationPredicate->id()); |
| metric->set_aggregation_type(aggregationType); |
| *metric->mutable_dimensions_in_what() = CreateAttributionUidDimensions( |
| android::util::SCHEDULED_JOB_STATE_CHANGED, {Position::FIRST}); |
| *metric->mutable_dimensions_in_condition() = *syncDimension; |
| |
| |
| auto links = metric->add_links(); |
| links->set_condition(isSyncingPredicate.id()); |
| *links->mutable_fields_in_what() = |
| CreateAttributionUidDimensions( |
| android::util::SCHEDULED_JOB_STATE_CHANGED, {Position::FIRST}); |
| *links->mutable_fields_in_condition() = |
| CreateAttributionUidDimensions(android::util::SYNC_STATE_CHANGED, {Position::FIRST}); |
| return config; |
| } |
| |
| } // namespace |
| |
| TEST(DimensionInConditionE2eTest, TestDurationMetric_PartialLink_AND_CombinationCondition) { |
| for (const bool hashStringInReport : {true, false}) { |
| for (auto aggregationType : {DurationMetric::SUM, DurationMetric::MAX_SPARSE}) { |
| ConfigKey cfgKey; |
| auto config = |
| CreateDurationMetricConfig_PartialLink_AND_CombinationCondition( |
| aggregationType, hashStringInReport); |
| int64_t bucketStartTimeNs = 10000000000; |
| int64_t bucketSizeNs = |
| TimeUnitToBucketSizeInMillis(config.duration_metric(0).bucket()) * 1000000LL; |
| |
| auto processor = CreateStatsLogProcessor( |
| bucketStartTimeNs, bucketStartTimeNs, config, cfgKey); |
| EXPECT_EQ(processor->mMetricsManagers.size(), 1u); |
| EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid()); |
| |
| std::vector<AttributionNodeInternal> attributions1 = { |
| CreateAttribution(111, "App1"), CreateAttribution(222, "GMSCoreModule1"), |
| CreateAttribution(222, "GMSCoreModule2")}; |
| |
| std::vector<AttributionNodeInternal> attributions2 = { |
| CreateAttribution(333, "App2"), CreateAttribution(222, "GMSCoreModule1"), |
| CreateAttribution(555, "GMSCoreModule2")}; |
| |
| std::vector<AttributionNodeInternal> attributions3 = { |
| CreateAttribution(444, "App3"), CreateAttribution(222, "GMSCoreModule1"), |
| CreateAttribution(555, "GMSCoreModule2")}; |
| |
| std::vector<std::unique_ptr<LogEvent>> events; |
| |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + 55)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + 120)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + 121)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + 450)); |
| |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_OFF, |
| bucketStartTimeNs + 501)); |
| events.push_back(CreateScreenStateChangedEvent(android::view::DISPLAY_STATE_ON, |
| bucketStartTimeNs + bucketSizeNs + 100)); |
| |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(111, "App1")}, "job1", bucketStartTimeNs + 1)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(111, "App1")}, "job1",bucketStartTimeNs + 101)); |
| |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(333, "App2")}, "job2", bucketStartTimeNs + 201)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(333, "App2")}, "job2",bucketStartTimeNs + 500)); |
| events.push_back(CreateStartScheduledJobEvent( |
| {CreateAttribution(333, "App2")}, "job2", bucketStartTimeNs + 600)); |
| events.push_back(CreateFinishScheduledJobEvent( |
| {CreateAttribution(333, "App2")}, "job2", |
| bucketStartTimeNs + bucketSizeNs + 850)); |
| |
| events.push_back( |
| CreateStartScheduledJobEvent({CreateAttribution(444, "App3")}, "job3", |
| bucketStartTimeNs + bucketSizeNs - 2)); |
| events.push_back( |
| CreateFinishScheduledJobEvent({CreateAttribution(444, "App3")}, "job3", |
| bucketStartTimeNs + bucketSizeNs + 900)); |
| |
| events.push_back(CreateSyncStartEvent(attributions1, "ReadEmail", |
| bucketStartTimeNs + 50)); |
| events.push_back(CreateSyncEndEvent(attributions1, "ReadEmail", |
| bucketStartTimeNs + 110)); |
| |
| events.push_back(CreateSyncStartEvent(attributions2, "ReadEmail", |
| bucketStartTimeNs + 300)); |
| events.push_back(CreateSyncEndEvent(attributions2, "ReadEmail", |
| bucketStartTimeNs + bucketSizeNs + 700)); |
| events.push_back(CreateSyncStartEvent(attributions2, "ReadDoc", |
| bucketStartTimeNs + 400)); |
| events.push_back(CreateSyncEndEvent(attributions2, "ReadDoc", |
| bucketStartTimeNs + bucketSizeNs - 1)); |
| |
| events.push_back(CreateSyncStartEvent(attributions3, "ReadDoc", |
| bucketStartTimeNs + 550)); |
| events.push_back(CreateSyncEndEvent(attributions3, "ReadDoc", |
| bucketStartTimeNs + 800)); |
| events.push_back(CreateSyncStartEvent(attributions3, "ReadDoc", |
| bucketStartTimeNs + bucketSizeNs - 1)); |
| events.push_back(CreateSyncEndEvent(attributions3, "ReadDoc", |
| bucketStartTimeNs + bucketSizeNs + 700)); |
| |
| sortLogEventsByTimestamp(&events); |
| |
| for (const auto& event : events) { |
| processor->OnLogEvent(event.get()); |
| } |
| |
| ConfigMetricsReportList reports; |
| vector<uint8_t> buffer; |
| processor->onDumpReport(cfgKey, bucketStartTimeNs + 2 * bucketSizeNs + 1, false, |
| true, ADB_DUMP, &buffer); |
| EXPECT_TRUE(buffer.size() > 0); |
| EXPECT_TRUE(reports.ParseFromArray(&buffer[0], buffer.size())); |
| backfillDimensionPath(&reports); |
| backfillStringInReport(&reports); |
| backfillStartEndTimestamp(&reports); |
| |
| EXPECT_EQ(reports.reports_size(), 1); |
| EXPECT_EQ(reports.reports(0).metrics_size(), 1); |
| StatsLogReport::DurationMetricDataWrapper metrics; |
| sortMetricDataByDimensionsValue( |
| reports.reports(0).metrics(0).duration_metrics(), &metrics); |
| if (aggregationType == DurationMetric::SUM) { |
| EXPECT_EQ(metrics.data_size(), 4); |
| auto data = metrics.data(0); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 111); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_condition(), android::util::SYNC_STATE_CHANGED, 111); |
| EXPECT_EQ("ReadEmail", |
| data.dimensions_in_condition().value_tuple(). |
| dimensions_value(1).value_str()); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 101 - 55); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| |
| data = metrics.data(1); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 333); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_condition(), android::util::SYNC_STATE_CHANGED, 333); |
| EXPECT_EQ("ReadDoc", |
| data.dimensions_in_condition().value_tuple(). |
| dimensions_value(1).value_str()); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), bucketSizeNs - 1 - 600 + 50); |
| |
| data = metrics.data(2); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 333); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_condition(), android::util::SYNC_STATE_CHANGED, 333); |
| EXPECT_EQ("ReadEmail", |
| data.dimensions_in_condition().value_tuple(). |
| dimensions_value(1).value_str()); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 450 - 300 + bucketSizeNs - 600); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), 100); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| |
| data = metrics.data(3); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 444); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_condition(), android::util::SYNC_STATE_CHANGED, 444); |
| EXPECT_EQ("ReadDoc", |
| data.dimensions_in_condition().value_tuple(). |
| dimensions_value(1).value_str()); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 1); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), 100); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| } else { |
| EXPECT_EQ(metrics.data_size(), 4); |
| auto data = metrics.data(0); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 111); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_condition(), android::util::SYNC_STATE_CHANGED, 111); |
| EXPECT_EQ("ReadEmail", |
| data.dimensions_in_condition().value_tuple(). |
| dimensions_value(1).value_str()); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 101 - 55); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| |
| data = metrics.data(1); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 333); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_condition(), android::util::SYNC_STATE_CHANGED, 333); |
| EXPECT_EQ("ReadDoc", |
| data.dimensions_in_condition().value_tuple(). |
| dimensions_value(1).value_str()); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 50); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), bucketSizeNs - 1 - 600); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| |
| data = metrics.data(2); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 333); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_condition(), android::util::SYNC_STATE_CHANGED, 333); |
| EXPECT_EQ("ReadEmail", |
| data.dimensions_in_condition().value_tuple(). |
| dimensions_value(1).value_str()); |
| EXPECT_EQ(data.bucket_info_size(), 2); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 450 - 300); |
| EXPECT_EQ(data.bucket_info(1).duration_nanos(), bucketSizeNs - 600 + 100); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| |
| data = metrics.data(3); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_what(), android::util::SCHEDULED_JOB_STATE_CHANGED, 444); |
| ValidateAttributionUidDimension( |
| data.dimensions_in_condition(), android::util::SYNC_STATE_CHANGED, 444); |
| EXPECT_EQ("ReadDoc", |
| data.dimensions_in_condition().value_tuple(). |
| dimensions_value(1).value_str()); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).duration_nanos(), 101); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_elapsed_nanos(), |
| bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_elapsed_nanos(), |
| bucketStartTimeNs + 2 * bucketSizeNs); |
| } |
| } |
| } |
| } |
| |
| #else |
| GTEST_LOG_(INFO) << "This test does nothing.\n"; |
| #endif |
| |
| } // namespace statsd |
| } // namespace os |
| } // namespace android |