/packages/modules/Telephony/libs/TelephonyStatsLib/src/com/android/telephony/statslib/ |
D | StatsLibPulledAtomCallback.java | 73 void registerAtom(int atomTag) { in registerAtom() argument 74 registerAtom(atomTag, new EmptyCallback()); in registerAtom() 82 void registerAtom(int atomTag, PulledCallback callback) { in registerAtom() argument 83 if (!mRegisteredCallback.containsKey(atomTag)) { in registerAtom() 84 mStatsLibStorage.init(atomTag); in registerAtom() 85 mStatsLibStorage.loadFromFile(atomTag); in registerAtom() 87 atomTag, POLICY_PULL_DAILY, new MetricExecutor(), this); in registerAtom() 88 mRegisteredCallback.put(atomTag, callback); in registerAtom() 97 boolean isRegisteredAtom(int atomTag) { in isRegisteredAtom() argument 98 return mRegisteredCallback.containsKey(atomTag); in isRegisteredAtom() [all …]
|
/packages/modules/Wifi/service/java/com/android/server/wifi/ |
D | WifiPulledAtomLogger.java | 68 public void setPullAtomCallback(int atomTag) { in setPullAtomCallback() argument 71 + atomTag); in setPullAtomCallback() 75 atomTag, in setPullAtomCallback() 88 public int onPullAtom(int atomTag, List<StatsEvent> data) { in onPullAtom() argument 89 switch (atomTag) { in onPullAtom() 91 return handleWifiVersionPull(atomTag, data); in onPullAtom() 93 return handleWifiSettingsPull(atomTag, data); in onPullAtom() 95 return handleWifiComplexSettingsPull(atomTag, data); in onPullAtom() 97 return handleWifiConfiguredNetworkInfoPull(atomTag, data); in onPullAtom() 104 private int handleWifiVersionPull(int atomTag, List<StatsEvent> data) { in handleWifiVersionPull() argument [all …]
|
/packages/modules/StatsD/statsd/tests/e2e/ |
D | RestrictedEventMetric_e2e_test.cpp | 60 int32_t atomTag; member in android::os::statsd::RestrictedEventMetricE2eTest 95 atomTag = 999; in SetUp() 96 AtomMatcher restrictedAtomMatcher = CreateSimpleAtomMatcher("restricted_matcher", atomTag); in SetUp() 139 events.push_back(CreateRestrictedLogEvent(atomTag, configAddedTimeNs + 100)); in TEST_F() 140 events.push_back(CreateRestrictedLogEvent(atomTag, configAddedTimeNs + 200)); in TEST_F() 141 events.push_back(CreateRestrictedLogEvent(atomTag, configAddedTimeNs + 300)); in TEST_F() 156 EXPECT_THAT(queryDataResult, ElementsAre(to_string(atomTag), to_string(configAddedTimeNs + 100), in TEST_F() 159 to_string(atomTag), to_string(configAddedTimeNs + 200), in TEST_F() 162 to_string(atomTag), to_string(configAddedTimeNs + 300), in TEST_F() 178 AStatsEvent_setAtomId(statsEvent, atomTag); in TEST_F() [all …]
|
D | RestrictedConfig_e2e_test.cpp | 28 const int32_t atomTag = 666; variable 37 AtomMatcher atomMatcher = CreateSimpleAtomMatcher("testmatcher", atomTag); in CreateConfigWithOneMetric() 47 AtomMatcher atomMatcher = CreateSimpleAtomMatcher("testmatcher", atomTag); in CreateConfigWithTwoMetrics() 62 events.push_back(CreateNonRestrictedLogEvent(atomTag, configAddedTimeNs + 10 * NS_PER_SEC)); in CreateLogEvents() 63 events.push_back(CreateNonRestrictedLogEvent(atomTag, configAddedTimeNs + 20 * NS_PER_SEC)); in CreateLogEvents() 64 events.push_back(CreateNonRestrictedLogEvent(atomTag, configAddedTimeNs + 30 * NS_PER_SEC)); in CreateLogEvents()
|
/packages/modules/StatsD/statsd/src/external/ |
D | StatsPullerManager.h | 46 int atomTag; member 55 return atomTag < that.atomTag; 59 return uid == that.uid && atomTag == that.atomTag; 73 const int atomTag; member 77 return atomTag == that.atomTag ? configKey < that.configKey : atomTag < that.atomTag; 150 void RegisterPullAtomCallback(const int uid, const int32_t atomTag, int64_t coolDownNs, 154 void UnregisterPullAtomCallback(const int uid, const int32_t atomTag);
|
D | StatsPullerManager.cpp | 55 VLOG("Initiating pulling %d", key.atomTag); in pullImpl() 59 StatsdStats::getInstance().notePullFailed(key.atomTag); in pullImpl() 67 {{.uid = AID_STATSD, .atomTag = util::TRAIN_INFO}, new TrainInfoPuller()}, in StatsPullerManager() 99 PullerKey key = {.uid = uid, .atomTag = tagId}; in PullLocked() 166 auto& receivers = mReceivers[{.atomTag = tagId, .configKey = configKey}]; in RegisterReceiver() 201 auto receiversIt = mReceivers.find({.atomTag = tagId, .configKey = configKey}); in UnRegisterReceiver() 387 PullLocked(pullInfo.first->atomTag, pullInfo.first->configKey, elapsedTimeNs, &data) in onAlarmFiredSynchronous() 469 int tagId = pair.first.atomTag; in initPullerQueue() 473 PullerKey key = {.uid = uid, .atomTag = tagId}; in initPullerQueue() 521 void StatsPullerManager::RegisterPullAtomCallback(const int uid, const int32_t atomTag, in RegisterPullAtomCallback() argument [all …]
|
D | PullResultReceiver.cpp | 28 Status PullResultReceiver::pullFinished(int32_t atomTag, bool success, in pullFinished() argument 30 pullFinishCallback(atomTag, success, output); in pullFinished()
|
/packages/modules/StatsD/lib/libstatspull/ |
D | stats_pull_atom_callback.cpp | 117 Status onPullAtom(int32_t atomTag, in onPullAtom() argument 120 int successInt = mCallback(atomTag, &statsEventList, mCookie); in onPullAtom() 137 Status status = resultReceiver->pullFinished(atomTag, success, parcels); in onPullAtom() 140 resultReceiver->pullFinished(atomTag, /*success=*/false, emptyParcels); in onPullAtom() 243 void registerStatsPullAtomCallbackBlocking(int32_t atomTag, in registerStatsPullAtomCallbackBlocking() argument 253 atomTag, cb->getCoolDownMillis(), cb->getTimeoutMillis(), cb->getAdditiveFields(), cb); in registerStatsPullAtomCallbackBlocking() 256 void unregisterStatsPullAtomCallbackBlocking(int32_t atomTag, in unregisterStatsPullAtomCallbackBlocking() argument 264 statsService->unregisterNativePullAtomCallback(atomTag); in unregisterStatsPullAtomCallbackBlocking() 272 int atomTag; member 288 void registerCallback(int atomTag, std::shared_ptr<StatsPullAtomCallbackInternal> callback) { in registerCallback() argument [all …]
|
/packages/modules/StatsD/apex/tests/libstatspull/jni/ |
D | stats_pull_helper.cpp | 34 static AStatsManager_PullAtomCallbackReturn pullAtomCallback(int32_t atomTag, AStatsEventList* data, in pullAtomCallback() argument 40 AStatsEvent_setAtomId(event, atomTag); in pullAtomCallback() 49 JNIEnv* /*env*/, jobject /* this */, jint atomTag, jlong timeoutMillis, in Java_com_android_internal_os_statsd_libstats_LibStatsPullTests_setStatsPuller() argument 51 sAtomTag = atomTag; in Java_com_android_internal_os_statsd_libstats_LibStatsPullTests_setStatsPuller()
|
/packages/modules/Connectivity/service/src/com/android/metrics/ |
D | ConnectivitySampleMetricsHelper.java | 54 final int atomTag, in start() argument 60 mgr.setPullAtomCallback(atomTag, null /* metadata */, in start() 69 public int onPullAtom(final int atomTag, final List<StatsEvent> data) { in onPullAtom() argument 70 Log.d(TAG, "Sampling data for atom : " + atomTag); in onPullAtom()
|
/packages/services/Car/service/src/com/android/car/stats/ |
D | CarStatsService.java | 109 (atomTag, data) -> pullVmsClientStats(atomTag, data) in init() 162 private int pullVmsClientStats(int atomTag, List<StatsEvent> pulledData) { in pullVmsClientStats() argument 163 if (atomTag != CarStatsLog.VMS_CLIENT_STATS) { in pullVmsClientStats() 164 Slogf.w(TAG, "Unexpected atom tag: " + atomTag); in pullVmsClientStats() 170 atomTag, in pullVmsClientStats()
|
/packages/providers/MediaProvider/src/com/android/providers/media/metrics/ |
D | PulledMetrics.java | 127 public int onPullAtom(int atomTag, List<StatsEvent> data) { in onPullAtom() argument 129 List<StatsEvent> events = pullEvents(atomTag); in onPullAtom() 138 private List<StatsEvent> pullEvents(int atomTag) { in pullEvents() argument 139 switch (atomTag) { in pullEvents()
|
/packages/modules/StatsD/aidl/android/os/ |
D | IStatsd.aidl | 197 oneway void registerPullAtomCallback(int uid, int atomTag, long coolDownMillis, in registerPullAtomCallback() argument 207 oneway void registerNativePullAtomCallback(int atomTag, long coolDownMillis, long timeoutMillis, in registerNativePullAtomCallback() argument 213 oneway void unregisterPullAtomCallback(int uid, int atomTag); in unregisterPullAtomCallback() argument 220 oneway void unregisterNativePullAtomCallback(int atomTag); in unregisterNativePullAtomCallback() argument
|
D | IStatsManagerService.aidl | 133 oneway void registerPullAtomCallback(int atomTag, long coolDownMillis, long timeoutMillis, in registerPullAtomCallback() argument 137 oneway void unregisterPullAtomCallback(int atomTag); in unregisterPullAtomCallback() argument
|
/packages/modules/StatsD/framework/java/android/app/ |
D | StatsManager.java | 640 public void setPullAtomCallback(int atomTag, @Nullable PullAtomMetadata metadata, in setPullAtomCallback() argument 655 new PullAtomCallbackInternal(atomTag, callback, executor); in setPullAtomCallback() 657 atomTag, coolDownMillis, timeoutMillis, additiveFields, rec); in setPullAtomCallback() 672 public void clearPullAtomCallback(int atomTag) { in clearPullAtomCallback() argument 676 service.unregisterPullAtomCallback(atomTag); in clearPullAtomCallback() 695 public void onPullAtom(int atomTag, IPullAtomResultReceiver resultReceiver) { in onPullAtom() argument 700 int successInt = mCallback.onPullAtom(atomTag, data); in onPullAtom() 708 resultReceiver.pullFinished(atomTag, success, parcels); in onPullAtom() 714 resultReceiver.pullFinished(atomTag, /*success=*/false, emptyData); in onPullAtom() 842 int onPullAtom(int atomTag, @NonNull List<StatsEvent> data); in onPullAtom() argument
|
/packages/modules/StatsD/statsd/tests/external/ |
D | StatsPullerManager_test.cpp | 66 Status onPullAtom(int atomTag, in onPullAtom() argument 68 onPullAtomCalled(atomTag); in onPullAtom() 71 AStatsEvent* event = createSimpleEvent(atomTag, mUid); in onPullAtom() 86 resultReceiver->pullFinished(atomTag, /*success*/ true, parcels); in onPullAtom() 92 virtual void onPullAtomCalled(int atomTag) const {}; in onPullAtomCalled() 228 const int32_t atomTag = i % 2 == 0 ? pullTagId1 : pullTagId2; in TEST() local 229 pullerManager->RegisterReceiver(atomTag, configKey, receiver, bucketBoundary, in TEST()
|
/packages/services/Mms/src/com/android/mms/service/metrics/ |
D | MmsMetricsCollector.java | 119 public int onPullAtom(int atomTag, List<StatsEvent> data) { in onPullAtom() argument 120 switch (atomTag) { in onPullAtom() 126 Log.e(TAG, String.format("unexpected atom ID %d", atomTag)); in onPullAtom()
|
/packages/modules/StatsD/service/java/com/android/server/stats/ |
D | StatsManagerService.java | 217 public void registerPullAtomCallback(int atomTag, long coolDownMillis, long timeoutMillis, in registerPullAtomCallback() argument 221 Log.w(TAG, "Puller callback is null for atom " + atomTag); in registerPullAtomCallback() 225 PullerKey key = new PullerKey(callingUid, atomTag); in registerPullAtomCallback() 242 statsd.registerPullAtomCallback(callingUid, atomTag, coolDownMillis, timeoutMillis, in registerPullAtomCallback() 245 Log.e(TAG, "Failed to access statsd to register puller for atom " + atomTag); in registerPullAtomCallback() 252 public void unregisterPullAtomCallback(int atomTag) { in unregisterPullAtomCallback() argument 255 PullerKey key = new PullerKey(callingUid, atomTag); in unregisterPullAtomCallback() 270 statsd.unregisterPullAtomCallback(callingUid, atomTag); in unregisterPullAtomCallback() 272 Log.e(TAG, "Failed to access statsd to unregister puller for atom " + atomTag); in unregisterPullAtomCallback()
|
/packages/modules/Permission/service/java/com/android/safetycenter/logging/ |
D | SafetyCenterPullAtomCallback.java | 86 public int onPullAtom(int atomTag, List<StatsEvent> statsEvents) { in onPullAtom() argument 87 if (atomTag != SAFETY_STATE) { in onPullAtom() 88 Log.w(TAG, "Attempt to pull atom: " + atomTag + ", but only SAFETY_STATE is supported"); in onPullAtom()
|
/packages/modules/StatsD/tests/src/android/cts/statsd/validation/ |
D | ValidationTests.java | 120 final int atomTag = Atom.WAKELOCK_STATE_CHANGED_FIELD_NUMBER; in testPartialWakelock() local 133 MetricsUtils.DEVICE_SIDE_TEST_PACKAGE, atomTag, true); // True: uses attribution. in testPartialWakelock() local 363 final int atomTag = Atom.WAKELOCK_STATE_CHANGED_FIELD_NUMBER; in uploadWakelockDurationBatteryStatsConfig() local 429 .setField(atomTag) in uploadWakelockDurationBatteryStatsConfig() 441 .setAtomId(atomTag) in uploadWakelockDurationBatteryStatsConfig() 452 .setAtomId(atomTag) in uploadWakelockDurationBatteryStatsConfig() 463 .setAtomId(atomTag) in uploadWakelockDurationBatteryStatsConfig() 474 .setAtomId(atomTag) in uploadWakelockDurationBatteryStatsConfig()
|
/packages/services/Telecomm/src/com/android/server/telecom/metrics/ |
D | TelecomMetricsController.java | 132 public int onPullAtom(final int atomTag, final List<StatsEvent> data) { in onPullAtom() argument 133 if (mStats.containsKey(atomTag)) { in onPullAtom() 134 return Objects.requireNonNull(mStats.get(atomTag)).pull(data); in onPullAtom()
|
/packages/modules/AdServices/sdksandbox/service/java/com/android/server/sdksandbox/ |
D | SdkSandboxPulledAtoms.java | 71 (atomTag, data) -> { in initialize() 72 if (atomTag != SANDBOX_SDK_STORAGE) { in initialize()
|
/packages/modules/AppSearch/service/java/com/android/server/appsearch/stats/ |
D | StatsCollector.java | 98 public int onPullAtom(int atomTag, @NonNull List<StatsEvent> data) { in onPullAtom() argument 100 switch (atomTag) { in onPullAtom() 104 Log.e(TAG, "unexpected atom ID " + atomTag); in onPullAtom()
|
/packages/modules/StatsD/statsd/src/ |
D | StatsService.h | 182 int32_t uid, int32_t atomTag, int64_t coolDownMillis, int64_t timeoutMillis, 190 int32_t atomTag, int64_t coolDownMillis, int64_t timeoutMillis, 197 virtual Status unregisterPullAtomCallback(int32_t uid, int32_t atomTag) override; 202 virtual Status unregisterNativePullAtomCallback(int32_t atomTag) override;
|
D | StatsService.cpp | 1365 Status StatsService::registerPullAtomCallback(int32_t uid, int32_t atomTag, int64_t coolDownMillis, in registerPullAtomCallback() argument 1372 mPullerManager->RegisterPullAtomCallback(uid, atomTag, MillisToNano(coolDownMillis), in registerPullAtomCallback() 1379 int32_t atomTag, int64_t coolDownMillis, int64_t timeoutMillis, in registerNativePullAtomCallback() argument 1387 AIBinder_getCallingUid(), kPermissionRegisterPullAtom, atomTag)); in registerNativePullAtomCallback() 1391 mPullerManager->RegisterPullAtomCallback(uid, atomTag, MillisToNano(coolDownMillis), in registerNativePullAtomCallback() 1397 Status StatsService::unregisterPullAtomCallback(int32_t uid, int32_t atomTag) { in unregisterPullAtomCallback() argument 1401 mPullerManager->UnregisterPullAtomCallback(uid, atomTag); in unregisterPullAtomCallback() 1405 Status StatsService::unregisterNativePullAtomCallback(int32_t atomTag) { in unregisterNativePullAtomCallback() argument 1411 AIBinder_getCallingUid(), kPermissionRegisterPullAtom, atomTag)); in unregisterNativePullAtomCallback() 1415 mPullerManager->UnregisterPullAtomCallback(uid, atomTag); in unregisterNativePullAtomCallback()
|