| /bionic/tests/ |
| fcntl_test.cpp | 205 int pipe1[2]; local
206 ASSERT_EQ(0, pipe(pipe1));
214 // Write /proc/version into pipe1.
215 ssize_t bytes_read = splice(in, 0, pipe1[1], NULL, 8*1024, SPLICE_F_MORE | SPLICE_F_MOVE);
217 close(pipe1[1]);
219 // Tee /proc/version from pipe1 into pipe2.
220 ssize_t bytes_teed = tee(pipe1[0], pipe2[1], SIZE_MAX, 0);
224 // The out fds of both pipe1 and pipe2 should now contain /proc/version.
226 FILE* fp1 = fdopen(pipe1[0], "r");
|
| /libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/ |
| DoubleStreamTestScenario.java | 158 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
160 DoubleStream pipe2 = m.apply(pipe1);
183 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
185 m.apply(pipe1).forEach(e -> {
|
| IntStreamTestScenario.java | 159 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
161 IntStream pipe2 = m.apply(pipe1);
184 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
186 m.apply(pipe1).forEach(e -> {
|
| LongStreamTestScenario.java | 158 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
160 LongStream pipe2 = m.apply(pipe1);
183 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
185 m.apply(pipe1).forEach(e -> {
|
| StreamTestScenario.java | 170 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
172 Stream<U> pipe2 = m.apply(pipe1);
222 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
224 m.apply(pipe1).forEach(e -> {
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| DoubleStreamTestScenario.java | 162 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
164 DoubleStream pipe2 = m.apply(pipe1);
187 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
189 m.apply(pipe1).forEach(e -> {
|
| IntStreamTestScenario.java | 162 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
164 IntStream pipe2 = m.apply(pipe1);
187 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
189 m.apply(pipe1).forEach(e -> {
|
| LongStreamTestScenario.java | 161 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
163 LongStream pipe2 = m.apply(pipe1);
186 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
188 m.apply(pipe1).forEach(e -> {
|
| StreamTestScenario.java | 173 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
175 Stream<U> pipe2 = m.apply(pipe1);
225 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), local
227 m.apply(pipe1).forEach(e -> {
|
