| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/ |
| H A D | PipeTest.java | 37 Pipe pipe = Pipe.open();
38 assertNotNull(pipe);
45 Pipe pipe = Pipe.open();
46 SinkChannel sink = pipe.sink();
54 Pipe pipe = Pipe.open();
55 SourceChannel source = pipe.source();
|
| H A D | SourceChannelTest.java | 36 private Pipe pipe; field in class:SourceChannelTest
48 pipe = Pipe.open();
49 sink = pipe.sink();
50 source = pipe.source();
158 // open new pipe everytime, will be closed in finally block
159 pipe = Pipe.open();
160 sink = pipe.sink();
161 source = pipe.source();
194 // close pipe everytime
301 Pipe pipe
[all...] |
| H A D | SinkChannelTest.java | 40 private Pipe pipe; field in class:SinkChannelTest
52 pipe = Pipe.open();
53 sink = pipe.sink();
54 source = pipe.source();
|
| H A D | SelectorTest.java | 361 final Pipe pipe = Pipe.open();
362 pipe.source().configureBlocking(false);
363 final SelectionKey key = pipe.source().register(selector, SelectionKey.OP_READ);
372 pipe.sink().write(ByteBuffer.allocate(4)); // unblock select()
|
| H A D | FileChannelTest.java | 103 private Pipe pipe; field in class:FileChannelTest
212 if (null != pipe) {
213 if (null != pipe.source()) {
215 pipe.source().close();
220 if (null != pipe.sink()) {
222 pipe.sink().close();
2575 // inits pipe.
2576 pipe = Pipe.open();
2578 // writes content to pipe.
2580 pipe
[all...] |
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| H A D | ChannelsTest.java | 52 Pipe pipe = Pipe.open();
53 WritableByteChannel sinkChannel = pipe.sink();
55 Pipe.SourceChannel sourceChannel = pipe.source();
|
| /libcore/luni/src/test/java/libcore/java/io/ |
| H A D | FileInputStreamTest.java | 70 FileDescriptor[] pipe = Libcore.os.pipe();
71 DataFeeder feeder = new DataFeeder(pipe[1]);
74 FileInputStream fis = new FileInputStream(pipe[0]);
81 IoUtils.closeQuietly(pipe[0]);
|
| /libcore/luni/src/main/native/ |
| H A D | java_lang_ProcessManager.cpp | 93 // Create 4 pipes: stdin, stdout, stderr, and an exec() status pipe.
96 if (pipe(pipes + i * 2) == -1) {
165 // Close child's pipe ends.
171 // Check status pipe for an error code. If execvp(2) succeeds, the other
172 // end of the pipe should automatically close, in which case, we'll read
|
| H A D | libcore_io_Posix.cpp | 1041 throwIfMinusOne(env, "pipe", TEMP_FAILURE_RETRY(pipe(&fds[0])));
1598 NATIVE_METHOD(Posix, pipe, "()[Ljava/io/FileDescriptor;"),
|
| /libcore/luni/src/main/java/android/system/ |
| H A D | Os.java | 303 * See <a href="http://man7.org/linux/man-pages/man2/pipe.2.html">pipe(2)</a>.
305 public static FileDescriptor[] pipe() throws ErrnoException { return Libcore.os.pipe(); } method in class:Os
|
| /libcore/luni/src/main/java/libcore/io/ |
| H A D | ForwardingOs.java | 116 public FileDescriptor[] pipe() throws ErrnoException { return os.pipe(); } method in class:ForwardingOs
|
| H A D | Os.java | 108 public FileDescriptor[] pipe() throws ErrnoException; method in interface:Os
|
| H A D | Posix.java | 110 public native FileDescriptor[] pipe() throws ErrnoException; method in class:Posix
|
| /libcore/luni/src/main/java/java/nio/ |
| H A D | SelectorImpl.java | 80 * The wakeup pipe. To trigger a wakeup, write a byte to wakeupOut. Each
92 * Create a pipe to trigger wakeup. We can't use a NIO pipe because it
94 * configure the pipe so we can fully drain it without blocking.
97 FileDescriptor[] pipeFds = Libcore.os.pipe();
212 int i = 1; // Our wakeup pipe comes before all the user's fds.
229 // We need one slot for each element of mutableKeys, plus one for the wakeup pipe.
240 // Read bytes from the wakeup pipe until the pipe is empty.
|