Home
last modified time | relevance | path

Searched refs:stream (Results 1 – 25 of 45) sorted by relevance

12

/platform_testing/libraries/tradefed-python-lib/tradefed_py/
Dbase_test.py31 def setUpDevice(self, serial, stream, options): argument
40 self.stream = stream
42 self.android_device = android_device.AndroidTestDevice(serial, stream)
53 self.stream.write('TEST_LOG %s\n' % json.dumps(resp))
Dtf_runner.py51 self.stream.write('TEST_RUN_STARTED %s\n' % json.dumps(resp))
61 self.stream.write('TEST_STARTED %s\n' % json.dumps(resp))
71 self.stream.write('TEST_ENDED %s\n' % json.dumps(resp))
82 self.stream.write('TEST_FAILED %s\n' % json.dumps(resp))
84 self.stream.write('TEST_ENDED %s\n' % json.dumps(resp))
95 self.stream.write('TEST_IGNORED %s\n' % json.dumps(resp))
97 self.stream.write('TEST_ENDED %s\n' % json.dumps(resp))
108 self.stream.write('TEST_ASSUMPTION_FAILURE %s\n' % json.dumps(resp))
110 self.stream.write('TEST_ENDED %s\n' % json.dumps(resp))
120 self.stream.write('TEST_ASSUMPTION_FAILURE %s\n' % json.dumps(resp))
[all …]
Dandroid_device.py25 def __init__(self, serial=None, stream=None): argument
28 self._logging = stream
/platform_testing/libraries/audio-test-harness/server/src/test/java/com/android/media/audiotestharness/server/service/
DCaptureChunkStreamObserverOutputStreamTests.java83 OutputStream stream = in write_writesAsExpected_singleByte() local
87 stream.write(byteToWrite); in write_writesAsExpected_singleByte()
106 OutputStream stream = in write_throwsIllegalStateException_singleByte_afterClose() local
109 stream.close(); in write_throwsIllegalStateException_singleByte_afterClose()
111 stream.write(/* b= */ 42); in write_throwsIllegalStateException_singleByte_afterClose()
119 OutputStream stream = in write_writesAsExpected_multipleBytes() local
125 stream.write(bytes); in write_writesAsExpected_multipleBytes()
145 OutputStream stream = in write_throwsIllegalStateException_multipleBytes_afterClose() local
148 stream.close(); in write_throwsIllegalStateException_multipleBytes_afterClose()
150 stream.write(new byte[4]); in write_throwsIllegalStateException_multipleBytes_afterClose()
[all …]
/platform_testing/libraries/health/composers/host/tests/src/android/host/test/composer/
DIterateTestBase.java24 import java.util.stream.Collectors;
25 import java.util.stream.IntStream;
60 Map<Integer, Long> countMap = output.stream() in testIterationsRespected()
65 .stream() in testIterationsRespected()
83 boolean cyclesSameAsInput = cycles.stream().allMatch(SIMPLE_INPUT::equals); in testCyclicOrderRespected()
102 testRuns.stream().allMatch(l -> l.stream().distinct().count() == 1); in testSequentialOrderRespected()
105 testRuns.stream().map(l -> l.get(0)).collect(Collectors.toList())); in testSequentialOrderRespected()
124 output.stream() in testOverrideOptionName()
129 .stream() in testOverrideOptionName()
DShuffleTestBase.java23 import java.util.stream.Collectors;
24 import java.util.stream.IntStream;
/platform_testing/libraries/health/composers/host/src/android/host/test/composer/
DIterateBase.java22 import java.util.stream.Collectors;
53 .stream() in apply()
54 .flatMap(Collection::stream) in apply()
57 return input.stream() in apply()
59 .flatMap(Collection::stream) in apply()
/platform_testing/libraries/compatibility-common-util/tests/src/com/android/compatibility/common/util/
DDynamicConfigTest.java119 FileOutputStream stream = new FileOutputStream(file); in createFileFromStr() local
120 stream.write(configStr.getBytes()); in createFileFromStr()
121 stream.flush(); in createFileFromStr()
122 stream.close(); in createFileFromStr()
DBusinessLogicTest.java246 FileOutputStream stream = new FileOutputStream(file); in createFileFromStr() local
247 stream.write(blString.getBytes()); in createFileFromStr()
248 stream.flush(); in createFileFromStr()
249 stream.close(); in createFileFromStr()
/platform_testing/libraries/collectors-helper/memory/test/src/com/android/helpers/tests/
DPinnerHelperTest.java33 import java.util.stream.Collectors;
132 .stream() in testSystemFileSizeMetrics()
147 .stream() in testIndividualAppFileSizeMetrics()
162 .stream() in testValidateTotalFileSizeCount()
166 int totalFilesCount = metrics.entrySet().stream().filter( in testValidateTotalFileSizeCount()
203 .stream() in testOnlySystemPinnerInfoIsPresent()
208 .stream() in testOnlySystemPinnerInfoIsPresent()
228 .stream() in testOnlyAppPinnerMetricsInfoIsPresent()
233 .stream() in testOnlyAppPinnerMetricsInfoIsPresent()
268 .stream() in testMetricMapResetOnMultipleGetMetrics()
[all …]
/platform_testing/libraries/health/rules/src/android/platform/test/rule/
DDex2oatPressureRule.java18 import static java.util.stream.Collectors.joining;
19 import static java.util.stream.Collectors.toSet;
87 if (!packagesToCompile.stream().allMatch(pkg -> installedPackages.contains(pkg))) { in starting()
93 .stream() in starting()
156 .stream() in getInstalledPackages()
DCompilationFilterRule.java19 import static java.util.stream.Collectors.joining;
70 String filterOptions = COMPILE_FILTER_LIST.stream().collect(joining(", ")); in finished()
/platform_testing/libraries/health/runners/longevity/platform/src/android/platform/test/longevity/
DProfile.java18 import static java.util.stream.Collectors.joining;
19 import static java.util.stream.Collectors.toList;
20 import static java.util.stream.Collectors.toMap;
144 input.stream() in getTestSequenceFromConfiguration()
153 nameToRunner.keySet().stream().collect(joining(", ")))); in getTestSequenceFromConfiguration()
156 .stream() in getTestSequenceFromConfiguration()
176 result.stream() in getTestSequenceFromConfiguration()
/platform_testing/libraries/app-helpers/core/src/android/platform/helpers/exceptions/
DMappedMultiException.java23 import java.util.stream.Collectors;
65 .stream() in getMessage()
/platform_testing/libraries/aupt-lib/src/android/support/test/aupt/
DProcessStatusTracker.java190 BufferedReader stream = executeShellCommand("ps"); in getRunningAppProcesses() local
193 while ((line = stream.readLine()) != null) { in getRunningAppProcesses()
206 if (stream != null) { in getRunningAppProcesses()
207 stream.close(); in getRunningAppProcesses()
234 BufferedReader stream = new BufferedReader(new InputStreamReader( in executeShellCommand() local
236 return stream; in executeShellCommand()
/platform_testing/libraries/device-collectors/src/test/java/android/device/collectors/
DScheduledRunCollectionListenerTest.java84 Arrays.stream(TEST_METRIC_VALUES) in initListener()
144 int expectedMin = Arrays.stream(TEST_METRIC_VALUES).min(Integer::compare).get(); in testInstrumentationResult()
150 int expectedMax = Arrays.stream(TEST_METRIC_VALUES).max(Integer::compare).get(); in testInstrumentationResult()
157 Arrays.stream(TEST_METRIC_VALUES).mapToDouble(i -> i.doubleValue()).sum() in testInstrumentationResult()
/platform_testing/libraries/audio-test-harness/client-lib/src/main/java/com/android/media/audiotestharness/client/grpc/
DGrpcAudioTestHarnessClient.java72 stream -> { in close()
74 stream.close(); in close()
/platform_testing/libraries/compatibility-common-util/src/com/android/compatibility/common/util/
DCrashUtils.java27 import java.util.stream.Collectors;
28 import java.util.stream.IntStream;
29 import java.util.stream.Stream;
152 if (!config.abortMessageIncludes.stream() in matchSecurityCrashes()
159 if (config.abortMessageExcludes.stream() in matchSecurityCrashes()
186 .flatMap(frame -> backtraceIncludes.stream().map(p -> p.match(frame))) in matchSecurityCrashes()
200 .flatMap(frame -> backtraceExcludes.stream().map(p -> p.match(frame))) in matchSecurityCrashes()
DBusinessLogicFactory.java80 public static BusinessLogic createFromFile(FileInputStream stream) { in createFromFile() argument
82 String businessLogicString = readStream(stream); in createFromFile()
274 private static String readStream(FileInputStream stream) throws IOException { in readStream() argument
277 try (Reader ir = new BufferedReader(new InputStreamReader(stream))) { in readStream()
/platform_testing/libraries/health/runners/longevity/host/src/android/host/test/longevity/
DLongevitySuite.java26 import java.util.stream.Collectors;
61 .stream() in LongevitySuite()
/platform_testing/libraries/device-collectors/src/main/java/android/device/collectors/
DBinderListener.java57 Arrays.stream(processes.split(PROCESS_SEPARATOR)) in setupAdditionalArgs()
DJankListener.java57 Arrays.stream(pkgs.split(PACKAGE_SEPARATOR)) in setupAdditionalArgs()
/platform_testing/libraries/health/rules/tests/src/android/platform/test/rule/
DDex2oatPressureRuleTest.java29 import static java.util.stream.Collectors.toList;
57 import java.util.stream.Stream;
299 .flatMap(l -> l.stream()) in testMultipleTestsParsePackageNamesIndependently()
319 assertThat(compiledInTest1.getAllValues().stream().allMatch(p -> p.endsWith("test1"))) in testMultipleTestsParsePackageNamesIndependently()
329 assertThat(compiledInTest2.stream().allMatch(p -> p.endsWith("test2"))).isTrue(); in testMultipleTestsParsePackageNamesIndependently()
361 logcat.stream() in testCompilationCommandCompiles()
/platform_testing/libraries/collectors-helper/jank/src/com/android/helpers/
DSfStatsCollectionHelper.java30 import java.util.stream.Stream;
248 long count = internalMap.values().stream().mapToLong(v -> v).sum(); in mean()
255 .stream() in mean()
/platform_testing/libraries/health/runners/longevity/platform/tests/src/android/platform/test/longevity/
DProfileTest.java40 import java.util.stream.Collectors;
125 List<String> outputDescriptions = output.stream().map(r -> in testProfileOrderingRespected()

12