Home
last modified time | relevance | path

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

1234

/tools/metalava/src/main/java/com/android/tools/metalava/apilevels/
DApiElement.java131 void print(String tag, ApiElement parentElement, String indent, PrintStream stream) { in print() argument
132 print(tag, true, parentElement, indent, stream); in print()
148 PrintStream stream) { in print() argument
149 stream.print(indent); in print()
150 stream.print('<'); in print()
151 stream.print(tag); in print()
152 stream.print(" name=\""); in print()
153 stream.print(encodeAttribute(mName)); in print()
155 stream.print("\" since=\""); in print()
156 stream.print(mSince); in print()
[all …]
DApiClass.java139 public void print(String tag, ApiElement parentElement, String indent, PrintStream stream) { in print() argument
143 super.print(tag, false, parentElement, indent, stream); in print()
145 print(mSuperClasses, "extends", innerIndent, stream); in print()
146 print(mInterfaces, "implements", innerIndent, stream); in print()
147 print(mMethods.values(), "method", innerIndent, stream); in print() local
148 print(mFields.values(), "field", innerIndent, stream); in print() local
149 printClosingTag(tag, indent, stream); in print()
DApi.java41 public void print(PrintStream stream) { in print() argument
42 stream.println("<api version=\"2\">"); in print()
43 print(mClasses.values(), "class", "\t", stream); in print() local
44 printClosingTag("api", "", stream); in print()
/tools/tradefederation/core/python-lib/tradefed_py/
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 …]
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))
/tools/tradefederation/core/tests/src/com/android/tradefed/util/
DShellOutputReceiverStreamTest.java50 try (ShellOutputReceiverStream stream = new ShellOutputReceiverStream(null)) { in testNullReceiver() argument
51 stream.write(mRandomTestByte); in testNullReceiver()
52 stream.write(mRandomTestData); in testNullReceiver()
53 stream.write(mRandomTestData, 0, mRandomTestData.length); in testNullReceiver()
61 try (ShellOutputReceiverStream stream = new ShellOutputReceiverStream(mReceiver)) { in testUpperBitsIgnoredInSingleByteWrite() argument
62 stream.write(testByte); in testUpperBitsIgnoredInSingleByteWrite()
70 try (ShellOutputReceiverStream stream = new ShellOutputReceiverStream(mReceiver)) { in testWriteSingleBytes() argument
71 stream.write(mRandomTestByte); in testWriteSingleBytes()
72 stream.write(mRandomTestByte); in testWriteSingleBytes()
80 try (ShellOutputReceiverStream stream = new ShellOutputReceiverStream(mReceiver)) { in testWriteFullByteArray1() argument
[all …]
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/io/
DStreamingLineReader.kt33 val stream = this@iterLines in <lambda>() constant
35 var lineStartIndex = stream.startIndex in <lambda>()
40 if (index > stream.endIndex) { in <lambda>()
41 if (!stream.loadIndex(index)) break in <lambda>()
43 val window = stream.windowFor(index) in <lambda>()
50 if (lineStartIndex > stream.endIndex) break in <lambda>()
53 if (foundAt == -1L) foundAt = stream.endIndex + 1 in <lambda>()
58 if (foundAt > 0 && stream[foundAt - 1] == '\r'.toByte()) foundAt -= 1 in <lambda>()
61 if (lineStartIndex >= stream.startIndex && (lineEndIndexInclusive - lineStartIndex) >= 0) { in <lambda>()
62 val window = stream.windowFor(lineStartIndex) in <lambda>()
[all …]
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/extractors/
DSystraceExtractor.kt28 override fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit) { in <lambda>()
30 stream.onWindowReleased = null in <lambda>()
31 startIndex = START.find(stream, startIndex) in <lambda>()
34 if (!stream.loadIndex(startIndex)) return in <lambda>()
35 if (stream[startIndex] == '\n'.toByte()) startIndex++ in <lambda>()
40 stream.onWindowReleased = { window -> processWindow(window, pipe) } in <lambda>()
41 endIndex = END.find(stream, startIndex) in <lambda>()
43 endIndex = stream.endIndex in <lambda>()
45 stream.onWindowReleased = null in <lambda>()
46 stream.windows.forEach { processWindow(it, pipe) } in <lambda>()
DZlibExtractor.kt42 private class DeflateProducer(stream: StreamingReader, val feedback: ImportFeedback)
45 private val source = stream.source
50 stream.loadIndex(stream.startIndex + 1024) in <lambda>()
51 val offset = findStart(stream) in <lambda>()
52 val buffIter = stream.iter(offset) in <lambda>()
89 override fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit) { in extract()
90 processSubStream(DeflateProducer(stream, feedback)) in extract()
/tools/tradefederation/core/src/com/android/tradefed/util/
DStreamUtil.java60 final InputStream stream = source.createInputStream(); in getStringFromSource() local
63 contents = getStringFromStream(stream); in getStringFromSource()
65 close(stream); in getStringFromSource()
96 final InputStream stream = source.createInputStream(); in getByteArrayListFromSource() local
99 contents = getByteArrayListFromStream(stream); in getByteArrayListFromSource()
101 close(stream); in getByteArrayListFromSource()
113 public static String getStringFromStream(InputStream stream) throws IOException { in getStringFromStream() argument
116 try (Reader ir = new BufferedReader(new InputStreamReader(stream))) { in getStringFromStream()
131 public static ByteArrayList getByteArrayListFromStream(InputStream stream) throws IOException { in getByteArrayListFromStream() argument
132 InputStream is = new BufferedInputStream(stream); in getByteArrayListFromStream()
[all …]
/tools/tradefederation/core/src/com/android/tradefed/util/testmapping/
DTestInfo.java29 import java.util.stream.Collectors;
170 mOptions.stream() in merge()
178 mOptions.stream() in merge()
182 mOptions.stream() in merge()
190 mOptions.stream() in merge()
196 .stream() in merge()
205 .stream() in merge()
210 .stream() in merge()
219 .stream() in merge()
281 mOptions.stream() in toString()
[all …]
DTestMapping.java45 import java.util.stream.Collectors;
46 import java.util.stream.Stream;
202 tests.stream() in mergeTests()
235 Stream<Path> stream = null; in getTests() local
239 stream = Files.walk(testMappingsRootPath, FileVisitOption.FOLLOW_LINKS); in getTests()
240 stream.filter(path -> path.getFileName().toString().equals(TEST_MAPPING)) in getTests()
257 if (stream != null) { in getTests()
258 stream.close(); in getTests()
275 Stream<Path> stream = null; in getAllTests() local
278 stream = Files.walk(testMappingsRootPath, FileVisitOption.FOLLOW_LINKS); in getAllTests()
[all …]
/tools/tradefederation/core/atest/
Datest_utils_unittest.py88 stream = open('/tmp/test_has_colors.txt', 'wb')
89 self.assertFalse(atest_utils._has_colors(stream))
90 stream.close()
93 stream = mock.Mock()
94 stream.isatty.return_value = False
95 self.assertFalse(atest_utils._has_colors(stream))
98 stream = mock.Mock()
99 stream.isatty.return_value = True
101 self.assertFalse(atest_utils._has_colors(stream))
104 stream = mock.Mock()
[all …]
/tools/tradefederation/core/tests/src/com/android/tradefed/testtype/suite/
DTestSuiteInfoTest.java58 FileInputStream stream = null; in testLoadConfig() local
68 stream = new FileInputStream(propertyFile); in testLoadConfig()
69 Properties p = instance.loadSuiteInfo(stream); in testLoadConfig()
77 StreamUtil.close(stream); in testLoadConfig()
84 FileInputStream stream = null; in testLoadConfig_multiArch() local
94 stream = new FileInputStream(propertyFile); in testLoadConfig_multiArch()
95 Properties p = instance.loadSuiteInfo(stream); in testLoadConfig_multiArch()
103 StreamUtil.close(stream); in testLoadConfig_multiArch()
/tools/tradefederation/core/src/com/android/tradefed/postprocessor/
DAggregatePostProcessor.java31 import java.util.stream.Collectors;
75 metrics.stream().map(Metric::getMeasurements).collect(Collectors.toList()); in processTestMetrics()
78 measures.stream() in processTestMetrics()
90 .flatMap(Collection::stream) in processTestMetrics()
128 .stream() in isAllDoubleValues()
151 values.stream().map(Double::parseDouble).collect(Collectors.toList());
168 double sum = values.stream().mapToDouble(Double::doubleValue).sum();
172 values.stream()
176 double variance = values.stream().reduce(0.0, (a, b) -> a + Math.pow(b - mean, 2) / count);
/tools/tradefederation/core/src/com/android/tradefed/result/
DSnapshotInputStreamSource.java36 public SnapshotInputStreamSource(String name, InputStream stream) { in SnapshotInputStreamSource() argument
37 if (stream == null) { in SnapshotInputStreamSource()
42 mBackingFile = createBackingFile(name, stream); in SnapshotInputStreamSource()
56 File createBackingFile(String name, InputStream stream) throws IOException { in createBackingFile() argument
59 FileUtil.writeToFile(stream, backingFile); in createBackingFile()
/tools/test/graphicsbenchmark/performance_tests/helper/src/com/android/game/qualification/
DGameCoreConfiguration.java19 import java.util.stream.Collectors;
43 getCertificationRequirements().stream() in validateConfiguration()
48 getApkInfo().stream() in validateConfiguration()
53 requirementNames.stream() in validateConfiguration()
74 return mCertificationRequirements.stream() in findCertificationRequirements()
/tools/tradefederation/contrib/src/com/android/regression/tests/
DDetectRegression.java44 import java.util.stream.Collectors;
183 runMetricsResult.stream().map(TableRow::toStringArray).forEach(table::addLine); in logResult()
194 .stream() in logResult()
206 .stream() in logResult()
226 .stream() in getMetricsFiles()
256 return list.stream().collect(Collectors.averagingDouble(x -> x)); in calcMean()
263 list.stream().collect(Collectors.averagingDouble(x -> Math.pow(x - mean, 2)))); in calcStdDev()
/tools/apkzlib/src/main/java/com/android/tools/build/apkzlib/zip/utils/
DByteTracker.java48 public CloseableDelegateByteSource fromStream(@Nonnull InputStream stream) throws IOException { in fromStream() argument
49 byte[] data = ByteStreams.toByteArray(stream); in fromStream()
67 public CloseableDelegateByteSource fromStream(@Nonnull ByteArrayOutputStream stream)
69 byte[] data = stream.toByteArray();
/tools/tradefederation/core/tests/src/com/android/tradefed/device/metric/
DRuntimeRestartCollectorTest.java44 import java.util.stream.Collectors;
505 .stream() in testAddingMetrics_includesSerialForMultipleDevices()
517 .stream() in testAddingMetrics_includesSerialForMultipleDevices()
524 .stream() in testAddingMetrics_includesSerialForMultipleDevices()
535 .stream() in getCount()
553 .stream() in ensureNoMetricWithKeySuffix()
569 .stream() in getStringMetricValuesByKeySuffix()
577 .flatMap(arr -> Arrays.stream(arr)) in getStringMetricValuesByKeySuffix()
588 .stream() in getIntMetricValuesByKeySuffix()
600 .stream() in getLongMetricValuesByKeySuffix()
/tools/tradefederation/core/src/com/android/tradefed/device/metric/
DRuntimeRestartCollector.java45 import java.util.stream.Collectors;
185 .stream() in onTestRunEnd()
229 .stream() in addStatsdStatsBasedMetrics()
239 .stream() in addStatsdStatsBasedMetrics()
261 .stream() in addAtomBasedMetrics()
271 .stream() in addAtomBasedMetrics()
/tools/test/connectivity/acts/framework/acts/test_utils/coex/
Daudio_capture.py82 stream = self.audio.open(
96 data = stream.read(self.chunk)
103 stream.stop_stream()
104 stream.close()
/tools/test/graphicsbenchmark/performance_tests/hostside/src/com/android/game/qualification/test/
DPerformanceTest.java199 try (InputStream stream = screenSource.createInputStream()) { in testScreenshot() argument
200 stream.reset(); in testScreenshot()
203 isImageBlack(stream)); in testScreenshot()
233 static boolean isImageBlack(InputStream stream) throws IOException { in isImageBlack() argument
234 BufferedImage img = ImageIO.read(stream); in isImageBlack()
/tools/metalava/src/main/java/com/android/tools/metalava/
DVersion.kt30 … val stream = BufferedInputStream(Version::class.java.getResourceAsStream("/version.properties")) constant
32 properties.load(stream)
34 stream.close()
/tools/tradefederation/core/src/com/android/tradefed/log/
DFileLogger.java218 SizeLimitedOutputStream stream = mLogStream; in doCloseLog() local
220 StreamUtil.flushAndCloseStream(stream); in doCloseLog()
221 if (stream != null) { in doCloseLog()
222 stream.delete(); in doCloseLog()

1234