| /packages/modules/StatsD/statsd/src/guardrail/ |
| D | StatsdStats.cpp | 176 it->second->deletion_time_sec = nowTimeSec; in noteConfigRemovedInternalLocked()
177 addToIceBoxLocked(it->second); in noteConfigRemovedInternalLocked()
190 it->second->reset_time_sec = getWallClockSec(); in noteConfigResetInternalLocked()
219 if (it->second->broadcast_sent_time_sec.size() == kMaxTimestampCount) { in noteBroadcastSent()
220 it->second->broadcast_sent_time_sec.pop_front(); in noteBroadcastSent()
222 it->second->broadcast_sent_time_sec.push_back(timeSec); in noteBroadcastSent()
236 auto& vec = activated ? it->second->activation_time_sec in noteActiveStatusChanged()
237 : it->second->deactivation_time_sec; in noteActiveStatusChanged()
284 if (it->second->data_drop_time_sec.size() == kMaxTimestampCount) { in noteDataDropped()
285 it->second->data_drop_time_sec.pop_front(); in noteDataDropped()
[all …]
|
| /packages/modules/StatsD/statsd/tests/metrics/ |
| D | ValueMetricProducer_test.cpp | 81 ASSERT_EQ(expectedValues.size(), mPastBuckets.begin()->second.size()); in assertPastBucketValuesSingleKey()
83 const vector<PastValueBucket>& buckets = mPastBuckets.begin()->second; in assertPastBucketValuesSingleKey()
300 valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()
302 valueProducer->mCurrentBaseInfo.begin()->second.baseInfos[0]; in TEST()
309 EXPECT_EQ(8, valueProducer->mPastBuckets.begin()->second[0].values[0].long_value); in TEST()
310 EXPECT_EQ(bucketSizeNs, valueProducer->mPastBuckets.begin()->second[0].mConditionTrueNs); in TEST()
317 curInterval = valueProducer->mCurrentSlicedBucket.begin()->second.intervals[0]; in TEST()
318 curBaseInfo = valueProducer->mCurrentBaseInfo.begin()->second.baseInfos[0]; in TEST()
325 ASSERT_EQ(2UL, valueProducer->mPastBuckets.begin()->second.size()); in TEST()
326 EXPECT_EQ(8, valueProducer->mPastBuckets.begin()->second[0].values[0].long_value); in TEST()
[all …]
|
| D | GaugeMetricProducer_test.cpp | 155 auto it = gaugeProducer.mCurrentSlicedBucket->begin()->second.front().mFields->begin(); in TEST()
162 ->second.back() in TEST()
171 it = gaugeProducer.mCurrentSlicedBucket->begin()->second.front().mFields->begin(); in TEST()
179 ASSERT_EQ(2UL, gaugeProducer.mPastBuckets.begin()->second.size()); in TEST()
180 it = gaugeProducer.mPastBuckets.begin()->second.back().mGaugeAtoms.front().mFields->begin(); in TEST()
191 ASSERT_EQ(3UL, gaugeProducer.mPastBuckets.begin()->second.size()); in TEST()
192 it = gaugeProducer.mPastBuckets.begin()->second.back().mGaugeAtoms.front().mFields->begin(); in TEST()
323 ->second.front() in TEST_P()
344 ->second.front() in TEST_P()
354 ->second.front() in TEST_P()
[all …]
|
| /packages/modules/StatsD/statsd/src/packages/ |
| D | UidMap.cpp | 81 return it != mMap.end() && !it->second.deleted; in hasApp()
98 if (kv.first.first == uid && !kv.second.deleted) { in getAppNamesFromUidLocked()
99 names.insert(returnNormalized ? normalizeAppName(kv.first.second) : kv.first.second); in getAppNamesFromUidLocked()
109 if (it == mMap.end() || it->second.deleted) { in getAppVersion()
112 return it->second.versionCode; in getAppVersion()
126 if (kv.second.deleted) { in updateMap()
127 deletedApps[kv.first] = kv.second; in updateMap()
143 mMap[kv.first] = kv.second; in updateMap()
175 prevVersion = it->second.versionCode; in updateApp()
176 prevVersionString = it->second.versionString; in updateApp()
[all …]
|
| /packages/modules/StatsD/statsd/src/ |
| D | stats_log_util.cpp | 477 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_TOTAL_PULL, (long long)pair.second.totalPull); in writePullerStatsToStream()
479 (long long)pair.second.totalPullFromCache); in writePullerStatsToStream()
481 (long long)pair.second.minPullIntervalSec); in writePullerStatsToStream()
483 (long long)pair.second.avgPullTimeNs); in writePullerStatsToStream()
485 (long long)pair.second.maxPullTimeNs); in writePullerStatsToStream()
487 (long long)pair.second.avgPullDelayNs); in writePullerStatsToStream()
489 (long long)pair.second.maxPullDelayNs); in writePullerStatsToStream()
490 protoOutput->write(FIELD_TYPE_INT64 | FIELD_ID_DATA_ERROR, (long long)pair.second.dataError); in writePullerStatsToStream()
492 (long long)pair.second.pullTimeout); in writePullerStatsToStream()
494 (long long)pair.second.pullExceedMaxDelay); in writePullerStatsToStream()
[all …]
|
| D | StatsLogProcessor.cpp | 128 itr.second->onAnomalyAlarmFired(timestampNs, alarmSet); in processFiredAnomalyAlarmsLocked()
137 itr.second->onPeriodicAlarmFired(timestampNs, alarmSet); in onPeriodicAlarmFired()
144 for (int i = indexRange.first; i <= indexRange.second; i++) { in mapIsolatedUidToHostUidIfNecessaryLocked()
458 bool isPrevActive = pair.second->isActive(); in OnLogEvent()
459 pair.second->onLogEvent(*event); in OnLogEvent()
460 bool isCurActive = pair.second->isActive(); in OnLogEvent()
465 activeConfigs->second.push_back(configId); in OnLogEvent()
478 flushIfNecessaryLocked(pair.first, *(pair.second)); in OnLogEvent()
486 if (elapsedRealtimeNs - lastBroadcastTime->second < in OnLogEvent()
495 if (mSendActivationBroadcast(uid, activeConfigs->second)) { in OnLogEvent()
[all …]
|
| /packages/modules/StatsD/statsd/src/config/ |
| D | ConfigManager.cpp | 70 if (it != thiz->mConfigReceivers.end() && it->second == pir) { in configReceiverDied()
104 if (it != thiz->mActiveConfigsChangedReceivers.end() && it->second == pir) { in activeConfigChangedReceiverDied()
126 UpdateConfig(pair.first, pair.second); in Startup()
151 auto it = uidIt->second.find(key); in UpdateConfig()
152 if (it == uidIt->second.end() && in UpdateConfig()
153 uidIt->second.size() >= StatsdStats::kMaxConfigCountPerUid) { in UpdateConfig()
160 if (uidIt != mConfigs.end() && uidIt->second.find(key) != uidIt->second.end() && in UpdateConfig()
223 if (uidIt != mConfigs.end() && uidIt->second.find(key) != uidIt->second.end()) { in RemoveConfig()
225 uidIt->second.erase(key); in RemoveConfig()
258 for (auto it = uidIt->second.begin(); it != uidIt->second.end(); ++it) { in RemoveConfigs()
[all …]
|
| /packages/modules/Wifi/service/tests/wifitests/src/com/android/server/wifi/rtt/ |
| D | RttServiceImplTest.java | 286 mDut.onRangingResults(mIntCaptor.getValue(), results.get(i).second); in testRangingFlow()
290 verify(mockCallback).onRangingResults(results.get(i).second); in testRangingFlow()
294 mDut.onRangingResults(mIntCaptor.getValue(), results.get(i).second); in testRangingFlow()
301 verify(mockMetrics).recordResult(eq(requests[i]), eq(results.get(i).second), in testRangingFlow()
359 RangingResult removed = results.second.remove(results.second.size() - 1); in testRangingFlowUsingAwarePeerHandles()
360 results.second.add( in testRangingFlowUsingAwarePeerHandles()
372 assertEquals(results.second, mListCaptor.getValue()); in testRangingFlowUsingAwarePeerHandles()
373 assertTrue(compareListContentsNoOrdering(results.second, mListCaptor.getValue())); in testRangingFlowUsingAwarePeerHandles()
427 mDut.onRangingResults(mIntCaptor.getValue(), results.get(i).second); in testRangingFlowNativeFailure()
431 verify(mockCallback).onRangingResults(results.get(i).second); in testRangingFlowNativeFailure()
[all …]
|
| /packages/modules/StatsD/statsd/src/anomaly/ |
| D | DurationAnomalyTracker.cpp | 49 mAlarmMonitor->remove(itr->second); in startAlarm()
67 if (itr->second != nullptr && timestampNs >= (int64_t)NS_PER_SEC * itr->second->timestampSec) { in stopAlarm()
70 itr->second->timestampSec); in stopAlarm()
73 mAlarmMonitor->remove(itr->second); in stopAlarm()
81 mAlarmMonitor->remove(itr.second); in cancelAllAlarms()
98 if (firedAlarms.count(kv.second) > 0) { in informAlarmsFired()
99 matchedAlarms.insert({kv.first, kv.second}); in informAlarmsFired()
107 mAlert.trigger_if_sum_gt() + (timestampNs / NS_PER_SEC) - kv.second->timestampSec); in informAlarmsFired()
109 firedAlarms.erase(kv.second); // No one else can also own it, so we're done with it. in informAlarmsFired()
|
| D | AnomalyTracker.cpp | 108 subtractValueFromSum(key, itr->second); in addPastBucket()
109 itr->second = bucketValue; in addPastBucket()
146 subtractValueFromSum(keyValuePair.first, keyValuePair.second); in subtractBucketFromSum()
157 itr->second -= bucketValue; in subtractValueFromSum()
158 if (itr->second == 0) { in subtractValueFromSum()
169 mSumOverPastBuckets[keyValuePair.first] += keyValuePair.second; in addBucketToSum()
186 return itr == bucket->end() ? 0 : itr->second; in getPastBucketValue()
192 return itr->second; in getSumOverPastBuckets()
253 return timestampNs < (it->second * (int64_t)NS_PER_SEC); in isInRefractoryPeriod()
283 if (it.second < systemElapsedTimeNs / NS_PER_SEC) { in writeAlertMetadataToProto()
[all …]
|
| /packages/providers/MediaProvider/jni/ |
| D | RedactionInfo.cpp | 36 if (ranges[i].second >= ranges[i + 1].first) { in mergeOverlappingRedactionRanges()
38 ranges[i + 1].second = std::max(ranges[i].second, ranges[i + 1].second); in mergeOverlappingRedactionRanges()
41 ranges[i].second = LONG_MAX; in mergeOverlappingRedactionRanges()
60 if (ranges[i].first == ranges[i].second) { in removeZeroSizeRedactionRanges()
64 ranges[i].second = LONG_MAX; in removeZeroSizeRedactionRanges()
82 if (!isRedactionNeeded() || off >= redaction_ranges_.back().second || in hasOverlapWithReadRequest()
98 redaction_ranges_[i].second = static_cast<off64_t>(redaction_ranges[2 * i + 1]); in processRedactionRanges()
127 if (iter->second > start && iter->first < end) { in getOverlappingRedactionRanges()
176 sorted_indices.push_back(rr->at(i).second); in getReadRanges()
191 if (read_end > rr->at(num_ranges - 1).second) { in getReadRanges()
|
| /packages/apps/StorageManager/robotests/src/com/android/storagemanager/utils/ |
| D | PreferenceListCacheTest.java | 64 Preference second = createPreference("second"); in testCacheAndRestoreAllPreferences() local
66 Preference[] preferences = new Preference[] {first, second, third}; in testCacheAndRestoreAllPreferences()
71 assertEquals(second, mCache.getCachedPreference("second")); in testCacheAndRestoreAllPreferences()
81 Preference second = createPreference("second"); in testRestoreSomePreferences() local
83 Preference[] preferences = new Preference[] {first, second, third}; in testRestoreSomePreferences()
88 assertEquals(second, mCache.getCachedPreference("second")); in testRestoreSomePreferences()
99 Preference second = createPreference("second"); in testRestoreZeroPreferences() local
101 Preference[] preferences = new Preference[] {first, second, third}; in testRestoreZeroPreferences()
110 verify(mGroup).removePreference(eq(second)); in testRestoreZeroPreferences()
117 Preference second = createPreference("first"); in testKeyCollisionThrows() local
[all …]
|
| /packages/modules/StatsD/statsd/src/metrics/duration_helper/ |
| D | MaxDurationTracker.cpp | 147 if (pair.second.state == kStarted) { in hasAccumulatingDuration()
185 if (it->second.state == DurationState::kStopped) { in flushCurrentBucket()
231 if (pair.second.state == kStopped) { in onSlicedConditionMayChange()
235 mConditionTrackerIndex, pair.second.conditionKeys, in onSlicedConditionMayChange()
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()
285 it->second.lastStartTime = timestamp; in noteConditionChanged()
300 if (it->second.state == DurationState::kStarted) { in predictAnomalyTimestampNs()
[all …]
|
| D | OringDurationTracker.cpp | 86 (it->second)--; in noteStop()
87 if (stopAll || !mNested || it->second <= 0) { in noteStop()
105 (pausedIt->second)--; in noteStop()
106 if (stopAll || !mNested || pausedIt->second <= 0) { in noteStop()
167 if (durationPassesThreshold(uploadThreshold, durationIt.second.mDuration)) { in flushCurrentBucket()
171 current_info.mDuration = durationIt.second.mDuration; in flushCurrentBucket()
175 durationIt.second.mDurationFullBucket += durationIt.second.mDuration; in flushCurrentBucket()
186 durationIt.second.mDurationFullBucket = 0; in flushCurrentBucket()
188 durationIt.second.mDuration = 0; in flushCurrentBucket()
249 mWizard->query(mConditionTrackerIndex, condIt->second, in onSlicedConditionMayChange()
[all …]
|
| /packages/services/Car/cpp/evs/manager/1.1/stats/ |
| D | CameraUsageStats.cpp | 49 it->second.timestamp = now; in updateFrameStatsOnArrival()
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()
69 it->second.history.pop(); in updateFrameStatsOnReturn()
72 if (roundtrip > it->second.peak) { in updateFrameStatsOnReturn()
73 it->second.peak = roundtrip; in updateFrameStatsOnReturn()
|
| /packages/apps/Contacts/tests/src/com/android/contacts/model/ |
| D | RawContactDeltaListTests.java | 380 final RawContactDeltaList second = buildSet(buildBeforeEntity(mContext, CONTACT_BOB, in testMergeDataRemoteInsert() local
384 final RawContactDeltaList merged = RawContactDeltaList.mergeAfter(second, first); in testMergeDataRemoteInsert()
385 assertEquals("Unexpected change when merging", second, merged); in testMergeDataRemoteInsert()
391 final RawContactDeltaList second = buildSet(buildBeforeEntity(mContext, CONTACT_BOB, in testMergeDataLocalUpdateRemoteInsert() local
405 final RawContactDeltaList merged = RawContactDeltaList.mergeAfter(second, first); in testMergeDataLocalUpdateRemoteInsert()
416 final RawContactDeltaList second = buildSet(buildBeforeEntity(mContext, CONTACT_BOB, in testMergeDataLocalUpdateRemoteDelete() local
431 final RawContactDeltaList merged = RawContactDeltaList.mergeAfter(second, first); in testMergeDataLocalUpdateRemoteDelete()
442 final RawContactDeltaList second = buildSet(buildBeforeEntity(mContext, CONTACT_BOB, in testMergeDataLocalDeleteRemoteUpdate() local
456 final RawContactDeltaList merged = RawContactDeltaList.mergeAfter(second, first); in testMergeDataLocalDeleteRemoteUpdate()
467 final RawContactDeltaList second = buildSet(buildBeforeEntity(mContext, CONTACT_BOB, in testMergeDataLocalInsertRemoteInsert() local
[all …]
|
| /packages/apps/TV/jni/ |
| D | tunertvinput_jni.cpp | 44 delete it->second; in Java_com_android_tv_tuner_TunerHal_nativeFinalize()
64 dvbManager = it->second; in Java_com_android_tv_tuner_TunerHal_nativeTune__JILjava_lang_String_2I()
87 dvbManager = it->second; in Java_com_android_tv_tuner_TunerHal_nativeTune__JIILjava_lang_String_2I()
104 it->second->closeAllDvbPidFilter(); in Java_com_android_tv_tuner_TunerHal_nativeCloseAllPidFilters()
117 it->second->stopTune(); in Java_com_android_tv_tuner_TunerHal_nativeStopTune()
131 return it->second->getSignalStrength(); in Java_com_android_tv_tuner_TunerHal_nativeGetSignalStrength()
147 it->second->startTsPidFilter(env, thiz, pid, filterType); in Java_com_android_tv_tuner_TunerHal_nativeAddPidFilter()
164 DvbManager *dvbManager = it->second; in Java_com_android_tv_tuner_TunerHal_nativeWriteInBuffer()
196 it->second->setHasPendingTune(hasPendingTune); in Java_com_android_tv_tuner_TunerHal_nativeSetHasPendingTune()
211 return it->second->getDeliverySystemType(env, thiz); in Java_com_android_tv_tuner_TunerHal_nativeGetDeliverySystemType()
[all …]
|
| /packages/modules/StatsD/statsd/src/metrics/ |
| D | DurationMetricProducer.cpp | 199 const Predicate& durationWhat = config.predicate(what_it->second); in onConfigUpdatedLocked()
241 it.second->onConfigUpdated(wizard, mConditionTrackerIndex); in onConfigUpdatedLocked()
324 whatIt.second->onStateChanged(eventTimeNs, atomId, newStateCopy); in onStateChanged()
382 if (slicedConditionIt != slicedConditionMap->end() && slicedConditionIt->second > 0) { in onSlicedConditionMayChangeLocked_opt1()
383 whatIt.second->onConditionChanged(currentUnSlicedPartCondition, eventTime); in onSlicedConditionMayChangeLocked_opt1()
395 whatIt.second->onConditionChanged(true, eventTime); in onSlicedConditionMayChangeLocked_opt1()
399 whatIt.second->onConditionChanged(false, eventTime); in onSlicedConditionMayChangeLocked_opt1()
416 whatIt.second->onSlicedConditionMayChange(overallCondition, eventTimeNs); in onSlicedConditionMayChangeInternalLocked()
450 whatIt.second->onConditionChanged(mIsActive, eventTimeNs); in onActiveStateChangedLocked()
457 whatIt.second->onConditionChanged(mIsActive, eventTimeNs); in onActiveStateChangedLocked()
[all …]
|
| D | MetricProducer.cpp | 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()
206 auto& activation = it->second; in activateLocked()
228 for (auto activationToCancelIt : it->second) { in cancelEventActivationLocked()
245 auto& activation = it->second; in loadActiveMetricLocked()
266 const std::shared_ptr<Activation>& activation = it.second; in writeActiveMetricToProtoOutputStream()
320 auto valueIt = atomIt->second.find(value->mValue.int_value); in mapStateValue()
321 if (valueIt == atomIt->second.end()) { in mapStateValue()
[all …]
|
| D | ValueMetricProducer.cpp | 107 ? StatsdStats::kAtomDimensionKeySizeLimitMap.at(pullTagId).second in ValueMetricProducer()
266 mStateChangePrimaryKey.second = primaryKey; in onStateChanged()
271 mStateChangePrimaryKey.second = DEFAULT_DIMENSION_KEY; in onStateChanged()
383 for (const auto& bucket : pair.second) { in onDumpReportLocked()
465 for (auto& baseInfo : slice.second.baseInfos) { in resetBase()
702 if (!presentInPulledData && whatKey.contains(mStateChangePrimaryKey.second)) { in accumulateEvents()
704 for (auto& baseInfo : it->second.baseInfos) { in accumulateEvents()
710 it->second.hasCurrentState = false; in accumulateEvents()
739 for (const auto& interval : it.second.intervals) { in dumpStatesLocked()
835 if (it != statePrimaryKeys.end() && it->second != mStateChangePrimaryKey.second) { in onMatchedLogEventInternalLocked()
[all …]
|
| /packages/services/Car/cpp/evs/manager/1.1/ |
| D | VirtualCamera.cpp | 243 auto halCamera = mHalCamera.begin()->second.promote(); in getCameraInfo()
320 auto pHwCamera = iter->second.promote(); in startVideoStream()
337 auto ptr = rb->second.promote(); in startVideoStream()
350 auto pHwCamera = mHalCamera.begin()->second.promote(); in startVideoStream()
440 auto& frameQueue = mFramesHeld.begin()->second; in doneWithFrame()
458 auto pHwCamera = mHalCamera.begin()->second.promote(); in doneWithFrame()
536 auto pHwCamera = mHalCamera.begin()->second.promote(); in getExtendedInfo()
553 auto pHwCamera = mHalCamera.begin()->second.promote(); in setExtendedInfo()
572 auto pHwCamera = mHalCamera.begin()->second.promote(); in getCameraInfo_1_1()
596 auto pHwCamera = device->second.promote(); in getPhysicalCameraInfo()
[all …]
|
| /packages/modules/StatsD/statsd/src/condition/ |
| D | SimpleConditionTracker.cpp | 97 mStartLogMatcherIndex = pair->second; in setMatcherIndices()
109 mStopLogMatcherIndex = pair->second; in setMatcherIndices()
122 mStopAllLogMatcherIndex = pair->second; in setMatcherIndices()
132 VLOG("\t%s : %d", pair.first.toString().c_str(), pair.second); in dumpState()
154 if (cond.second > 0) { in handleStopAll()
212 auto& startedCount = outputIt->second; in handleConditionEvent()
308 if (slicedCondition.second > 0) { in evaluateCondition()
322 itr->second > 0 ? ConditionState::kTrue : ConditionState::kFalse; in evaluateCondition()
372 itr->second > 0 ? ConditionState::kTrue : ConditionState::kFalse; in isConditionMet()
381 const HashableDimensionKey& key = pair->second; in isConditionMet()
[all …]
|
| /packages/inputmethods/LatinIME/native/jni/tests/dictionary/utils/ |
| D | trie_map_test.cpp | 110 EXPECT_EQ(v.second, trieMap.getRoot(v.first).mValue); in TEST()
163 secondLevelKey.second, secondLevel); in TEST()
166 threeLevelMap[secondLevelKey.first][secondLevelKey.second][key] = value; in TEST()
170 EXPECT_EQ(firstLevelEntry.second, trieMap.getRoot(firstLevelEntry.first).mValue); in TEST()
176 for (const auto &secondLevelEntry : firstLevelEntry.second) { in TEST()
177 EXPECT_EQ(secondLevelEntry.second, in TEST()
185 for (const auto &secondLevelEntry : firstLevelEntry.second) { in TEST()
189 for (const auto &thirdLevelEntry : secondLevelEntry.second) { in TEST()
190 EXPECT_EQ(thirdLevelEntry.second, in TEST()
217 EXPECT_TRUE(secondLevelEntry.second.empty()); in TEST()
[all …]
|
| /packages/services/Car/tests/common_utils/src/com/android/car/test/power/ |
| D | CarPowerPolicyUtil.java | 27 public static void assertPolicyIdentical(CarPowerPolicy first, CarPowerPolicy second) in assertPolicyIdentical() argument
29 assertThat(first.getPolicyId()).isEqualTo(second.getPolicyId()); in assertPolicyIdentical()
30 assertComponentsIdentical(first.getEnabledComponents(), second.getEnabledComponents()); in assertPolicyIdentical()
31 assertComponentsIdentical(first.getDisabledComponents(), second.getDisabledComponents()); in assertPolicyIdentical()
34 private static void assertComponentsIdentical(int[] first, int[] second) throws Exception { in assertComponentsIdentical() argument
35 Integer[] boxedArr = Arrays.stream(second).boxed().toArray(Integer[]::new); in assertComponentsIdentical()
|
| /packages/modules/StatsD/statsd/tests/e2e/ |
| D | Anomaly_count_e2e_test.cpp | 70 EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid()); in TEST()
71 ASSERT_EQ(1u, processor->mMetricsManagers.begin()->second->mAllAnomalyTrackers.size()); in TEST()
74 processor->mMetricsManagers.begin()->second->mAllAnomalyTrackers[0]; in TEST()
187 EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid()); in TEST()
188 ASSERT_EQ(1u, processor->mMetricsManagers.begin()->second->mAllAnomalyTrackers.size()); in TEST()
191 processor->mMetricsManagers.begin()->second->mAllAnomalyTrackers[0]; in TEST()
258 EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid()); in TEST()
259 ASSERT_EQ(1u, processor->mMetricsManagers.begin()->second->mAllAnomalyTrackers.size()); in TEST()
283 EXPECT_TRUE(processor->mMetricsManagers.begin()->second->isConfigValid()); in TEST()
284 ASSERT_EQ(1u, processor->mMetricsManagers.begin()->second->mAllAnomalyTrackers.size()); in TEST()
[all …]
|