| /libcore/harmony-tests/src/test/java/org/apache/harmony/tests/java/nio/channels/ |
| D | PipeTest.java | 37 Pipe pipe = Pipe.open(); in test_open() local
38 assertNotNull(pipe); in test_open()
45 Pipe pipe = Pipe.open(); in test_sink() local
46 SinkChannel sink = pipe.sink(); in test_sink()
54 Pipe pipe = Pipe.open(); in test_source() local
55 SourceChannel source = pipe.source(); in test_source()
|
| D | SourceChannelTest.java | 36 private Pipe pipe; field in SourceChannelTest
48 pipe = Pipe.open(); in setUp()
49 sink = pipe.sink(); in setUp()
50 source = pipe.source(); in setUp()
159 pipe = Pipe.open(); in test_read_$LByteBuffer()
160 sink = pipe.sink(); in test_read_$LByteBuffer()
161 source = pipe.source(); in test_read_$LByteBuffer()
301 Pipe pipe = Pipe.open(); in test_read_$LByteBufferII() local
302 sink = pipe.sink(); in test_read_$LByteBufferII()
303 source = pipe.source(); in test_read_$LByteBufferII()
|
| D | SinkChannelTest.java | 40 private Pipe pipe; field in SinkChannelTest
52 pipe = Pipe.open(); in setUp()
53 sink = pipe.sink(); in setUp()
54 source = pipe.source(); in setUp()
|
| 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()
|
| D | FileChannelTest.java | 109 private Pipe pipe; field in FileChannelTest
171 if (null != pipe) { in tearDown()
172 IoUtils.closeQuietly(pipe.source()); in tearDown()
173 IoUtils.closeQuietly(pipe.sink()); in tearDown()
2674 pipe = Pipe.open(); in test_transferFromLReadableByteChannelJJ_Pipe()
2678 pipe.sink().write(writeBuffer); in test_transferFromLReadableByteChannelJJ_Pipe()
2683 long result = writeOnlyFileChannel.transferFrom(pipe.source(), OFFSET, in test_transferFromLReadableByteChannelJJ_Pipe()
3045 pipe = Pipe.open(); in test_transferToJJLWritableByteChannel_Pipe()
3050 long result = readOnlyFileChannel.transferTo(OFFSET, LENGTH, pipe in test_transferToJJLWritableByteChannel_Pipe()
3058 result = pipe.source().read(readBuffer); in test_transferToJJLWritableByteChannel_Pipe()
|
| /libcore/luni/src/test/java/libcore/java/nio/channels/ |
| D | ChannelsTest.java | 65 Pipe pipe = Pipe.open(); in createNonBlockingChannel() local
66 WritableByteChannel sinkChannel = pipe.sink(); in createNonBlockingChannel()
68 Pipe.SourceChannel sourceChannel = pipe.source(); in createNonBlockingChannel()
|
| /libcore/luni/src/test/java/libcore/java/io/ |
| D | FileInputStreamTest.java | 86 FileDescriptor[] pipe = Libcore.os.pipe2(0); in testSkipInPipes() local
87 DataFeeder feeder = new DataFeeder(pipe[1]); in testSkipInPipes()
90 FileInputStream fis = new FileInputStream(pipe[0]); in testSkipInPipes()
97 IoUtils.closeQuietly(pipe[0]); in testSkipInPipes()
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| D | OpTestCase.java | 622 … private static AbstractPipeline<?, ?, ?> chain(AbstractPipeline pipe, IntermediateTestOp... ops) { in chain() argument
624 pipe = chain(pipe, op); in chain()
625 return pipe; in chain()
629 … private static <T> AbstractPipeline<?, T, ?> chain(BaseStream pipe, IntermediateTestOp<?, T> op) { in chain() argument
630 return chain((AbstractPipeline) pipe, op); in chain()
634 public static AbstractPipeline<?, ?, ?> chain(BaseStream pipe, IntermediateTestOp... ops) { in chain() argument
635 return chain((AbstractPipeline) pipe, ops); in chain()
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| D | OpTestCase.java | 623 … private static AbstractPipeline<?, ?, ?> chain(AbstractPipeline pipe, IntermediateTestOp... ops) { in chain() argument
625 pipe = chain(pipe, op); in chain()
626 return pipe; in chain()
630 … private static <T> AbstractPipeline<?, T, ?> chain(BaseStream pipe, IntermediateTestOp<?, T> op) { in chain() argument
631 return chain((AbstractPipeline) pipe, op); in chain()
635 public static AbstractPipeline<?, ?, ?> chain(BaseStream pipe, IntermediateTestOp... ops) { in chain() argument
636 return chain((AbstractPipeline) pipe, ops); in chain()
|
| /libcore/ojluni/src/main/native/ |
| D | UNIXProcess_md.c | 909 if ((fds[0] == -1 && pipe(in) < 0) || in UNIXProcess_forkAndExec()
910 (fds[1] == -1 && pipe(out) < 0) || in UNIXProcess_forkAndExec()
911 (fds[2] == -1 && pipe(err) < 0) || in UNIXProcess_forkAndExec()
912 (pipe(fail) < 0)) { in UNIXProcess_forkAndExec()
|
| D | IOUtil.c | 95 if (pipe(fd) < 0) { in IOUtil_makePipe()
|
| /libcore/luni/src/test/java/libcore/android/system/ |
| D | OsTest.java | 1384 FileDescriptor[] pipe = Os.pipe2(0); in test_splice() local
1395 .splice(fdIn, offIn, pipe[1], null /* offOut */, 10 /* len */, 0 /* flags */); in test_splice()
1404 .splice(pipe[0], null /* offIn */, fdOut, offOut, 10 /* len */, 0 /* flags */); in test_splice()
1411 Os.close(pipe[0]); in test_splice()
1412 Os.close(pipe[1]); in test_splice()
1418 FileDescriptor[] pipe = Os.pipe2(0); in test_splice_errors() local
1422 Os.splice(null /* fdIn */, null /* offIn */, pipe[1], in test_splice_errors()
1431 Os.splice(pipe[0] /* fdIn */, null /* offIn */, null /* fdOut */, in test_splice_errors()
1451 Os.close(pipe[0]); in test_splice_errors()
1452 Os.close(pipe[1]); in test_splice_errors()
|
| /libcore/luni/src/main/java/android/system/ |
| D | Os.java | 417 public static FileDescriptor[] pipe() throws ErrnoException { return Libcore.os.pipe2(0); } in pipe() method in Os
|