| // 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 CreateStatsdConfigForPushedEvent() { |
| StatsdConfig config; |
| *config.add_atom_matcher() = CreateMoveToBackgroundAtomMatcher(); |
| *config.add_atom_matcher() = CreateMoveToForegroundAtomMatcher(); |
| |
| auto atomMatcher = CreateSimpleAtomMatcher("", android::util::APP_START_CHANGED); |
| *config.add_atom_matcher() = atomMatcher; |
| |
| auto isInBackgroundPredicate = CreateIsInBackgroundPredicate(); |
| *isInBackgroundPredicate.mutable_simple_predicate()->mutable_dimensions() = |
| CreateDimensions(android::util::ACTIVITY_FOREGROUND_STATE_CHANGED, {1 /* uid field */ }); |
| *config.add_predicate() = isInBackgroundPredicate; |
| |
| auto gaugeMetric = config.add_gauge_metric(); |
| gaugeMetric->set_id(123456); |
| gaugeMetric->set_what(atomMatcher.id()); |
| gaugeMetric->set_condition(isInBackgroundPredicate.id()); |
| gaugeMetric->mutable_gauge_fields_filter()->set_include_all(false); |
| auto fieldMatcher = gaugeMetric->mutable_gauge_fields_filter()->mutable_fields(); |
| fieldMatcher->set_field(android::util::APP_START_CHANGED); |
| fieldMatcher->add_child()->set_field(3); // type (enum) |
| fieldMatcher->add_child()->set_field(4); // activity_name(str) |
| fieldMatcher->add_child()->set_field(7); // activity_start_msec(int64) |
| *gaugeMetric->mutable_dimensions_in_what() = |
| CreateDimensions(android::util::APP_START_CHANGED, {1 /* uid field */ }); |
| gaugeMetric->set_bucket(ONE_MINUTE); |
| |
| auto links = gaugeMetric->add_links(); |
| links->set_condition(isInBackgroundPredicate.id()); |
| auto dimensionWhat = links->mutable_fields_in_what(); |
| dimensionWhat->set_field(android::util::APP_START_CHANGED); |
| dimensionWhat->add_child()->set_field(1); // uid field. |
| auto dimensionCondition = links->mutable_fields_in_condition(); |
| dimensionCondition->set_field(android::util::ACTIVITY_FOREGROUND_STATE_CHANGED); |
| dimensionCondition->add_child()->set_field(1); // uid field. |
| return config; |
| } |
| |
| std::unique_ptr<LogEvent> CreateAppStartChangedEvent( |
| const int uid, const string& pkg_name, AppStartChanged::TransitionType type, |
| const string& activity_name, const string& calling_pkg_name, const bool is_instant_app, |
| int64_t activity_start_msec, uint64_t timestampNs) { |
| auto logEvent = std::make_unique<LogEvent>( |
| android::util::APP_START_CHANGED, timestampNs); |
| logEvent->write(uid); |
| logEvent->write(pkg_name); |
| logEvent->write(type); |
| logEvent->write(activity_name); |
| logEvent->write(calling_pkg_name); |
| logEvent->write(is_instant_app); |
| logEvent->write(activity_start_msec); |
| logEvent->init(); |
| return logEvent; |
| } |
| |
| } // namespace |
| |
| TEST(GaugeMetricE2eTest, TestMultipleFieldsForPushedEvent) { |
| auto config = CreateStatsdConfigForPushedEvent(); |
| int64_t bucketStartTimeNs = 10000000000; |
| int64_t bucketSizeNs = |
| TimeUnitToBucketSizeInMillis(config.gauge_metric(0).bucket()) * 1000000; |
| |
| ConfigKey cfgKey; |
| auto processor = CreateStatsLogProcessor(bucketStartTimeNs / NS_PER_SEC, config, cfgKey); |
| EXPECT_EQ(processor->mMetricsManagers.size(), 1u); |
| EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid()); |
| |
| int appUid1 = 123; |
| int appUid2 = 456; |
| std::vector<std::unique_ptr<LogEvent>> events; |
| events.push_back(CreateMoveToBackgroundEvent(appUid1, bucketStartTimeNs + 15)); |
| events.push_back(CreateMoveToForegroundEvent(appUid1, bucketStartTimeNs + bucketSizeNs + 250)); |
| events.push_back(CreateMoveToBackgroundEvent(appUid1, bucketStartTimeNs + bucketSizeNs + 350)); |
| events.push_back(CreateMoveToForegroundEvent( |
| appUid1, bucketStartTimeNs + 2 * bucketSizeNs + 100)); |
| |
| |
| events.push_back(CreateAppStartChangedEvent( |
| appUid1, "app1", AppStartChanged::WARM, "activity_name1", "calling_pkg_name1", |
| true /*is_instant_app*/, 101 /*activity_start_msec*/, bucketStartTimeNs + 10)); |
| events.push_back(CreateAppStartChangedEvent( |
| appUid1, "app1", AppStartChanged::HOT, "activity_name2", "calling_pkg_name2", |
| true /*is_instant_app*/, 102 /*activity_start_msec*/, bucketStartTimeNs + 20)); |
| events.push_back(CreateAppStartChangedEvent( |
| appUid1, "app1", AppStartChanged::COLD, "activity_name3", "calling_pkg_name3", |
| true /*is_instant_app*/, 103 /*activity_start_msec*/, bucketStartTimeNs + 30)); |
| events.push_back(CreateAppStartChangedEvent( |
| appUid1, "app1", AppStartChanged::WARM, "activity_name4", "calling_pkg_name4", |
| true /*is_instant_app*/, 104 /*activity_start_msec*/, |
| bucketStartTimeNs + bucketSizeNs + 30)); |
| events.push_back(CreateAppStartChangedEvent( |
| appUid1, "app1", AppStartChanged::COLD, "activity_name5", "calling_pkg_name5", |
| true /*is_instant_app*/, 105 /*activity_start_msec*/, |
| bucketStartTimeNs + 2 * bucketSizeNs)); |
| events.push_back(CreateAppStartChangedEvent( |
| appUid1, "app1", AppStartChanged::HOT, "activity_name6", "calling_pkg_name6", |
| false /*is_instant_app*/, 106 /*activity_start_msec*/, |
| bucketStartTimeNs + 2 * bucketSizeNs + 10)); |
| |
| events.push_back(CreateMoveToBackgroundEvent(appUid2, bucketStartTimeNs + bucketSizeNs + 10)); |
| events.push_back(CreateAppStartChangedEvent( |
| appUid2, "app2", AppStartChanged::COLD, "activity_name7", "calling_pkg_name7", |
| true /*is_instant_app*/, 201 /*activity_start_msec*/, |
| bucketStartTimeNs + 2 * bucketSizeNs + 10)); |
| |
| sortLogEventsByTimestamp(&events); |
| |
| for (const auto& event : events) { |
| processor->OnLogEvent(event.get()); |
| } |
| ConfigMetricsReportList reports; |
| vector<uint8_t> buffer; |
| processor->onDumpReport(cfgKey, bucketStartTimeNs + 3 * bucketSizeNs, &buffer); |
| EXPECT_TRUE(buffer.size() > 0); |
| EXPECT_TRUE(reports.ParseFromArray(&buffer[0], buffer.size())); |
| EXPECT_EQ(reports.reports_size(), 1); |
| EXPECT_EQ(reports.reports(0).metrics_size(), 1); |
| StatsLogReport::GaugeMetricDataWrapper gaugeMetrics; |
| sortMetricDataByDimensionsValue(reports.reports(0).metrics(0).gauge_metrics(), &gaugeMetrics); |
| EXPECT_EQ(gaugeMetrics.data_size(), 2); |
| |
| auto data = gaugeMetrics.data(0); |
| EXPECT_EQ(data.dimensions_in_what().field(), android::util::APP_START_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value_size(), 1); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), 1 /* uid field */); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).value_int(), appUid1); |
| EXPECT_EQ(data.bucket_info_size(), 3); |
| EXPECT_EQ(data.bucket_info(0).atom_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_nanos(), bucketStartTimeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_nanos(), bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).atom(0).app_start_changed().type(), AppStartChanged::HOT); |
| EXPECT_EQ(data.bucket_info(0).atom(0).app_start_changed().activity_name(), "activity_name2"); |
| EXPECT_EQ(data.bucket_info(0).atom(0).app_start_changed().activity_start_millis(), 102L); |
| |
| EXPECT_EQ(data.bucket_info(1).atom_size(), 1); |
| EXPECT_EQ(data.bucket_info(1).start_bucket_nanos(), bucketStartTimeNs + bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).end_bucket_nanos(), bucketStartTimeNs + 2 * bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(1).atom(0).app_start_changed().type(), AppStartChanged::WARM); |
| EXPECT_EQ(data.bucket_info(1).atom(0).app_start_changed().activity_name(), "activity_name4"); |
| EXPECT_EQ(data.bucket_info(1).atom(0).app_start_changed().activity_start_millis(), 104L); |
| |
| EXPECT_EQ(data.bucket_info(2).atom_size(), 1); |
| EXPECT_EQ(data.bucket_info(2).start_bucket_nanos(), bucketStartTimeNs + 2 * bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(2).end_bucket_nanos(), bucketStartTimeNs + 3 * bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(2).atom(0).app_start_changed().type(), AppStartChanged::COLD); |
| EXPECT_EQ(data.bucket_info(2).atom(0).app_start_changed().activity_name(), "activity_name5"); |
| EXPECT_EQ(data.bucket_info(2).atom(0).app_start_changed().activity_start_millis(), 105L); |
| |
| data = gaugeMetrics.data(1); |
| |
| EXPECT_EQ(data.dimensions_in_what().field(), android::util::APP_START_CHANGED); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value_size(), 1); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).field(), 1 /* uid field */); |
| EXPECT_EQ(data.dimensions_in_what().value_tuple().dimensions_value(0).value_int(), appUid2); |
| EXPECT_EQ(data.bucket_info_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).atom_size(), 1); |
| EXPECT_EQ(data.bucket_info(0).start_bucket_nanos(), bucketStartTimeNs + 2 * bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).end_bucket_nanos(), bucketStartTimeNs + 3 * bucketSizeNs); |
| EXPECT_EQ(data.bucket_info(0).atom(0).app_start_changed().type(), AppStartChanged::COLD); |
| EXPECT_EQ(data.bucket_info(0).atom(0).app_start_changed().activity_name(), "activity_name7"); |
| EXPECT_EQ(data.bucket_info(0).atom(0).app_start_changed().activity_start_millis(), 201L); |
| } |
| |
| #else |
| GTEST_LOG_(INFO) << "This test does nothing.\n"; |
| #endif |
| |
| } // namespace statsd |
| } // namespace os |
| } // namespace android |