/aosp12/packages/modules/StatsD/statsd/tests/e2e/ |
H A D | GaugeMetric_e2e_pull_test.cpp | 81 processor->mPullerManager->ForceClearPullerCache(); in TEST() 90 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST() 92 processor->mPullerManager->mReceivers.begin()->second.front().intervalNs); in TEST() 94 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST() 220 processor->mPullerManager->ForceClearPullerCache(); in TEST() 317 processor->mPullerManager->ForceClearPullerCache(); in TEST() 326 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST() 425 processor->mPullerManager->ForceClearPullerCache(); in TEST() 435 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST() 543 processor->mPullerManager->ForceClearPullerCache(); in TEST() [all …]
|
H A D | ValueMetric_pull_e2e_test.cpp | 215 processor->mPullerManager->ForceClearPullerCache(); in TEST() 224 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST() 226 processor->mPullerManager->mReceivers.begin()->second.front().intervalNs); in TEST() 228 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST() 319 processor->mPullerManager->ForceClearPullerCache(); in TEST() 328 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST() 330 processor->mPullerManager->mReceivers.begin()->second.front().intervalNs); in TEST() 332 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST() 431 processor->mPullerManager->ForceClearPullerCache(); in TEST() 441 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST() [all …]
|
H A D | PartialBucket_e2e_test.cpp | 252 service->mPullerManager->RegisterPullAtomCallback( in TEST() 282 service->mPullerManager->RegisterPullAtomCallback( in TEST() 318 service->mPullerManager->RegisterPullAtomCallback( in TEST() 346 service->mPullerManager->RegisterPullAtomCallback( in TEST() 372 service->mPullerManager->RegisterPullAtomCallback( in TEST() 404 service->mPullerManager->RegisterPullAtomCallback( in TEST()
|
H A D | ConfigUpdate_e2e_test.cpp | 976 processor->mPullerManager->ForceClearPullerCache(); in TEST_F() 979 processor->mPullerManager->ForceClearPullerCache(); in TEST_F() 1011 sp<StatsPullerManager> pullerManager = processor->mPullerManager; in TEST_F() 1049 processor->mPullerManager->ForceClearPullerCache(); in TEST_F() 1052 processor->mPullerManager->ForceClearPullerCache(); in TEST_F() 1346 processor->mPullerManager->ForceClearPullerCache(); in TEST_F() 1349 processor->mPullerManager->ForceClearPullerCache(); in TEST_F() 1381 sp<StatsPullerManager> pullerManager = processor->mPullerManager; in TEST_F() 1405 processor->mPullerManager->ForceClearPullerCache(); in TEST_F() 1408 processor->mPullerManager->ForceClearPullerCache(); in TEST_F()
|
/aosp12/packages/modules/StatsD/statsd/src/ |
H A D | StatsService.cpp | 122 mPullerManager = new StatsPullerManager(); 126 mUidMap, mPullerManager, mAnomalyAlarmMonitor, mPeriodicAlarmMonitor, 354 mShellSubscriber = new ShellSubscriber(mUidMap, mPullerManager); in handleShellCommand() 829 if (mPullerManager->Pull(s, uids, getElapsedRealtimeNs(), &stats)) { in cmd_print_pulled_metrics() 856 int cleared = mPullerManager->ForceClearPullerCache(); in cmd_clear_puller_cache() 1048 mPullerManager->SetStatsCompanionService(statsCompanion); in statsCompanionReady() 1219 mPullerManager->RegisterPullAtomCallback(uid, atomTag, MillisToNano(coolDownMillis), in registerPullAtomCallback() 1237 mPullerManager->RegisterPullAtomCallback(uid, atomTag, MillisToNano(coolDownMillis), in registerNativePullAtomCallback() 1246 mPullerManager->UnregisterPullAtomCallback(uid, atomTag); in unregisterPullAtomCallback() 1259 mPullerManager->UnregisterPullAtomCallback(uid, atomTag); in unregisterNativePullAtomCallback() [all …]
|
H A D | StatsLogProcessor.cpp | 96 mPullerManager(pullerManager), in StatsLogProcessor() 104 mPullerManager->ForceClearPullerCache(); in StatsLogProcessor() 448 mPullerManager->ClearPullerCacheIfNecessary(curTimeSec * NS_PER_SEC); in OnLogEvent() 538 new MetricsManager(key, config, mTimeBaseNs, timestampNs, mUidMap, mPullerManager, in OnConfigUpdatedLocked() 774 mPullerManager->ForceClearPullerCache(); in OnConfigRemoved() 1069 mPullerManager->OnAlarmFired(timestampNs); in informPullAlarmFired()
|
H A D | StatsService.h | 349 sp<StatsPullerManager> mPullerManager; variable
|
H A D | StatsLogProcessor.h | 180 sp<StatsPullerManager> mPullerManager; // Reference to StatsPullerManager variable
|
/aosp12/packages/modules/StatsD/statsd/src/external/ |
H A D | StatsPullerManager.cpp | 49 mPullerManager(pullerManager), mPullerKey(pullerKey), mPuller(puller) { in PullAtomCallbackDeathCookie() 52 wp<StatsPullerManager> mPullerManager; member 59 sp<StatsPullerManager> thiz = cookie_->mPullerManager.promote(); in pullAtomCallbackDied()
|
/aosp12/packages/modules/StatsD/statsd/src/metrics/ |
H A D | GaugeMetricProducer.cpp | 87 mPullerManager(pullerManager), 140 mPullerManager->RegisterReceiver(mPullTagId, mConfigKey, this, getCurrentBucketEndTimeNs(), 155 mPullerManager->UnRegisterReceiver(mPullTagId, mConfigKey, this); in ~GaugeMetricProducer() 386 if (!mPullerManager->Pull(mPullTagId, mConfigKey, timestampNs, &allData)) { in pullAndMatchEventsLocked()
|
H A D | MetricsManager.cpp | 73 mPullerManager(pullerManager), in MetricsManager() 94 mPullerManager->RegisterPullUidProvider(mConfigKey, this); in MetricsManager() 110 mPullerManager->UnregisterPullUidProvider(mConfigKey, this); in ~MetricsManager() 138 mConfigKey, config, mUidMap, mPullerManager, anomalyAlarmMonitor, periodicAlarmMonitor, in updateConfig()
|
H A D | ValueMetricProducer.cpp | 97 mPullerManager(pullerManager), in ValueMetricProducer() 168 mPullerManager->RegisterReceiver(mPullTagId, mConfigKey, this, getCurrentBucketEndTimeNs(), in ValueMetricProducer() 189 mPullerManager->UnRegisterReceiver(mPullTagId, mConfigKey, this); in ~ValueMetricProducer() 608 if (!mPullerManager->Pull(mPullTagId, mConfigKey, timestampNs, &allData)) { in pullAndMatchEventsLocked()
|
H A D | GaugeMetricProducer.h | 165 sp<StatsPullerManager> mPullerManager; variable
|
H A D | MetricsManager.h | 181 sp<StatsPullerManager> mPullerManager; variable
|
H A D | ValueMetricProducer.h | 178 sp<StatsPullerManager> mPullerManager; variable
|