Home
last modified time | relevance | path

Searched refs:reader (Results 1 – 25 of 72) sorted by relevance

123

/tools/netsim/rust/daemon/src/transport/
Dh4.rs50 pub fn read_h4_packet<R: Read>(reader: &mut R) -> Result<Packet, PacketError> { in read_h4_packet()
53 reader.read_exact(&mut buffer).map_err(PacketError::IoError)?; in read_h4_packet()
61 _ => return h4_recovery(reader), in read_h4_packet()
66 reader.read_exact(&mut packet).map_err(PacketError::IoError)?; in read_h4_packet()
95 let result = reader.read_exact(&mut packet[preamble_size..]); in read_h4_packet()
116 fn h4_recovery<R: Read>(mut reader: R) -> Result<Packet, PacketError> { in h4_recovery()
125 reader.read_exact(&mut byte).map_err(PacketError::IoError)?; in h4_recovery()
155 let mut reader = Cursor::new(&hci_cmd); in test_read_h4_cmd_packet() localVariable
156 let packet = read_h4_packet(&mut reader).unwrap(); in test_read_h4_cmd_packet()
167 let mut reader = Cursor::new(&hci_acl); in test_read_h4_acl_packet() localVariable
[all …]
Duci.rs41 pub fn read_uci_packet<R: Read>(reader: &mut R) -> Result<Packet, PacketError> { in read_uci_packet()
44 reader.read_exact(&mut buffer[0..]).map_err(PacketError::IoError)?; in read_uci_packet()
48 reader.read_exact(&mut buffer[UCI_HEADER_SIZE..]).map_err(PacketError::IoError)?; in read_uci_packet()
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/util/
DStringSearch.kt68 … fun find(reader: StreamingReader, startIndex: Long = 0, inEndIndex: Long = Long.MAX_VALUE): Long { in find()
72 if (index > reader.endIndex) { in find()
73 if (!reader.loadIndex(index)) return -1 in find()
74 if (reader.reachedEof) { in find()
75 endIndex = reader.endIndex in find()
79 while (reader.windowFor(index) !== reader.windowFor(index - lookFor.length + 1)) { in find()
81 while (lookForIndex >= 0 && reader[index] == lookFor[lookForIndex].toByte()) { in find()
88 index += maxOf(skipLut[reader[index].toInt() and 0xFF], suffixSkip[lookForIndex]) in find()
90 if (index > reader.endIndex) { in find()
91 if (!reader.loadIndex(index)) return -1 in find()
[all …]
DBufferReader.kt74 class MatchResult(val reader: BufferReader) { constant in trebuchet.util.MatchResult
79 reader.index = startIndex + matcher!!.start(group) in int()
80 return reader.readInt() in int()
88 reader.index = startIndex + matcher!!.start(group) in double()
89 return reader.readDouble() in double()
93 reader.index = startIndex + matcher!!.start(group) in long()
94 return reader.readLong() in long()
98 reader.index = startIndex + matcher!!.start(group) in string()
100 return reader.stringTo { index = endAt } in string()
104 reader.index = startIndex + matcher!!.start(group) in slice()
[all …]
/tools/trebuchet/trebuchet/traceutils/src/
DTraceUtils.kt44 val reader = StreamingReader(stream) in findTraces() constant
45 reader.loadIndex(reader.keepLoadedSize.toLong()) in findTraces()
46 val extractor = ExtractorRegistry.extractorFor(reader, importFeedback) in findTraces()
48 extractor.extract(reader, { in findTraces()
53 val importer = ImporterRegistry.importerFor(reader, importFeedback) in findTraces()
55 traceFound(reader) in findTraces()
58 traceFound(reader) in findTraces()
68 fun copy(reader: StreamingReader, output: OutputStream) { in copy()
69 reader.windows.forEach { in copy()
73 var next = reader.source.next() in copy()
[all …]
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/task/
DImportTask.kt40 val reader = StreamingReader(stream) in extractOrImport() constant
41 reader.loadIndex(reader.keepLoadedSize.toLong()) in extractOrImport()
42 val extractor = ExtractorRegistry.extractorFor(reader, importFeedback) in extractOrImport()
44 extractor.extract(reader, this::extractOrImport) in extractOrImport()
46 addImporterSource(reader) in extractOrImport()
55 private fun addImporterSource(reader: StreamingReader) { in addImporterSource()
56 val importer = ImporterRegistry.importerFor(reader, importFeedback) in addImporterSource()
58 val result = importer.import(reader) in addImporterSource()
/tools/tradefederation/core/javatests/com/android/tradefed/targetprep/
DFlashingResourcesParserTest.java63 BufferedReader reader = new BufferedReader(new StringReader(validInfoData)); in testParseAndroidInfo() local
64 AndroidInfo fullInfo = FlashingResourcesParser.parseAndroidInfo(reader, null); in testParseAndroidInfo()
85 BufferedReader reader = new BufferedReader(new StringReader(validInfoData)); in testParseAndroidInfo_withConstraint() local
89 AndroidInfo fullInfo = FlashingResourcesParser.parseAndroidInfo(reader, constraintMap); in testParseAndroidInfo_withConstraint()
116 BufferedReader reader = new BufferedReader(new StringReader(validInfoData)); in testParseAndroidInfo_boardAndProduct() local
118 IFlashingResourcesParser parser = new FlashingResourcesParser(reader); in testParseAndroidInfo_boardAndProduct()
132 BufferedReader reader = new BufferedReader(new StringReader(validInfoData)); in testParseAndroidInfo_onlyBoard() local
134 IFlashingResourcesParser parser = new FlashingResourcesParser(reader); in testParseAndroidInfo_onlyBoard()
151 BufferedReader reader = new BufferedReader(new StringReader(validInfoData)); in testParseAndroidInfo_onlyProduct() local
153 IFlashingResourcesParser parser = new FlashingResourcesParser(reader); in testParseAndroidInfo_onlyProduct()
[all …]
/tools/tradefederation/core/javatests/com/android/tradefed/command/console/
DConfigCompleterTest.java24 import org.jline.reader.Candidate;
25 import org.jline.reader.LineReader;
26 import org.jline.reader.LineReaderBuilder;
27 import org.jline.reader.ParsedLine;
28 import org.jline.reader.Parser;
29 import org.jline.reader.impl.DefaultParser;
40 private LineReader reader = createLineReader(); field in ConfigCompleterTest
58 mConfigCompleter.complete(reader, parsedLine, mCandidates); in testCommandCompletion()
67 mConfigCompleter.complete(reader, parsedLine, mCandidates); in testConfigCompletion()
/tools/dexter/dexter/
Ddexter.cc129 static void PrintDexMap(const dex::Reader& reader) { in PrintDexMap() argument
132 const dex::MapList& dexMap = *reader.DexMapList(); in PrintDexMap()
197 ? reader.Header()->file_size - section.offset in PrintDexMap()
234 static void PrintDexFileStats(const dex::Reader& reader) { in PrintDexFileStats() argument
235 auto header = reader.Header(); in PrintDexFileStats()
236 auto map_list = reader.DexMapList(); in PrintDexFileStats()
247 printf(" method_handle_ids_size : %zu\n", reader.MethodHandles().size()); in PrintDexFileStats()
253 static void ListClasses(const dex::Reader& reader) { in ListClasses() argument
255 auto classes = reader.ClassDefs(); in ListClasses()
256 auto types = reader.TypeIds(); in ListClasses()
[all …]
/tools/netsim/rust/daemon/src/http_server/
Dhttp_request.rs38 reader: &mut BufReader<T>, in parse_http_request()
41 reader.read_line(&mut line).map_err(|e| format!("Failed to read request line: {e}"))?; in parse_http_request()
56 for line in reader.lines() { in parse_http_request()
83 reader.read_exact(&mut body).map_err(|e| format!("Failed to read body: {e}"))?; in parse_http_request()
102 let mut reader = BufReader::new(request.as_bytes()); in test_parse() localVariable
103 let http_request = parse_http_request::<&[u8]>(&mut reader).unwrap(); in test_parse()
117 let mut reader = BufReader::new(request.as_bytes()); in test_parse_without_body() localVariable
118 let http_request = parse_http_request::<&[u8]>(&mut reader).unwrap(); in test_parse_without_body()
132 let mut reader = BufReader::new(request.as_bytes()); in test_parse_without_content_length() localVariable
133 let http_request = parse_http_request::<&[u8]>(&mut reader).unwrap(); in test_parse_without_content_length()
/tools/apksig/src/test/java/com/android/apksig/internal/asn1/ber/
DBerDataValueTest.java103 BerDataValueReader reader = TEST_VALUE1.dataValueReader(); in testDataValueReader() local
104 assertSame(TEST_VALUE1, reader.readDataValue()); in testDataValueReader()
105 assertNull(reader.readDataValue()); in testDataValueReader()
106 assertNull(reader.readDataValue()); in testDataValueReader()
118 BerDataValueReader reader = dataValue.contentsReader(); in testContentsReader() local
119 assertEquals(ByteBufferBerDataValueReader.class, reader.getClass()); in testContentsReader()
120 assertByteBufferEquals(HexEncoding.decode("30020304"), reader.readDataValue().getEncoded()); in testContentsReader()
121 assertByteBufferEquals(HexEncoding.decode("0500"), reader.readDataValue().getEncoded()); in testContentsReader()
122 assertNull(reader.readDataValue()); in testContentsReader()
DBerDataValueReaderTestBase.java49 BerDataValueReader reader = createReader("3000"); // SEQUENCE with empty contents in testEndOfInput() local
50 assertNotNull(reader.readDataValue()); in testEndOfInput()
52 assertNull(reader.readDataValue()); in testEndOfInput()
54 assertNull(reader.readDataValue()); in testEndOfInput()
260 BerDataValueReader reader = createReader("37018f050001020304"); in testReadAdvancesPosition() local
261 assertByteBufferEquals(HexEncoding.decode("37018f"), reader.readDataValue().getEncoded()); in testReadAdvancesPosition()
262 assertByteBufferEquals(HexEncoding.decode("0500"), reader.readDataValue().getEncoded()); in testReadAdvancesPosition()
263 assertByteBufferEquals(HexEncoding.decode("01020304"), reader.readDataValue().getEncoded()); in testReadAdvancesPosition()
264 assertNull(reader.readDataValue()); in testReadAdvancesPosition()
/tools/loganalysis/src/com/android/loganalysis/
DLogAnalyzer.java108 BufferedReader reader = null; in run() local
111 reader = getBufferedReader(mBugreportPath); in run()
112 BugreportItem bugreport = new BugreportParser().parse(reader); in run()
118 reader = getBufferedReader(mLogcatPath); in run()
119 LogcatItem logcat = new LogcatParser().parse(reader); in run()
125 reader = getBufferedReader(mKernelLogPath); in run()
126 KernelLogItem kernelLog = new KernelLogParser().parse(reader); in run()
132 reader = getBufferedReader(mMemoryHealthLogPath); in run()
133 MemoryHealthItem item = new MemoryHealthParser().parse(reader); in run()
139 reader = getBufferedReader(mEventsLogPath); in run()
[all …]
/tools/tradefederation/core/src/com/android/tradefed/command/console/
DConfigCompleter.java18 import org.jline.reader.Candidate;
19 import org.jline.reader.Completer;
20 import org.jline.reader.LineReader;
21 import org.jline.reader.ParsedLine;
39 public void complete(LineReader reader, ParsedLine line, List<Candidate> candidates) { in complete() argument
DConsoleReaderOutputStream.java18 import org.jline.reader.LineReader;
33 public ConsoleReaderOutputStream(LineReader reader) { in ConsoleReaderOutputStream() argument
34 if (reader == null) { in ConsoleReaderOutputStream()
37 mConsoleReader = reader; in ConsoleReaderOutputStream()
/tools/metalava/metalava-model-text/src/main/java/com/android/tools/metalava/model/text/
DFileFormat.kt513 reader: Reader, in <lambda>()
517 if (reader is LineNumberReader) reader else LineNumberReader(reader, BUFFER_SIZE) in <lambda>()
542 reader: LineNumberReader, in <lambda>()
547 reader.mark(BUFFER_SIZE) in <lambda>()
554 reader.read(buffer, 0, prefixLength).let { count -> in <lambda>()
567 var line = reader.readLine() in <lambda>()
569 line = reader.readLine() in <lambda>()
582 reader.reset() in <lambda>()
594 reader.lineNumber = 1 in <lambda>()
602 val versionNumber = reader.readLine() in <lambda>()
[all …]
/tools/netsim/rust/capture/tests/
Dintegration_test.rs30 let mut reader = BufReader::new(Cursor::new(DATA)); in read_file() localVariable
31 let header = pcap::read_file_header(&mut reader).await?; in read_file()
36 match pcap::read_record(&mut reader).await { in read_file()
47 assert_eq!(DATA.len() as u64, reader.stream_position().await?); in read_file()
/tools/netsim/rust/http-proxy/src/
Dconnector.rs66 let mut reader = BufReader::new(stream); in connect() localVariable
68 reader.read_line(&mut response).await?; in connect()
70 Ok(reader.into_inner()) in connect()
99 let mut reader = BufReader::new(stream); in test_connect() localVariable
102 reader.read_line(&mut line).await.unwrap(); in test_connect()
108 let mut stream = reader.into_inner(); in test_connect()
/tools/tradefederation/contrib/src/com/android/media/tests/
DCameraShotToShotLatencyTest.java119 BufferedReader reader = null; in parseOutputFile() local
131 reader = new BufferedReader(new FileReader(outputFile)); in parseOutputFile()
133 lineMean = reader.readLine(); in parseOutputFile()
134 lineSd = reader.readLine(); in parseOutputFile()
157 if (reader != null) { in parseOutputFile()
159 reader.close(); in parseOutputFile()
/tools/metalava/metalava/src/main/java/com/android/tools/metalava/cli/signature/
DUpdateSignatureHeaderCommand.kt97 LineNumberReader(file.reader()).use { reader -> in <lambda>() method
100 val currentFormat = parseHeader(file.toPath(), reader) in <lambda>()
116 val line = reader.readLine() ?: break in <lambda>()
/tools/netsim/rust/capture/src/
Dpcap.rs184 pub async fn read_file_header(mut reader: impl AsyncRead + Unpin) -> Result<FileHeader> { in read_file_header()
186 reader.read_exact(&mut header_bytes).await?; in read_file_header()
211 pub async fn read_record(mut reader: impl AsyncRead + Unpin) -> Result<(PacketHeader, Vec<u8>)> { in read_record()
213 reader.read_exact(&mut pkt_hdr_bytes).await?; in read_record()
219 reader.read_exact(&mut packet_data).await?; in read_record()
/tools/metalava/metalava-testing/src/main/java/com/android/tools/metalava/testing/
DBaselineFile.kt51 baselineFile.reader().use { baseline.read(it, baselineFile.path) } in <lambda>()
65 resource?.openStream()?.reader()?.use { baseline.read(it, resource.toExternalForm()) } in <lambda>()
89 val reader = LineNumberReader(streamReader) in read() constant
92 val line = reader.readLine() ?: break in read()
/tools/netsim/rust/http-proxy/benches/
Ddns_benchmark.rs25 let mut reader = BufReader::new(Cursor::new(DATA)); in dns_benchmark() localVariable
26 let header = pcap::read_file_header(&mut reader).await.unwrap(); in dns_benchmark()
30 match pcap::read_record(&mut reader).await { in dns_benchmark()
/tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/events/
DEventParserState.kt102 val reader = BufferReader() in createEventParser() constant
105 reader.reset(slice, stringCache) in createEventParser()
106 return reader.tryMatch(matchers[matcher], result) in createEventParser()
114 return reader.read(detailsSlice, stringCache, init) in createEventParser()
/tools/netsim/rust/http-proxy/tests/
Dintegration_test.rs32 let mut reader = BufReader::new(Cursor::new(DATA)); in dns_manager() localVariable
33 let header = pcap::read_file_header(&mut reader).await?; in dns_manager()
37 match pcap::read_record(&mut reader).await { in dns_manager()

123