| /packages/modules/StatsD/statsd/src/external/ |
| D | StatsPullerManager.h | 45 const int atomTag; member
54 return atomTag < that.atomTag;
58 return uid == that.uid && atomTag == that.atomTag;
119 void RegisterPullAtomCallback(const int uid, const int32_t atomTag, const int64_t coolDownNs,
123 void UnregisterPullAtomCallback(const int uid, const int32_t atomTag);
134 const int atomTag; member
138 return atomTag == that.atomTag ? configKey < that.configKey : atomTag < that.atomTag;
|
| D | StatsPullerManager.cpp | 73 StatsdStats::getInstance().notePullerCallbackRegistrationChanged(pullerKey.atomTag, in pullAtomCallbackDied()
88 {{.atomTag = util::TRAIN_INFO, .uid = AID_STATSD}, new TrainInfoPuller()}, in StatsPullerManager()
131 PullerKey key = {.atomTag = tagId, .uid = uid}; in PullLocked()
185 auto& receivers = mReceivers[{.atomTag = tagId, .configKey = configKey}]; in RegisterReceiver()
220 auto receiversIt = mReceivers.find({.atomTag = tagId, .configKey = configKey}); in UnRegisterReceiver()
276 bool pullSuccess = PullLocked(pullInfo.first->atomTag, pullInfo.first->configKey, in OnAlarmFired()
335 void StatsPullerManager::RegisterPullAtomCallback(const int uid, const int32_t atomTag, in RegisterPullAtomCallback() argument
340 VLOG("RegisterPullerCallback: adding puller for tag %d", atomTag); in RegisterPullAtomCallback()
343 ALOGW("SetPullAtomCallback called with null callback for atom %d.", atomTag); in RegisterPullAtomCallback()
347 StatsdStats::getInstance().notePullerCallbackRegistrationChanged(atomTag, /*registered=*/true); in RegisterPullAtomCallback()
[all …]
|
| D | PullResultReceiver.cpp | 28 Status PullResultReceiver::pullFinished(int32_t atomTag, bool success, in pullFinished() argument
30 pullFinishCallback(atomTag, success, output); in pullFinished()
|
| D | PullResultReceiver.h | 39 Status pullFinished(int32_t atomTag, bool success,
|
| D | StatsCallbackPuller.cpp | 62 int32_t atomTag, bool success, const vector<StatsEventParcel>& output) { in PullInternal() argument
|
| /packages/modules/StatsD/lib/libstatspull/ |
| D | stats_pull_atom_callback.cpp | 115 Status onPullAtom(int32_t atomTag, in onPullAtom() argument
118 int successInt = mCallback(atomTag, &statsEventList, mCookie); in onPullAtom()
138 Status status = resultReceiver->pullFinished(atomTag, success, parcels); in onPullAtom()
141 resultReceiver->pullFinished(atomTag, /*success=*/false, emptyParcels); in onPullAtom()
208 void registerStatsPullAtomCallbackBlocking(int32_t atomTag, in registerStatsPullAtomCallbackBlocking() argument
217 atomTag, cb->getCoolDownMillis(), cb->getTimeoutMillis(), cb->getAdditiveFields(), cb); in registerStatsPullAtomCallbackBlocking()
220 void unregisterStatsPullAtomCallbackBlocking(int32_t atomTag) { in unregisterStatsPullAtomCallbackBlocking() argument
227 statsService->unregisterNativePullAtomCallback(atomTag); in unregisterStatsPullAtomCallbackBlocking()
|
| /packages/modules/StatsD/framework/java/android/app/ |
| D | StatsManager.java | 494 public void setPullAtomCallback(int atomTag, @Nullable PullAtomMetadata metadata, in setPullAtomCallback() argument
509 new PullAtomCallbackInternal(atomTag, callback, executor); in setPullAtomCallback()
511 atomTag, coolDownMillis, timeoutMillis, additiveFields, rec); in setPullAtomCallback()
526 public void clearPullAtomCallback(int atomTag) { in clearPullAtomCallback() argument
530 service.unregisterPullAtomCallback(atomTag); in clearPullAtomCallback()
549 public void onPullAtom(int atomTag, IPullAtomResultReceiver resultReceiver) { in onPullAtom() argument
554 int successInt = mCallback.onPullAtom(atomTag, data); in onPullAtom()
562 resultReceiver.pullFinished(atomTag, success, parcels); in onPullAtom()
568 resultReceiver.pullFinished(atomTag, /*success=*/false, emptyData); in onPullAtom()
696 int onPullAtom(int atomTag, @NonNull List<StatsEvent> data); in onPullAtom() argument
|
| /packages/services/Car/service/src/com/android/car/stats/ |
| D | CarStatsService.java | 106 (atomTag, data) -> pullVmsClientStats(atomTag, data) in init()
155 private int pullVmsClientStats(int atomTag, List<StatsEvent> pulledData) { in pullVmsClientStats() argument
156 if (atomTag != CarStatsLog.VMS_CLIENT_STATS) { in pullVmsClientStats()
157 Slog.w(TAG, "Unexpected atom tag: " + atomTag); in pullVmsClientStats()
163 atomTag, in pullVmsClientStats()
|
| /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/StatsD/tests/src/android/cts/statsd/atom/ |
| D | DeviceAtomTestCase.java | 114 protected void createAndUploadConfig(int atomTag, boolean useAttribution) throws Exception { in createAndUploadConfig() argument
116 addAtomEvent(conf, atomTag, useAttribution); in createAndUploadConfig()
127 … protected void addAtomEvent(StatsdConfig.Builder conf, int atomTag, FieldValueMatcher.Builder fvm) in addAtomEvent() argument
132 addAtomEvent(conf, atomTag, Arrays.asList(fvm, fvmUid)); in addAtomEvent()
142 protected void addAtomEvent(StatsdConfig.Builder conf, int atomTag, in addAtomEvent() argument
151 addAtomEvent(conf, atomTag, Arrays.asList(fvmUid)); in addAtomEvent()
|
| D | AtomTestCase.java | 283 protected void createAndUploadConfig(int atomTag) throws Exception { in createAndUploadConfig() argument
285 addAtomEvent(conf, atomTag); in createAndUploadConfig()
601 protected void addAtomEvent(StatsdConfig.Builder conf, int atomTag) throws Exception { in addAtomEvent() argument
602 addAtomEvent(conf, atomTag, new ArrayList<FieldValueMatcher.Builder>()); in addAtomEvent()
612 protected void addAtomEvent(StatsdConfig.Builder conf, int atomTag, in addAtomEvent() argument
615 addAtomEvent(conf, atomTag, Arrays.asList(fvm)); in addAtomEvent()
|
| /packages/modules/StatsD/aidl/android/os/ |
| D | IStatsd.aidl | 193 oneway void registerPullAtomCallback(int uid, int atomTag, long coolDownMillis, in registerPullAtomCallback() argument
203 oneway void registerNativePullAtomCallback(int atomTag, long coolDownMillis, long timeoutMillis, in registerNativePullAtomCallback() argument
209 oneway void unregisterPullAtomCallback(int uid, int atomTag); in unregisterPullAtomCallback() argument
216 oneway void unregisterNativePullAtomCallback(int atomTag); in unregisterNativePullAtomCallback() argument
|
| D | IStatsManagerService.aidl | 131 oneway void registerPullAtomCallback(int atomTag, long coolDownMillis, long timeoutMillis, in registerPullAtomCallback() argument
135 oneway void unregisterPullAtomCallback(int atomTag); in unregisterPullAtomCallback() argument
|
| D | IPullAtomCallback.aidl | 29 oneway void onPullAtom(int atomTag, IPullAtomResultReceiver resultReceiver); in onPullAtom() argument
|
| D | IPullAtomResultReceiver.aidl | 30 oneway void pullFinished(int atomTag, boolean success, in StatsEventParcel[] output); in pullFinished() argument
|
| /packages/providers/MediaProvider/src/com/android/providers/media/metrics/ |
| D | PulledMetrics.java | 119 public int onPullAtom(int atomTag, List<StatsEvent> data) { in onPullAtom() argument
121 List<StatsEvent> events = pullEvents(atomTag); in onPullAtom()
130 private List<StatsEvent> pullEvents(int atomTag) { in pullEvents() argument
131 switch (atomTag) { in pullEvents()
|
| /packages/modules/StatsD/service/java/com/android/server/stats/ |
| D | StatsManagerService.java | 173 public void registerPullAtomCallback(int atomTag, long coolDownMillis, long timeoutMillis, in registerPullAtomCallback() argument
177 Log.w(TAG, "Puller callback is null for atom " + atomTag); in registerPullAtomCallback()
181 PullerKey key = new PullerKey(callingUid, atomTag); in registerPullAtomCallback()
198 statsd.registerPullAtomCallback(callingUid, atomTag, coolDownMillis, timeoutMillis, in registerPullAtomCallback()
201 Log.e(TAG, "Failed to access statsd to register puller for atom " + atomTag); in registerPullAtomCallback()
208 public void unregisterPullAtomCallback(int atomTag) { in unregisterPullAtomCallback() argument
211 PullerKey key = new PullerKey(callingUid, atomTag); in unregisterPullAtomCallback()
226 statsd.unregisterPullAtomCallback(callingUid, atomTag); in unregisterPullAtomCallback()
228 Log.e(TAG, "Failed to access statsd to unregister puller for atom " + atomTag); in unregisterPullAtomCallback()
|
| /packages/modules/StatsD/tests/src/android/cts/statsd/validation/ |
| D | ValidationTests.java | 94 final int atomTag = Atom.WAKELOCK_STATE_CHANGED_FIELD_NUMBER; in testPartialWakelock() local
108 createAndUploadConfig(atomTag, true); // True: uses attribution. in testPartialWakelock()
345 final int atomTag = Atom.WAKELOCK_STATE_CHANGED_FIELD_NUMBER; in uploadWakelockDurationBatteryStatsConfig() local
411 .setField(atomTag) in uploadWakelockDurationBatteryStatsConfig()
423 .setAtomId(atomTag) in uploadWakelockDurationBatteryStatsConfig()
434 .setAtomId(atomTag) in uploadWakelockDurationBatteryStatsConfig()
445 .setAtomId(atomTag) in uploadWakelockDurationBatteryStatsConfig()
456 .setAtomId(atomTag) in uploadWakelockDurationBatteryStatsConfig()
|
| /packages/modules/StatsD/statsd/src/ |
| D | StatsService.h | 173 int32_t uid, int32_t atomTag, int64_t coolDownMillis, int64_t timeoutMillis,
181 int32_t atomTag, int64_t coolDownMillis, int64_t timeoutMillis,
188 virtual Status unregisterPullAtomCallback(int32_t uid, int32_t atomTag) override;
193 virtual Status unregisterNativePullAtomCallback(int32_t atomTag) override;
|
| D | StatsService.cpp | 1213 Status StatsService::registerPullAtomCallback(int32_t uid, int32_t atomTag, int64_t coolDownMillis, in registerPullAtomCallback() argument
1219 mPullerManager->RegisterPullAtomCallback(uid, atomTag, MillisToNano(coolDownMillis), in registerPullAtomCallback()
1226 int32_t atomTag, int64_t coolDownMillis, int64_t timeoutMillis, in registerNativePullAtomCallback() argument
1233 AIBinder_getCallingUid(), kPermissionRegisterPullAtom, atomTag)); in registerNativePullAtomCallback()
1237 mPullerManager->RegisterPullAtomCallback(uid, atomTag, MillisToNano(coolDownMillis), in registerNativePullAtomCallback()
1243 Status StatsService::unregisterPullAtomCallback(int32_t uid, int32_t atomTag) { in unregisterPullAtomCallback() argument
1246 mPullerManager->UnregisterPullAtomCallback(uid, atomTag); in unregisterPullAtomCallback()
1250 Status StatsService::unregisterNativePullAtomCallback(int32_t atomTag) { in unregisterNativePullAtomCallback() argument
1255 AIBinder_getCallingUid(), kPermissionRegisterPullAtom, atomTag)); in unregisterNativePullAtomCallback()
1259 mPullerManager->UnregisterPullAtomCallback(uid, atomTag); in unregisterNativePullAtomCallback()
|
| /packages/modules/StatsD/statsd/tests/external/ |
| D | StatsPullerManager_test.cpp | 58 Status onPullAtom(int atomTag, in onPullAtom() argument
61 AStatsEvent* event = createSimpleEvent(atomTag, mUid); in onPullAtom()
71 resultReceiver->pullFinished(atomTag, /*success*/ true, parcels); in onPullAtom()
|
| /packages/modules/StatsD/apex/tests/libstatspull/src/com/android/internal/os/statsd/libstats/ |
| D | LibStatsPullTests.java | 282 private native void setStatsPuller(int atomTag, long timeoutMillis, long coolDownMillis, in setStatsPuller() argument
285 private native void clearStatsPuller(int atomTag); in clearStatsPuller() argument
|
| /packages/modules/StatsD/statsd/src/guardrail/ |
| D | StatsdStats.cpp | 571 void StatsdStats::noteAtomError(int atomTag, bool pull) { in noteAtomError() argument
574 mPulledAtomStats[atomTag].atomErrorCount++; in noteAtomError()
578 bool present = (mPushedAtomErrorStats.find(atomTag) != mPushedAtomErrorStats.end()); in noteAtomError()
581 mPushedAtomErrorStats[atomTag]++; in noteAtomError()
|
| /packages/modules/StatsD/statsd/tests/ |
| D | statsd_test_util.h | 376 const int32_t atomTag = 0 /*for puller only*/,
457 Status onPullAtom(int atomTag,
|
| D | statsd_test_util.cpp | 1100 const int32_t atomTag, const sp<UidMap> uidMap) { in CreateStatsLogProcessor() argument
1103 pullerManager->RegisterPullAtomCallback(/*uid=*/0, atomTag, NS_PER_SEC, NS_PER_SEC * 10, {}, in CreateStatsLogProcessor()
1597 Status FakeSubsystemSleepCallback::onPullAtom(int atomTag, in onPullAtom() argument
1603 AStatsEvent_setAtomId(event, atomTag); in onPullAtom()
1622 resultReceiver->pullFinished(atomTag, /*success=*/true, parcels); in onPullAtom()
|