| /packages/modules/StatsD/statsd/tests/metrics/ |
| D | ValueMetricProducer_test.cpp | 1704 auto it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() local
1705 for (; it != valueProducer->mCurrentSlicedBucket.end(); it++) { in TEST()
1706 if (it != iter) { in TEST()
1711 for (; itBase != valueProducer->mCurrentBaseInfo.end(); it++) { in TEST()
1716 EXPECT_TRUE(it != iter); in TEST()
1718 auto& interval2 = it->second.intervals[0]; in TEST()
1720 EXPECT_EQ(2, it->first.getDimensionKeyInWhat().getValues()[0].mValue.int_value); in TEST()
1757 const auto& it = valueProducer->mCurrentSlicedBucket.begin(); in TEST() local
1758 ValueMetricProducer::Interval& interval1 = it->second.intervals[0]; in TEST()
1760 valueProducer->mCurrentBaseInfo.find(it->first.getDimensionKeyInWhat()) in TEST()
[all …]
|
| /packages/apps/TV/jni/ |
| D | tunertvinput_jni.cpp | 42 std::map<jlong, DvbManager *>::iterator it = sDvbManagers.find(deviceId); in Java_com_android_tv_tuner_TunerHal_nativeFinalize() local
43 if (it != sDvbManagers.end()) { in Java_com_android_tv_tuner_TunerHal_nativeFinalize()
44 delete it->second; in Java_com_android_tv_tuner_TunerHal_nativeFinalize()
45 sDvbManagers.erase(it); in Java_com_android_tv_tuner_TunerHal_nativeFinalize()
58 std::map<jlong, DvbManager *>::iterator it = sDvbManagers.find(deviceId); in Java_com_android_tv_tuner_TunerHal_nativeTune__JILjava_lang_String_2I() local
60 if (it == sDvbManagers.end()) { in Java_com_android_tv_tuner_TunerHal_nativeTune__JILjava_lang_String_2I()
64 dvbManager = it->second; in Java_com_android_tv_tuner_TunerHal_nativeTune__JILjava_lang_String_2I()
80 std::map<jlong, DvbManager *>::iterator it = sDvbManagers.find(deviceId); in Java_com_android_tv_tuner_TunerHal_nativeTune__JIILjava_lang_String_2I() local
82 if (it == sDvbManagers.end()) { in Java_com_android_tv_tuner_TunerHal_nativeTune__JIILjava_lang_String_2I()
87 dvbManager = it->second; in Java_com_android_tv_tuner_TunerHal_nativeTune__JIILjava_lang_String_2I()
[all …]
|
| /packages/modules/Virtualization/zipfuse/src/ |
| D | inode.rs | 242 let it = InodeTable::from_zip(&mut zip.unwrap()); in setup() localVariable
243 assert!(it.is_ok()); in setup()
244 it.unwrap() in setup()
247 fn check_dir(it: &InodeTable, parent: Inode, name: &str) -> Inode { in check_dir()
249 let inode = it.find(parent, &name); in check_dir()
252 let inode_data = it.get(inode); in check_dir()
260 fn check_file<'a>(it: &'a InodeTable, parent: Inode, name: &str) -> &'a InodeData { in check_file()
262 let inode = it.find(parent, &name); in check_file()
265 let inode_data = it.get(inode); in check_file()
274 let it = setup(|_| {}); in empty_zip_has_two_inodes() localVariable
[all …]
|
| /packages/modules/StatsD/statsd/src/config/ |
| D | ConfigManager.cpp | 69 auto it = thiz->mConfigReceivers.find(configKey); in configReceiverDied() local
70 if (it != thiz->mConfigReceivers.end() && it->second == pir) { in configReceiverDied()
103 auto it = thiz->mActiveConfigsChangedReceivers.find(uid); in activeConfigChangedReceiverDied() local
104 if (it != thiz->mActiveConfigsChangedReceivers.end() && it->second == pir) { in activeConfigChangedReceiverDied()
151 auto it = uidIt->second.find(key); in UpdateConfig() local
152 if (it == uidIt->second.end() && in UpdateConfig()
258 for (auto it = uidIt->second.begin(); it != uidIt->second.end(); ++it) { in RemoveConfigs() local
260 remove_saved_configs(*it); in RemoveConfigs()
261 removed.push_back(*it); in RemoveConfigs()
287 for (auto it = uidIt->second.begin(); it != uidIt->second.end();) { in RemoveAllConfigs() local
[all …]
|
| /packages/services/Car/cpp/watchdog/server/src/ |
| D | IoPerfCollection.cpp | 100 for (auto it = curUidProcessStats.topNIoBlockedProcesses.begin(); in getUidProcessStats() local
101 it != curUidProcessStats.topNIoBlockedProcesses.end(); ++it) { in getUidProcessStats()
102 if (it->count < ioBlockedTasksCnt) { in getUidProcessStats()
104 .emplace(it, in getUidProcessStats()
113 for (auto it = curUidProcessStats.topNMajorFaultProcesses.begin(); in getUidProcessStats() local
114 it != curUidProcessStats.topNMajorFaultProcesses.end(); ++it) { in getUidProcessStats()
115 if (it->count < stats.process.majorFaults) { in getUidProcessStats()
117 .emplace(it, in getUidProcessStats()
441 for (auto it = topNReads.begin(); it != topNReads.end(); ++it) { in processUidIoPerfData() local
442 const UidIoUsage* curRead = *it; in processUidIoPerfData()
[all …]
|
| D | IoOveruseMonitor.cpp | 200 for (auto it = perUidIoUsage.begin(); it != perUidIoUsage.end();) { in onPeriodicCollection() local
205 if (it->second.ios.sumWriteBytes() == 0) { in onPeriodicCollection()
206 it = perUidIoUsage.erase(it); in onPeriodicCollection()
209 seenUids.push_back(it->first); in onPeriodicCollection()
210 ++it; in onPeriodicCollection()
230 const auto& [it, wasInserted] = mUserPackageDailyIoUsageById.insert( in onPeriodicCollection()
232 dailyIoUsage = &it->second; in onPeriodicCollection()
398 if (const auto it = mOveruseListenersByUid.find(uid); it == mOveruseListenersByUid.end()) { in notifyNativePackagesLocked() local
401 listener = it->second.get(); in notifyNativePackagesLocked()
484 const auto processor = [&](ListenersByUidMap& listeners, ListenersByUidMap::const_iterator it) { in removeIoOveruseListener() argument
[all …]
|
| D | WatchdogProcessService.cpp | 318 for (auto it = clients.begin(); it != clients.end(); it++, count++) { in dump() local
320 it->toString().c_str()), in dump()
404 for (auto it = clients.begin(); it != clients.end();) { in terminate() local
405 it->unlinkToDeath(mBinderDeathRecipient); in terminate()
406 it = clients.erase(it); in terminate()
452 std::vector<ClientInfo>::const_iterator it) { in unregisterClientLocked() argument
453 it->unlinkToDeath(mBinderDeathRecipient); in unregisterClientLocked()
454 clients.erase(it); in unregisterClientLocked()
471 PingedClientMap::const_iterator it = clients.find(sessionId); in tellClientAliveLocked() local
472 if (it == clients.cend() || !it->second.matchesBinder(binder)) { in tellClientAliveLocked()
[all …]
|
| D | IoOveruseConfigs.cpp | 194 if (const auto it = seenCategoryMappings.find(meta.packageName); in isValidResourceOveruseConfig() local
195 it != seenCategoryMappings.end() && it->second != meta.appCategoryType) { in isValidResourceOveruseConfig()
199 << " and " << toString(it->second); in isValidResourceOveruseConfig()
268 if (const auto& it = mPerPackageThresholds.find(packageThreshold.name); in updatePerPackageThresholds() local
269 it != mPerPackageThresholds.end()) { in updatePerPackageThresholds()
373 if (const auto& it = mPerCategoryThresholds.find(category); in updatePerCategoryThresholds() local
374 it != mPerCategoryThresholds.end()) { in updatePerCategoryThresholds()
394 if (const auto& it = mAlertThresholds.find(alertThreshold); it != mAlertThresholds.end()) { in updateAlertThresholds() local
399 alertThreshold.durationInSeconds, it->writtenBytesPerSecond); in updateAlertThresholds()
686 if (const auto it = mSystemConfig.mPerPackageThresholds.find( in fetchThreshold() local
[all …]
|
| /packages/services/Car/cpp/telemetry/cartelemetryd/tests/ |
| D | FakeLooperWrapper.h | 49 for (auto it = mUptimeEntries.begin(); it != mUptimeEntries.end();) { in removeMessages() local
50 auto [entryUptime, entries] = *it; in removeMessages()
59 it = mUptimeEntries.erase(it); in removeMessages()
61 ++it; in removeMessages()
68 auto it = mUptimeEntries.begin(); in poll() local
69 if (it == mUptimeEntries.end() || it->second.empty()) { in poll()
72 auto entry = std::move(it->second.front()); in poll()
73 it->second.pop_front(); in poll()
74 if (it->second.empty()) { in poll()
76 mUptimeEntries.erase(it); in poll()
[all …]
|
| /packages/inputmethods/LatinIME/native/jni/src/dictionary/header/ |
| D | header_read_write_utils.cpp | 97 AttributeMap::const_iterator it = headerAttributes->find(keyVector); in readCodePointTable() local
98 if (it == headerAttributes->end()) { in readCodePointTable()
101 return it->second.data(); in readCodePointTable()
141 for (AttributeMap::const_iterator it = headerAttributes->begin(); in writeHeaderAttributes() local
142 it != headerAttributes->end(); ++it) { in writeHeaderAttributes()
143 if (it->first.empty() || it->second.empty()) { in writeHeaderAttributes()
147 if (!buffer->writeCodePointsAndAdvancePosition(&(it->first.at(0)), it->first.size(), in writeHeaderAttributes()
152 if (!buffer->writeCodePointsAndAdvancePosition(&(it->second.at(0)), it->second.size(), in writeHeaderAttributes()
193 AttributeMap::const_iterator it = headerAttributes->find(keyVector); in readCodePointVectorAttributeValue() local
194 if (it == headerAttributes->end()) { in readCodePointVectorAttributeValue()
[all …]
|
| /packages/modules/StatsD/statsd/src/metrics/ |
| D | MetricsManager.cpp | 105 for (auto it : mAllMetricProducers) { in ~MetricsManager() local
106 for (int atomId : it->getSlicedStateAtoms()) { in ~MetricsManager()
107 StateManager::getInstance().unregisterListener(atomId, it); in ~MetricsManager()
196 auto it = UidMap::sAidToUidMapping.find(source); in createAllLogSourcesFromConfig() local
197 if (it != UidMap::sAidToUidMapping.end()) { in createAllLogSourcesFromConfig()
198 mAllowedUid.push_back(it->second); in createAllLogSourcesFromConfig()
215 auto it = UidMap::sAidToUidMapping.find(pullSource); in createAllLogSourcesFromConfig() local
216 if (it != UidMap::sAidToUidMapping.end()) { in createAllLogSourcesFromConfig()
218 mDefaultPullUids.insert(it->second); in createAllLogSourcesFromConfig()
229 auto it = UidMap::sAidToUidMapping.find(pullPackage); in createAllLogSourcesFromConfig() local
[all …]
|
| D | MetricProducer.cpp | 178 for (auto& it : mEventActivationMap) { in evaluateActiveStateLocked() local
179 if (it.second->state == ActivationState::kActive && in evaluateActiveStateLocked()
180 elapsedTimestampNs > it.second->ttl_ns + it.second->start_ns) { in evaluateActiveStateLocked()
181 it.second->state = ActivationState::kNotActive; in evaluateActiveStateLocked()
183 if (it.second->state == ActivationState::kActive) { in evaluateActiveStateLocked()
202 auto it = mEventActivationMap.find(activationTrackerIndex); in activateLocked() local
203 if (it == mEventActivationMap.end()) { in activateLocked()
206 auto& activation = it->second; in activateLocked()
224 auto it = mEventDeactivationMap.find(deactivationTrackerIndex); in cancelEventActivationLocked() local
225 if (it == mEventDeactivationMap.end()) { in cancelEventActivationLocked()
[all …]
|
| /packages/modules/StatsD/statsd/src/ |
| D | StatsLogProcessor.cpp | 378 for (auto it = mMetricsManagers.begin(); it != mMetricsManagers.end(); it++) { in resetConfigsLocked() local
379 configKeys.push_back(it->first); in resetConfigsLocked()
534 const auto& it = mMetricsManagers.find(key); in OnConfigUpdatedLocked() local
536 if (!modularUpdate || it == mMetricsManagers.end()) { in OnConfigUpdatedLocked()
550 configValid = it->second->updateConfig(config, mTimeBaseNs, timestampNs, in OnConfigUpdatedLocked()
566 auto it = mMetricsManagers.find(key); in GetMetricsSize() local
567 if (it == mMetricsManagers.end()) { in GetMetricsSize()
571 return it->second->byteSize(); in GetMetricsSize()
607 auto it = mMetricsManagers.find(key); in onDumpReport() local
608 if (it != mMetricsManagers.end() && it->second->shouldPersistLocalHistory()) { in onDumpReport()
[all …]
|
| /packages/modules/Connectivity/tests/common/java/android/net/ |
| D | CaptivePortalDataTest.kt | 86 assertNotEqualsAfterChange { it.setRefreshTime(456L) } in testEquals()
87 assertNotEqualsAfterChange { it.setUserPortalUrl(Uri.parse("https://example.com/")) } in testEquals()
88 assertNotEqualsAfterChange { it.setUserPortalUrl(null) } in testEquals()
89 assertNotEqualsAfterChange { it.setVenueInfoUrl(Uri.parse("https://example.com/")) } in testEquals()
90 assertNotEqualsAfterChange { it.setVenueInfoUrl(null) } in testEquals()
91 assertNotEqualsAfterChange { it.setSessionExtendable(false) } in testEquals()
92 assertNotEqualsAfterChange { it.setBytesRemaining(789L) } in testEquals()
93 assertNotEqualsAfterChange { it.setExpiryTime(12L) } in testEquals()
94 assertNotEqualsAfterChange { it.setCaptive(false) } in testEquals()
97 assertNotEqualsAfterChange { it.setVenueFriendlyName("another friendly name") } in testEquals()
[all …]
|
| /packages/modules/StatsD/statsd/src/metrics/duration_helper/ |
| D | OringDurationTracker.cpp | 84 auto it = mStarted.find(key); in noteStop() local
85 if (it != mStarted.end()) { in noteStop()
86 (it->second)--; in noteStop()
87 if (stopAll || !mNested || it->second <= 0) { in noteStop()
88 mStarted.erase(it); in noteStop()
240 for (auto it = mStarted.begin(); it != mStarted.end();) { in onSlicedConditionMayChange() local
241 const auto& key = it->first; in onSlicedConditionMayChange()
245 ++it; in onSlicedConditionMayChange()
252 startedToPaused.push_back(*it); in onSlicedConditionMayChange()
253 it = mStarted.erase(it); in onSlicedConditionMayChange()
[all …]
|
| D | MaxDurationTracker.cpp | 184 for (auto it = mInfos.begin(); it != mInfos.end();) { in flushCurrentBucket() local
185 if (it->second.state == DurationState::kStopped) { in flushCurrentBucket()
187 it = mInfos.erase(it); in flushCurrentBucket()
189 ++it; in flushCurrentBucket()
257 auto it = mInfos.find(key); in noteConditionChanged() local
258 if (it == mInfos.end()) { in noteConditionChanged()
262 switch (it->second.state) { in noteConditionChanged()
268 it->second.state = DurationState::kPaused; in noteConditionChanged()
269 it->second.lastDuration += (timestamp - it->second.lastStartTime); in noteConditionChanged()
284 it->second.state = DurationState::kStarted; in noteConditionChanged()
[all …]
|
| /packages/modules/DnsResolver/ |
| D | DnsTlsQueryMap.cpp | 52 const auto [it, inserted] = mQueries.try_emplace(newId, q); in recordQuery()
57 return std::make_unique<QueryFuture>(q, it->second.result.get_future()); in recordQuery()
67 auto it = mQueries.find(newId); in markTried() local
68 if (it != mQueries.end()) { in markTried()
69 it->second.tries++; in markTried()
75 for (auto it = mQueries.begin(); it != mQueries.end();) { in cleanup() local
76 auto& p = it->second; in cleanup()
79 it = mQueries.erase(it); in cleanup()
81 ++it; in cleanup()
142 auto it = mQueries.find(id); in onResponse() local
[all …]
|
| /packages/inputmethods/LatinIME/native/dicttoolkit/src/utils/ |
| D | arguments_and_options.h | 46 const auto &it = mOptions.find(optionName); in getOptionValue() local
47 ASSERT(it != mOptions.end()); in getOptionValue()
48 return it->second; in getOptionValue()
52 const auto &it = mArguments.find(name); in hasArgument() local
53 return it != mArguments.end() && !it->second.empty(); in hasArgument()
57 const auto &it = mArguments.find(name); in getSingleArgument() local
58 ASSERT(it != mArguments.end() && !it->second.empty()); in getSingleArgument()
59 return it->second.front(); in getSingleArgument()
63 const auto &it = mArguments.find(name); in getVariableLengthArguments() local
64 ASSERT(it != mArguments.end()); in getVariableLengthArguments()
[all …]
|
| /packages/apps/DeskClock/src/com/android/deskclock/settings/ |
| D | SettingsActivity.kt | 109 val hasVibrator: Boolean = (it.getContext() in onCreatePreferences()
111 it.setVisible(hasVibrator) in onCreatePreferences()
213 it.setEntryValues(timezones.timeZoneIds) in loadTimeZoneList()
214 it.setEntries(timezones.timeZoneNames) in loadTimeZoneList()
215 it.setSummary(homeTimezonePref.getEntry()) in loadTimeZoneList()
216 it.setOnPreferenceChangeListener(this) in loadTimeZoneList()
223 val delay: String = it.getValue() in refresh()
224 updateAutoSnoozeSummary(it, delay) in refresh()
225 it.setOnPreferenceChangeListener(this) in refresh()
230 it.setSummary(it.getEntry()) in refresh()
[all …]
|
| /packages/modules/Connectivity/tests/cts/net/src/android/net/cts/ |
| D | NetworkAgentTest.kt | 151 it.what = what in <lambda>()
152 it.arg1 = arg1 in <lambda>()
153 it.arg2 = arg2 in <lambda>()
154 it.obj = obj in <lambda>()
184 agentsToCleanUp.forEach { it.unregister() } in tearDown()
185 callbacksToCleanUp.forEach { mCM.unregisterNetworkCallback(it) } in tearDown()
301 assertArrayEquals(thresholds, it.thresholds) in disconnect()
330 assertEquals(it.status, VALID_NETWORK) in disconnect()
335 assertEquals("", it.uri.toString()) in disconnect()
351 history.poll(DEFAULT_TIMEOUT_MS) { it is T }.also { in disconnect()
[all …]
|
| /packages/modules/Permission/PermissionController/src/com/android/permissioncontroller/permission/model/livedatatypes/ |
| D | LightAppPermGroup.kt | 73 val backgroundPermNames = permissions.mapNotNull { it.value.backgroundPermission } in <lambda>()
82 val foreground = AppPermSubGroup(permissions.filter { it.key in foregroundPermNames }, in <lambda>()
85 val background = AppPermSubGroup(permissions.filter { it.key in backgroundPermNames }, in <lambda>()
96 val hasBackgroundGroup = backgroundPermNames.any { permissions.contains(it) } in <lambda>()
125 permissions.any { it.value.isOneTime }) || in <lambda>()
142 val isUserSensitive = permissions.any { it.value.isUserSensitive } in <lambda>()
147 val isRevokeWhenRequested = permissions.any { it.value.isRevokeWhenRequested } in <lambda>()
165 val isGranted = specialLocationGrant ?: permissions.any { it.value.isGrantedIncludingAppOp } in <lambda>()
170 val isGrantedByDefault = permissions.any { it.value.isGrantedByDefault } in <lambda>()
175 val isPolicyFixed = permissions.any { it.value.isPolicyFixed } in <lambda>()
[all …]
|
| /packages/modules/StatsD/statsd/src/packages/ |
| D | UidMap.cpp | 80 auto it = mMap.find(std::make_pair(uid, packageName)); in hasApp() local
81 return it != mMap.end() && !it->second.deleted; in hasApp()
108 auto it = mMap.find(std::make_pair(uid, packageName)); in getAppVersion() local
109 if (it == mMap.end() || it->second.deleted) { in getAppVersion()
112 return it->second.versionCode; in getAppVersion()
172 auto it = mMap.find(std::make_pair(uid, appName)); in updateApp() local
173 if (it != mMap.end()) { in updateApp()
175 prevVersion = it->second.versionCode; in updateApp()
176 prevVersionString = it->second.versionString; in updateApp()
177 it->second.versionCode = versionCode; in updateApp()
[all …]
|
| /packages/services/Car/cpp/evs/manager/1.1/stats/ |
| D | CameraUsageStats.cpp | 45 auto it = mBufferHistory.find(b.bufferId); in updateFrameStatsOnArrival() local
46 if (it == mBufferHistory.end()) { in updateFrameStatsOnArrival()
49 it->second.timestamp = now; in updateFrameStatsOnArrival()
59 auto it = mBufferHistory.find(b.bufferId); in updateFrameStatsOnReturn() local
60 if (it == mBufferHistory.end()) { in updateFrameStatsOnReturn()
64 const auto roundtrip = now - it->second.timestamp; in updateFrameStatsOnReturn()
65 it->second.history.emplace(roundtrip); in updateFrameStatsOnReturn()
66 it->second.sum += roundtrip; in updateFrameStatsOnReturn()
67 if (it->second.history.size() > kMaxHistoryLength) { in updateFrameStatsOnReturn()
68 it->second.sum -= it->second.history.front(); in updateFrameStatsOnReturn()
[all …]
|
| /packages/modules/Connectivity/tests/unit/java/android/net/util/ |
| D | MultinetworkPolicyTrackerTest.kt | 67 doReturn(R.integer.config_networkAvoidBadWifi).`when`(it).getIdentifier( in <lambda>()
69 doReturn(0).`when`(it).getInteger(R.integer.config_networkAvoidBadWifi) in <lambda>()
73 doReturn(null).`when`(it).getActiveSubscriptionInfo(anyInt()) in <lambda>()
78 doReturn(Context.TELEPHONY_SERVICE).`when`(it) in <lambda>()
80 doReturn(telephonyManager).`when`(it).getSystemService(Context.TELEPHONY_SERVICE) in <lambda>()
81 if (it.getSystemService(TelephonyManager::class.java) == null) { in <lambda>()
83 doCallRealMethod().`when`(it).getSystemService(TelephonyManager::class.java) in <lambda>()
85 doReturn(subscriptionManager).`when`(it) in <lambda>()
87 doReturn(resolver).`when`(it).contentResolver in <lambda>()
88 doReturn(resources).`when`(it).resources in <lambda>()
[all …]
|
| /packages/services/Car/cpp/computepipe/runner/engine/ |
| D | DefaultEngine.cpp | 312 for (auto& it : mStreamManagers) { in broadcastStartRun() local
313 if (it.second->handleExecutionPhase(runEvent) != Status::SUCCESS) { in broadcastStartRun()
314 LOG(ERROR) << "Engine::failure to enter run phase for stream " << it.first; in broadcastStartRun()
318 successfulStreams.push_back(it.first); in broadcastStartRun()
332 for (auto& it : mInputManagers) { in broadcastStartRun() local
333 if (it.second->handleExecutionPhase(runEvent) != Status::SUCCESS) { in broadcastStartRun()
334 LOG(ERROR) << "Engine::failure to enter run phase for input manager " << it.first; in broadcastStartRun()
338 successfulInputs.push_back(it.first); in broadcastStartRun()
350 for (auto& it : mStreamManagers) { in broadcastStartRun() local
351 (void)it.second->handleExecutionPhase(runEvent); in broadcastStartRun()
[all …]
|