| /tools/metalava/metalava/src/main/java/com/android/tools/metalava/apilevels/ |
| D | ApiElement.kt | 155 open fun print(tag: String?, parentElement: ApiElement, indent: String, stream: PrintStream) { in print()
156 print(tag, true, parentElement, indent, stream) in print()
176 stream: PrintStream in print()
178 stream.print(indent) in print()
179 stream.print('<') in print()
180 stream.print(tag) in print()
181 stream.print(" name=\"") in print()
182 stream.print(encodeAttribute(name)) in print()
184 stream.print("\" module=\"") in print()
185 stream.print(encodeAttribute(mainlineModule!!)) in print()
[all …]
|
| D | Api.kt | 33 fun print(stream: PrintStream, sdkIdentifiers: Set<SdkIdentifier>) { in print()
34 stream.print("<api version=\"3\"") in print()
36 stream.print(" min=\"$mMin\"") in print()
38 stream.println(">") in print()
40 stream.println( in print()
50 print(mClasses.values, "class", "\t", stream) in print()
51 printClosingTag("api", "", stream) in print()
|
| /tools/test/connectivity/acts_tests/acts_contrib/test_utils/fuchsia/ |
| D | wmm_test_cases.py | 36 dict(operator='<', phase='phase_1', stream='stream_VO')
59 dict(operator='<', phase='phase_1', stream='stream_VO')
82 dict(operator='<', phase='phase_1', stream='stream_VO')
105 dict(operator='<', phase='phase_1', stream='stream_VI')
128 dict(operator='<', phase='phase_1', stream='stream_VI')
151 dict(operator='<', phase='phase_1', stream='stream_BE')
178 stream='stream_VO_staut_to_ap')
203 stream='stream_VO_staut_to_ap')
228 stream='stream_VO_staut_to_ap')
253 stream='stream_VI_staut_to_ap')
[all …]
|
| /tools/tradefederation/core/javatests/com/android/tradefed/util/ |
| D | ShellOutputReceiverStreamTest.java | 50 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 …]
|
| D | ZipUtilTest.java | 249 .stream() in testPartipUnzip()
270 .stream() in testPartipUnzip()
301 .stream() in testPartipUnzip()
320 .stream() in testPartipUnzip()
339 .stream() in testPartipUnzip()
358 .stream() in testPartipUnzip()
376 zipEntries.stream() in testPartipUnzip()
407 zipEntries.stream() in testPartipUnzip()
475 .stream() in testPartialUnzipWithUseZip64()
495 .stream() in testPartialUnzipWithUseZip64()
[all …]
|
| /tools/security/fuzzing/llm/xmlreader_fuzzer/ |
| D | XmlRead_Memory_Fuzzer.cpp | 6 std::string GenerateRandomXML(FuzzedDataProvider& stream) { in GenerateRandomXML() argument
8 int numberOfElements = stream.ConsumeIntegralInRange<int>(1, 10); in GenerateRandomXML()
11 … std::string elementName = stream.ConsumeRandomLengthString(10); // Limiting name length to 10 in GenerateRandomXML()
14 if (stream.ConsumeBool()) { in GenerateRandomXML()
15 … std::string textContent = stream.ConsumeRandomLengthString(20); // Limiting text content length in GenerateRandomXML()
19 int numberOfAttributes = stream.ConsumeIntegralInRange<int>(0, 5); in GenerateRandomXML()
21 …std::string attributeName = stream.ConsumeRandomLengthString(10); // Limiting attribute name length in GenerateRandomXML()
22 …std::string attributeValue = stream.ConsumeRandomLengthString(20); // Limiting attribute value len… in GenerateRandomXML()
34 FuzzedDataProvider stream(data, size); in LLVMFuzzerTestOneInput() local
47 std::string buffer = GenerateRandomXML(stream); in LLVMFuzzerTestOneInput()
[all …]
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/io/ |
| D | StreamingLineReader.kt | 33 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/netsim/rust/daemon/src/http_server/ |
| D | server_response.rs | 164 let mut stream = Cursor::new(Vec::new()); in test_put_error() localVariable
165 let mut writer = ServerResponseWriter::new(&mut stream); in test_put_error()
167 let written_bytes = stream.get_ref(); in test_put_error()
175 let mut stream = Cursor::new(Vec::new()); in test_put_ok() localVariable
176 let mut writer = ServerResponseWriter::new(&mut stream); in test_put_ok()
178 let written_bytes = stream.get_ref(); in test_put_ok()
186 let mut stream = Cursor::new(Vec::new()); in test_put_ok_with_length() localVariable
187 let mut writer = ServerResponseWriter::new(&mut stream); in test_put_ok_with_length()
189 let written_bytes = stream.get_ref(); in test_put_ok_with_length()
197 let mut stream = Cursor::new(Vec::new()); in test_put_ok_with_vec() localVariable
[all …]
|
| D | http_router.rs | 143 let mut stream = Cursor::new(Vec::new()); in test_handle_request() localVariable
144 let mut writer = ServerResponseWriter::new(&mut stream); in test_handle_request()
146 let written_bytes = stream.get_ref(); in test_handle_request()
157 let mut stream = Cursor::new(Vec::new()); in test_handle_request() localVariable
158 let mut writer = ServerResponseWriter::new(&mut stream); in test_handle_request()
160 let written_bytes = stream.get_ref(); in test_handle_request()
176 let mut stream = Cursor::new(Vec::new()); in test_mismatch_uri() localVariable
177 let mut writer = ServerResponseWriter::new(&mut stream); in test_mismatch_uri()
179 let written_bytes = stream.get_ref(); in test_mismatch_uri()
195 let mut stream = Cursor::new(Vec::new()); in test_handle_query() localVariable
[all …]
|
| /tools/apksig/src/main/java/com/android/apksig/internal/apk/v4/ |
| D | V4Signature.java | 207 static V4Signature readFrom(InputStream stream) throws IOException { in readFrom() argument
208 final int version = readIntLE(stream); in readFrom()
212 final byte[] hashingInfo = readBytes(stream); in readFrom()
213 final byte[] signingInfo = readBytes(stream); in readFrom()
217 public void writeTo(OutputStream stream) throws IOException { in writeTo() argument
218 writeIntLE(stream, this.version); in writeTo()
219 writeBytes(stream, this.hashingInfo); in writeTo()
220 writeBytes(stream, this.signingInfos); in writeTo()
247 static void readFully(InputStream stream, byte[] buffer) throws IOException { in readFully() argument
251 int count = stream.read(buffer, n, len - n); in readFully()
[all …]
|
| /tools/test/connectivity/acts_tests/tests/google/fuchsia/wlan/performance/ |
| D | WlanWmmTest.py | 297 for stream_id, stream in phases[phase_id].items():
298 if 'validation' in stream:
299 transmitter = stream['transmitter']
300 uuid = stream['uuid']
306 for check in stream['validation']:
341 if 'bandwidth' in stream:
342 comp_bw = stream['bandwidth']
350 max_bw_percentage = stream.get(
421 for stream_id, stream in phase.items():
422 transmitter = stream['transmitter']
[all …]
|
| /tools/netsim/rust/daemon/src/transport/ |
| D | socket.rs | 39 stream: TcpStream, field
47 if let Err(e) = self.stream.write_all(&buffer[..]) { in response()
68 for stream in listener.incoming() { in accept_incoming()
69 let stream = stream?; in accept_incoming() localVariable
71 info!("Hci client address: {}", stream.peer_addr().unwrap()); in accept_incoming()
75 handle_hci_client(stream); in accept_incoming()
82 fn handle_hci_client(stream: TcpStream) { in handle_hci_client()
87 name: Some(format!("socket-{}", stream.peer_addr().unwrap())), in handle_hci_client()
103 &stream.peer_addr().unwrap().port().to_string(), in handle_hci_client()
104 &format!("socket-{}", stream.peer_addr().unwrap()), in handle_hci_client()
[all …]
|
| /tools/security/fuzzing/llm/tinyxml2_fuzzer/ |
| D | tinyxml_parse_fuzzer.cpp | 35 void GenerateXML(FuzzedDataProvider* stream, XMLElement* element, int maxDepth = 3) { in GenerateXML() argument
36 element->name = stream->ConsumeRandomLengthString(20); in GenerateXML()
38 int numAttributes = stream->ConsumeIntegralInRange<int>(0, 5); in GenerateXML()
41 stream->ConsumeRandomLengthString(15), // Attribute name in GenerateXML()
42 stream->ConsumeRandomLengthString(30) // Attribute value in GenerateXML()
46 int numChildren = stream->ConsumeIntegralInRange<int>(0, 3); in GenerateXML()
52 GenerateXML(stream, &child, maxDepth - 1); in GenerateXML()
55 child.textContent = stream->ConsumeRandomLengthString(30); in GenerateXML()
63 FuzzedDataProvider stream(data, size); in LLVMFuzzerTestOneInput() local
66 GenerateXML(&stream, &rootElement); in LLVMFuzzerTestOneInput()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/extractors/ |
| D | SystraceExtractor.kt | 28 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>()
|
| D | ZlibExtractor.kt | 42 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/security/fuzzing/llm/xz_fuzzer/ |
| D | xz_decoder_fuzzer.cpp | 5 struct xz_dec *init_xz_dec(FuzzedDataProvider& stream) { in init_xz_dec() argument
8 enum xz_mode mode = stream.PickValueInArray(modes); in init_xz_dec()
11 uint32_t dict_max = stream.ConsumeIntegral<uint32_t>(); in init_xz_dec()
20 FuzzedDataProvider stream(data, size); in LLVMFuzzerTestOneInput() local
23 struct xz_dec *s = init_xz_dec(stream); in LLVMFuzzerTestOneInput()
27 size_t in_buffer_size = stream.ConsumeIntegralInRange<size_t>(0, size); in LLVMFuzzerTestOneInput()
30 in_buffer[i] = stream.ConsumeIntegral<uint8_t>(); in LLVMFuzzerTestOneInput()
36 size_t out_buffer_size = stream.ConsumeIntegralInRange<size_t>(0, size); in LLVMFuzzerTestOneInput()
|
| /tools/tradefederation/core/common_util/com/android/tradefed/util/ |
| D | StreamUtil.java | 64 final InputStream stream = source.createInputStream(); in getStringFromSource() local
67 contents = getStringFromStream(stream); in getStringFromSource()
69 close(stream); in getStringFromSource()
100 final InputStream stream = source.createInputStream(); in getByteArrayListFromSource() local
103 contents = getByteArrayListFromStream(stream); in getByteArrayListFromSource()
105 close(stream); in getByteArrayListFromSource()
117 public static String getStringFromStream(InputStream stream) throws IOException { in getStringFromStream() argument
118 return getStringFromStream(stream, 0); in getStringFromStream()
129 public static String getStringFromStream(InputStream stream, long length) throws IOException { in getStringFromStream() argument
132 try (Reader ir = new BufferedReader(new InputStreamReader(stream))) { in getStringFromStream()
[all …]
|
| /tools/tradefederation/core/src/com/android/tradefed/util/testmapping/ |
| D | TestInfo.java | 28 import java.util.stream.Collectors;
195 mOptions.stream() in merge()
203 mOptions.stream() in merge()
207 mOptions.stream() in merge()
215 mOptions.stream() in merge()
221 .stream() in merge()
230 .stream() in merge()
235 .stream() in merge()
244 .stream() in merge()
306 mOptions.stream() in toString()
[all …]
|
| /tools/tradefederation/core/javatests/com/android/tradefed/testtype/suite/ |
| D | TestSuiteInfoTest.java | 58 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/netsim/src/backend/ |
| D | grpc_server.cc | 58 Stream *stream) override { in StreamPackets() argument
66 bool success = stream->Read(&request); in StreamPackets()
120 chip_id_to_stream[chip_id] = stream; in StreamPackets()
122 this->ProcessRequests(stream, chip_id, chip_kind); in StreamPackets()
152 void ProcessRequests(Stream *stream, uint32_t chip_id, in ProcessRequests() argument
156 if (!stream->Read(&request)) { in ProcessRequests()
207 auto stream = chip_id_to_stream[chip_id]; in HandleResponse() local
208 if (stream) { in HandleResponse()
219 if (!stream->Write(response)) { in HandleResponse()
|
| /tools/tradefederation/core/src/com/android/tradefed/result/ |
| D | SnapshotInputStreamSource.java | 36 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/ |
| D | GameCoreConfiguration.java | 19 import java.util.stream.Collectors;
45 getCertificationRequirements().stream() in validateConfiguration()
50 getApkInfo().stream() in validateConfiguration()
55 requirementNames.stream() in validateConfiguration()
76 return mCertificationRequirements.stream() in findCertificationRequirements()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| D | MetricUtility.java | 44 import java.util.stream.Collectors;
184 List<Measurements> measures = metrics.stream().map(Metric::getMeasurements) in aggregateStoredTestMetricsAndWriteToFile()
187 List<String> rawValues = measures.stream() in aggregateStoredTestMetricsAndWriteToFile()
199 .flatMap(Collection::stream) in aggregateStoredTestMetricsAndWriteToFile()
243 .stream() in isAllDoubleValues()
265 double sum = values.stream().mapToDouble(Double::doubleValue).sum();
268 double mean = values.stream()
272 double variance = values.stream().reduce(0.0, (a, b) -> a + Math.pow(b - mean, 2) / count);
295 .stream()
319 List<Double> doubleValues = values.stream().map(Double::parseDouble)
|
| /tools/tradefederation/core/javatests/com/android/tradefed/result/error/ |
| D | ErrorIdentifierTest.java | 29 import java.util.stream.Collectors;
42 List<String> names = errors.stream().map(e -> e.name()).collect(Collectors.toList()); in testUniqueErrors()
45 names.stream().filter(e -> !uniques.add(e)).collect(Collectors.toSet()); in testUniqueErrors()
54 errors.stream().map(e -> Long.toString(e.code())).collect(Collectors.toList()); in testUniqueErrors()
57 codes.stream().filter(e -> !uniqueCodes.add(e)).collect(Collectors.toSet()); in testUniqueErrors()
|
| /tools/tradefederation/core/javatests/com/android/tradefed/testtype/python/ |
| D | PythonBinaryHostTestTest.java | 147 OutputStream stream = (OutputStream) invocation.getArguments()[2]; in testRun()
148 StreamUtil.copyFileToStream(mOutputFile, stream); in testRun()
259 OutputStream stream = (OutputStream) invocation.getArguments()[2]; in testRun_withIncludeFilters()
261 new ByteArrayInputStream(output.getBytes()), stream); in testRun_withIncludeFilters()
328 OutputStream stream = (OutputStream) invocation.getArguments()[2]; in testRun_withExcludeFilters()
330 new ByteArrayInputStream(output.getBytes()), stream); in testRun_withExcludeFilters()
391 OutputStream stream = (OutputStream) invocation.getArguments()[2]; in testRun_withAdbPath()
392 StreamUtil.copyFileToStream(mOutputFile, stream); in testRun_withAdbPath()
449 OutputStream stream = (OutputStream) invocation.getArguments()[2]; in testRun_withSharedLibInHostTestsDir()
450 StreamUtil.copyFileToStream(mOutputFile, stream); in testRun_withSharedLibInHostTestsDir()
[all …]
|