Searched refs:pipe (Results 1 – 4 of 4) sorted by relevance
| /tools/trebuchet/core/common/src/main/kotlin/trebuchet/extractors/ |
| D | SystraceExtractor.kt | 38 val pipe = Pipe<DataSlice>() in <lambda>() constant
40 stream.onWindowReleased = { window -> processWindow(window, pipe) } in <lambda>()
46 stream.windows.forEach { processWindow(it, pipe) } in <lambda>()
47 pipe.close() in <lambda>()
51 processSubStream(SubStream(pipe)) in <lambda>()
59 private class SubStream(val pipe: Pipe<DataSlice>) : BufferProducer { in <lambda>() constant in trebuchet.extractors.SystraceExtractor.SubStream
60 override fun next(): DataSlice? = pipe.next() in <lambda>()
63 private fun processWindow(window: StreamingReader.Window, pipe: Pipe<DataSlice>) { in <lambda>()
66 pipe.add(window.slice) in <lambda>()
70 pipe.add(window.slice.slice(sliceStart.toInt(), sliceEnd.toInt())) in <lambda>()
|
| /tools/tradefederation/core/src/com/android/tradefed/util/ |
| D | TableBuilder.java | 65 Separator(char end, char pipe, String text) { in Separator() argument
67 mPipe = pipe; in Separator()
219 public TableBuilder addSeparator(char end, char pipe) { in addSeparator() argument
220 mTable.add(new Separator(end, pipe, "")); in addSeparator()
|
| /tools/netsim/scripts/ |
| D | utils.py | 243 def _reader(pipe, logfn): argument
245 with pipe:
246 for line in iter(pipe.readline, b""):
|
| /tools/tradefederation/core/src/com/android/tradefed/device/ |
| D | TestDevice.java | 2938 PipedInputStream pipe = new PipedInputStream(); in startMicrodroid() local
2939 process = getRunUtil().runCmdInBackground(args, new PipedOutputStream(pipe)); in startMicrodroid()
2940 cid = getCidFromVmRunOutput(new InputStreamReader(pipe)); in startMicrodroid()
|