Searched refs:StreamingReader (Results 1 – 13 of 13) sorted by relevance
| /tools/trebuchet/trebuchet/traceutils/src/ |
| D | TraceUtils.kt | 22 import trebuchet.io.StreamingReader in <lambda>()
41 traceFound: (StreamingReader) -> Unit) { in findTraces()
44 val reader = StreamingReader(stream) in findTraces()
68 fun copy(reader: StreamingReader, output: OutputStream) { in copy()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/util/ |
| D | StringSearch.kt | 20 import trebuchet.io.StreamingReader
68 … fun find(reader: StreamingReader, startIndex: Long = 0, inEndIndex: Long = Long.MAX_VALUE): Long { in find()
108 fun findInLoadedRegion(reader: StreamingReader, endIndex: Long = reader.endIndex): Long { in findInLoadedRegion()
168 …private fun findInWindow(window: StreamingReader.Window, globalStartIndex: Long, globalEndIndex: L… in findInWindow()
192 if (this is StreamingReader) { in searchFor()
|
| /tools/trebuchet/core/common/src/test/kotlin/trebuchet/testutils/ |
| D | StringToStreamAdapter.kt | 21 import trebuchet.io.StreamingReader
24 fun String.makeReader(): StreamingReader { in makeReader()
26 return StreamingReader(object : BufferProducer { in makeReader()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/task/ |
| D | ImportTask.kt | 23 import trebuchet.io.StreamingReader
40 val reader = StreamingReader(stream) in extractOrImport()
55 private fun addImporterSource(reader: StreamingReader) { in addImporterSource()
|
| /tools/trebuchet/core/common/src/test/kotlin/trebuchet/extractors/ |
| D | SystraceExtractorTest.kt | 23 import trebuchet.io.StreamingReader in <lambda>()
88 fun makeStream(list: Iterator<String>): StreamingReader { in <lambda>()
89 return StreamingReader(object : BufferProducer { in <lambda>()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ |
| D | Importer.kt | 19 import trebuchet.io.StreamingReader
30 fun import(stream: StreamingReader): ModelFragment?
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/extractors/ |
| D | Extractor.kt | 20 import trebuchet.io.StreamingReader
34 fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit)
|
| D | SystraceExtractor.kt | 28 override fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit) { in <lambda>()
63 private fun processWindow(window: StreamingReader.Window, pipe: Pipe<DataSlice>) { in <lambda>()
|
| D | ZlibExtractor.kt | 42 private class DeflateProducer(stream: StreamingReader, val feedback: ImportFeedback)
89 override fun extract(stream: StreamingReader, processSubStream: (BufferProducer) -> Unit) { in extract()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/importers/ftrace/ |
| D | FtraceImporter.kt | 26 import trebuchet.io.StreamingReader in <lambda>()
36 override fun import(stream: StreamingReader): ModelFragment? { in <lambda>()
|
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/io/ |
| D | StreamingLineReader.kt | 21 private fun findNewlineInWindow(window: StreamingReader.Window, startIndex: Long): Long { in findNewlineInWindow()
32 fun StreamingReader.iterLines() = iterator { in <lambda>() method
|
| D | StreamingReader.kt | 21 class StreamingReader(val source: BufferProducer, val keepLoadedSize: Int = 8096) : GenericByteBuff… class
|
| /tools/trebuchet/core/common/src/test/kotlin/trebuchet/importers/ftrace/ |
| D | FtraceImporterTest.kt | 22 import trebuchet.io.StreamingReader
28 fun String.makeLoadedReader(): StreamingReader { in String()
|