| /packages/modules/StatsD/statsd/tests/e2e/ |
| D | GaugeMetric_e2e_pull_test.cpp | 82 processor->mPullerManager->ForceClearPullerCache(); in TEST()
91 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST()
93 processor->mPullerManager->mReceivers.begin()->second.front().intervalNs); in TEST()
95 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()
225 processor->mPullerManager->ForceClearPullerCache(); in TEST()
229 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST()
231 processor->mPullerManager->mReceivers.begin()->second.front().intervalNs); in TEST()
233 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()
345 processor->mPullerManager->ForceClearPullerCache(); in TEST()
443 processor->mPullerManager->ForceClearPullerCache(); in TEST()
[all …]
|
| 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()
337 processor->mPullerManager->ForceClearPullerCache(); in TEST()
346 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST()
348 processor->mPullerManager->mReceivers.begin()->second.front().intervalNs); in TEST()
350 processor->mPullerManager->mReceivers.begin()->second.front().nextPullTimeNs; in TEST()
475 processor->mPullerManager->ForceClearPullerCache(); in TEST()
485 ASSERT_EQ((size_t)1, processor->mPullerManager->mReceivers.size()); in TEST()
[all …]
|
| D | PartialBucket_e2e_test.cpp | 258 service->mPullerManager->RegisterPullAtomCallback( in TEST_F()
286 service->mPullerManager->RegisterPullAtomCallback( in TEST_F()
320 service->mPullerManager->RegisterPullAtomCallback( in TEST_F()
347 service->mPullerManager->RegisterPullAtomCallback( in TEST_F()
372 service->mPullerManager->RegisterPullAtomCallback( in TEST_F()
402 service->mPullerManager->RegisterPullAtomCallback( in TEST_F()
|
| D | StringReplace_e2e_test.cpp | 265 processor->mPullerManager->ForceClearPullerCache(); in TEST()
328 processor->mPullerManager->ForceClearPullerCache(); in TEST()
650 processor->mPullerManager->ForceClearPullerCache(); in TEST()
|
| D | ConfigUpdate_e2e_test.cpp | 1008 processor->mPullerManager->ForceClearPullerCache(); in TEST_F()
1011 processor->mPullerManager->ForceClearPullerCache(); in TEST_F()
1043 sp<StatsPullerManager> pullerManager = processor->mPullerManager; in TEST_F()
1081 processor->mPullerManager->ForceClearPullerCache(); in TEST_F()
1084 processor->mPullerManager->ForceClearPullerCache(); in TEST_F()
1386 processor->mPullerManager->ForceClearPullerCache(); in TEST_F()
1389 processor->mPullerManager->ForceClearPullerCache(); in TEST_F()
1421 sp<StatsPullerManager> pullerManager = processor->mPullerManager; in TEST_F()
1445 processor->mPullerManager->ForceClearPullerCache(); in TEST_F()
1448 processor->mPullerManager->ForceClearPullerCache(); in TEST_F()
|
| /packages/modules/StatsD/statsd/src/ |
| D | StatsService.cpp | 160 mPullerManager = new StatsPullerManager();
164 mUidMap, mPullerManager, mAnomalyAlarmMonitor, mPeriodicAlarmMonitor,
907 if (mPullerManager->Pull(s, uids, getElapsedRealtimeNs(), &stats)) { in cmd_print_pulled_metrics()
934 int cleared = mPullerManager->ForceClearPullerCache(); in cmd_clear_puller_cache()
1100 mPullerManager->SetStatsCompanionService(statsCompanion); in statsCompanionReady()
1365 mPullerManager->RegisterPullAtomCallback(uid, atomTag, MillisToNano(coolDownMillis), in registerPullAtomCallback()
1384 mPullerManager->RegisterPullAtomCallback(uid, atomTag, MillisToNano(coolDownMillis), in registerNativePullAtomCallback()
1394 mPullerManager->UnregisterPullAtomCallback(uid, atomTag); in unregisterPullAtomCallback()
1408 mPullerManager->UnregisterPullAtomCallback(uid, atomTag); in unregisterNativePullAtomCallback()
1475 mPullerManager->SetStatsCompanionService(nullptr); in statsCompanionServiceDiedImpl()
[all …]
|
| D | StatsLogProcessor.cpp | 106 mPullerManager(pullerManager), in StatsLogProcessor()
116 mPullerManager->ForceClearPullerCache(); in StatsLogProcessor()
458 mPullerManager->ClearPullerCacheIfNecessary(curTimeSec * NS_PER_SEC); in OnLogEvent()
579 new MetricsManager(key, config, mTimeBaseNs, timestampNs, mUidMap, mPullerManager, in OnConfigUpdatedLocked()
895 mPullerManager->ForceClearPullerCache(); in OnConfigRemoved()
1424 mPullerManager->OnAlarmFired(timestampNs); in informPullAlarmFired()
|
| D | StatsService.h | 437 sp<StatsPullerManager> mPullerManager; variable
|
| D | StatsLogProcessor.h | 219 sp<StatsPullerManager> mPullerManager; // Reference to StatsPullerManager variable
|
| /packages/modules/StatsD/statsd/tests/ |
| D | StatsService_test.cpp | 157 service->mPullerManager->RegisterPullAtomCallback(/*uid=*/0, ATOM_TAG, NS_PER_SEC, in TEST_F()
166 service->mProcessor->mPullerManager->ForceClearPullerCache(); in TEST_F()
|
| /packages/modules/StatsD/statsd/src/metrics/ |
| D | GaugeMetricProducer.cpp | 94 mPullerManager(pullerManager),
143 mPullerManager->RegisterReceiver(mPullTagId, mConfigKey, this, getCurrentBucketEndTimeNs(),
157 mPullerManager->UnRegisterReceiver(mPullTagId, mConfigKey, this); in ~GaugeMetricProducer()
410 if (!mPullerManager->Pull(mPullTagId, mConfigKey, timestampNs, &allData)) { in pullAndMatchEventsLocked()
|
| D | MetricsManager.cpp | 83 mPullerManager(pullerManager), in MetricsManager()
115 mPullerManager->RegisterPullUidProvider(mConfigKey, this); in MetricsManager()
131 mPullerManager->UnregisterPullUidProvider(mConfigKey, this); in ~MetricsManager()
169 mConfigKey, config, mUidMap, mPullerManager, anomalyAlarmMonitor, periodicAlarmMonitor, in updateConfig()
|
| D | ValueMetricProducer.cpp | 90 mPullerManager(pullOptions.pullerManager), in ValueMetricProducer()
135 mPullerManager->RegisterReceiver(mPullAtomId, mConfigKey, this, getCurrentBucketEndTimeNs(), in ValueMetricProducer()
154 mPullerManager->UnRegisterReceiver(mPullAtomId, mConfigKey, this); in ~ValueMetricProducer()
|
| D | GaugeMetricProducer.h | 182 sp<StatsPullerManager> mPullerManager; variable
|
| D | ValueMetricProducer.h | 254 const sp<StatsPullerManager> mPullerManager; variable
|
| D | MetricsManager.h | 223 sp<StatsPullerManager> mPullerManager; variable
|
| D | NumericValueMetricProducer.cpp | 173 if (!mPullerManager->Pull(mPullAtomId, mConfigKey, timestampNs, &allData)) { in pullAndMatchEventsLocked()
|