Home
last modified time | relevance | path

Searched refs:mPullerManager (Results 1 – 15 of 15) sorted by relevance

/aosp12/packages/modules/StatsD/statsd/tests/e2e/
H A DGaugeMetric_e2e_pull_test.cpp81 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 DValueMetric_pull_e2e_test.cpp215 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 DPartialBucket_e2e_test.cpp252 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 DConfigUpdate_e2e_test.cpp976 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 DStatsService.cpp122 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 DStatsLogProcessor.cpp96 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 DStatsService.h349 sp<StatsPullerManager> mPullerManager; variable
H A DStatsLogProcessor.h180 sp<StatsPullerManager> mPullerManager; // Reference to StatsPullerManager variable
/aosp12/packages/modules/StatsD/statsd/src/external/
H A DStatsPullerManager.cpp49 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 DGaugeMetricProducer.cpp87 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 DMetricsManager.cpp73 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 DValueMetricProducer.cpp97 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 DGaugeMetricProducer.h165 sp<StatsPullerManager> mPullerManager; variable
H A DMetricsManager.h181 sp<StatsPullerManager> mPullerManager; variable
H A DValueMetricProducer.h178 sp<StatsPullerManager> mPullerManager; variable