Home
last modified time | relevance | path

Searched refs:pipes (Results 1 – 25 of 223) sorted by relevance

123456789

/third_party/python/Lib/test/
Dtest_pipes.py1 import pipes
29 t = pipes.Template()
30 t.append(s_command, pipes.STDIN_STDOUT)
41 t = pipes.Template()
42 t.append(s_command + ' < $IN > $OUT', pipes.FILEIN_FILEOUT)
52 t = pipes.Template()
53 t.append(s_command + ' < $IN', pipes.FILEIN_STDOUT)
67 t=pipes.Template()
77 t=pipes.Template()
87 t = pipes.Template()
[all …]
/third_party/ltp/testcases/kernel/syscalls/splice/
Dsplice03.c46 static int pipes[2]; variable
56 { &badfd, NULL, &pipes[1], NULL, EBADF },
57 { &pipes[0], NULL, &badfd, NULL, EBADF },
58 { &wrfd, NULL, &pipes[1], NULL, EBADF },
59 { &pipes[0], NULL, &appendfd, NULL, EINVAL },
61 { &pipes[0], &offset, &wrfd, NULL, ESPIPE },
62 { &rdfd, NULL, &pipes[1], &offset, ESPIPE },
74 SAFE_PIPE(pipes); in setup()
76 SAFE_WRITE(1, pipes[1], STR, sizeof(STR) - 1); in setup()
113 if (pipes[0] > 0) in cleanup()
[all …]
Dsplice01.c55 int pipes[2]; in splice_test() local
60 SAFE_PIPE(pipes); in splice_test()
62 ret = splice(fd_in, NULL, pipes[1], NULL, TEST_BLOCK_SIZE, 0); in splice_test()
66 ret = splice(pipes[0], NULL, fd_out, NULL, TEST_BLOCK_SIZE, 0); in splice_test()
72 SAFE_CLOSE(pipes[0]); in splice_test()
73 SAFE_CLOSE(pipes[1]); in splice_test()
/third_party/ltp/testcases/kernel/syscalls/tee/
Dtee02.c33 static int pipes[2]; variable
40 { &fd, &pipes[1], EINVAL },
41 { &pipes[0], &fd, EINVAL },
42 { &pipes[0], &pipes[1], EINVAL },
48 SAFE_PIPE(pipes); in setup()
49 SAFE_WRITE(1, pipes[1], STR, sizeof(STR) - 1); in setup()
80 if (pipes[0] > 0) in cleanup()
81 SAFE_CLOSE(pipes[0]); in cleanup()
83 if (pipes[1] > 0) in cleanup()
84 SAFE_CLOSE(pipes[1]); in cleanup()
/third_party/ltp/testcases/kernel/syscalls/vmsplice/
Dvmsplice04.c19 static int pipes[2]; variable
29 TEST(vmsplice(pipes[1], &iov, 1, SPLICE_F_NONBLOCK)); in vmsplice_test()
44 TEST(vmsplice(pipes[1], &iov, 1, 0)); in vmsplice_test()
64 if (pipes[1] > 0) in cleanup()
65 SAFE_CLOSE(pipes[1]); in cleanup()
66 if (pipes[0] > 0) in cleanup()
67 SAFE_CLOSE(pipes[0]); in cleanup()
72 SAFE_PIPE(pipes); in setup()
74 pipe_max_size = SAFE_FCNTL(pipes[1], F_GETPIPE_SZ); in setup()
80 TEST(vmsplice(pipes[1], &iov, 1, 0)); in setup()
Dvmsplice02.c37 static int pipes[2]; variable
48 { &pipes[1], &ivc, IOV_MAX + 1, EINVAL },
55 SAFE_PIPE(pipes); in setup()
89 if (pipes[0] > 0) in cleanup()
90 SAFE_CLOSE(pipes[0]); in cleanup()
92 if (pipes[1] > 0) in cleanup()
93 SAFE_CLOSE(pipes[1]); in cleanup()
Dvmsplice03.c24 int pipes[2]; in vmsplice_test() local
29 SAFE_PIPE(pipes); in vmsplice_test()
30 SAFE_WRITE(1, pipes[1], buffer, TEST_BLOCK_SIZE); in vmsplice_test()
31 written = vmsplice(pipes[0], iov, 1, 0); in vmsplice_test()
50 SAFE_CLOSE(pipes[1]); in vmsplice_test()
51 SAFE_CLOSE(pipes[0]); in vmsplice_test()
Dvmsplice01.c51 int pipes[2]; in vmsplice_test() local
62 SAFE_PIPE(pipes); in vmsplice_test()
64 struct pollfd pfd = {.fd = pipes[1], .events = POLLOUT}; in vmsplice_test()
76 written = vmsplice(pipes[1], &v, 1, 0); in vmsplice_test()
88 ret = splice(pipes[0], NULL, fd_out, &offset, written, 0); in vmsplice_test()
94 SAFE_CLOSE(pipes[0]); in vmsplice_test()
95 SAFE_CLOSE(pipes[1]); in vmsplice_test()
/third_party/node/test/parallel/
Dtest-stream-pipe-same-destination-twice.js23 assert.strictEqual(passThrough._readableState.pipes.length, 2);
24 assert.strictEqual(passThrough._readableState.pipes[0], dest);
25 assert.strictEqual(passThrough._readableState.pipes[1], dest);
30 assert.strictEqual(passThrough._readableState.pipes.length, 1);
31 assert.deepStrictEqual(passThrough._readableState.pipes, [dest]);
50 assert.strictEqual(passThrough._readableState.pipes.length, 2);
51 assert.strictEqual(passThrough._readableState.pipes[0], dest);
52 assert.strictEqual(passThrough._readableState.pipes[1], dest);
67 assert.strictEqual(passThrough._readableState.pipes.length, 2);
68 assert.strictEqual(passThrough._readableState.pipes[0], dest);
[all …]
Dtest-stream-pipe-unpipe-streams.js17 assert.strictEqual(source._readableState.pipes[0], dest1);
18 assert.strictEqual(source._readableState.pipes[1], dest2);
19 assert.strictEqual(source._readableState.pipes.length, 2);
25 assert.deepStrictEqual(source._readableState.pipes, [dest1]);
26 assert.notStrictEqual(source._readableState.pipes, dest2);
33 assert.strictEqual(source._readableState.pipes.length, 0);
46 assert.strictEqual(source._readableState.pipes.length, 0);
Dtest-stream-unpipe-event.js26 assert.strictEqual(src._readableState.pipes.length, 0);
37 assert.strictEqual(src._readableState.pipes.length, 1);
49 assert.strictEqual(src._readableState.pipes.length, 0);
60 assert.strictEqual(src._readableState.pipes.length, 0);
71 assert.strictEqual(src._readableState.pipes.length, 1);
83 assert.strictEqual(src._readableState.pipes.length, 0);
/third_party/libuv/src/unix/
Dprocess.c258 int (*pipes)[2], in uv__process_child_init()
294 use_fd = pipes[fd][1]; in uv__process_child_init()
298 pipes[fd][1] = fcntl(use_fd, F_DUPFD_CLOEXEC, stdio_count); in uv__process_child_init()
300 pipes[fd][1] = fcntl(use_fd, F_DUPFD, stdio_count); in uv__process_child_init()
302 if (pipes[fd][1] == -1) in uv__process_child_init()
305 n = uv__cloexec(pipes[fd][1], 1); in uv__process_child_init()
313 use_fd = pipes[fd][1]; in uv__process_child_init()
516 int (*pipes)[2]) { in uv__spawn_set_posix_spawn_file_actions()
547 use_fd = pipes[fd][1]; in uv__spawn_set_posix_spawn_file_actions()
555 if (pipes[fd2][1] == use_fd) { in uv__spawn_set_posix_spawn_file_actions()
[all …]
/third_party/toybox/lib/
Dxwrap.c227 pid_t xpopen_both(char **argv, int *pipes) in xpopen_both() argument
233 if (pipes) for (pid = 0; pid < 2; pid++) { in xpopen_both()
234 if (pipes[pid] != -1) continue; in xpopen_both()
241 if (pipes) { in xpopen_both()
248 pipes[1] = cestnepasun[3]; in xpopen_both()
254 pipes[0] = cestnepasun[0]; in xpopen_both()
258 if (!pipes[1]) pipes[1] = dup(0); in xpopen_both()
261 if (pipes[0]) { in xpopen_both()
262 dup2(pipes[0], 0); in xpopen_both()
263 close(pipes[0]); in xpopen_both()
[all …]
/third_party/glib/glib/tests/
Dprotocol.c138 int pipes[2]; in test_message() local
144 if (0 > pipe (pipes)) in test_message()
150 argv[1] = g_strdup_printf ("--GTestLogFD=%u", pipes[1]); in test_message()
166 channel = g_io_channel_win32_new_fd (pipes[0]); in test_message()
168 channel = g_io_channel_unix_new (pipes[0]); in test_message()
269 int pipes[2]; in test_error() local
271 if (0 > pipe (pipes)) in test_error()
277 argv[1] = g_strdup_printf ("--GTestLogFD=%u", pipes[1]); in test_error()
293 channel = g_io_channel_win32_new_fd (pipes[0]); in test_error()
295 channel = g_io_channel_unix_new (pipes[0]); in test_error()
/third_party/mesa3d/src/gallium/drivers/r300/
Dr300_texture_desc.c355 unsigned i, pipes; in r300_setup_hyperz_properties() local
358 pipes = screen->info.r300_num_z_pipes; in r300_setup_hyperz_properties()
360 pipes = screen->info.r300_num_gb_pipes; in r300_setup_hyperz_properties()
378 zmask_blocks_x_per_dw[pipes-1] * zcompsize, in r300_setup_hyperz_properties()
379 zmask_blocks_y_per_dw[pipes-1] * zcompsize); in r300_setup_hyperz_properties()
383 zcomp_numdw <= screen->caps.zmask_ram * pipes) { in r300_setup_hyperz_properties()
388 util_align_npot(stride, zmask_blocks_x_per_dw[pipes-1] * zcompsize); in r300_setup_hyperz_properties()
396 stride = util_align_npot(stride, hiz_align_x[pipes-1]); in r300_setup_hyperz_properties()
397 height = align(height, hiz_align_y[pipes-1]); in r300_setup_hyperz_properties()
400 hiz_numdw = (stride * height) / (8*8 * pipes); in r300_setup_hyperz_properties()
[all …]
/third_party/node/test/async-hooks/
Dtest-pipeconnectwrap.js34 const pipes = hooks.activitiesOfTypes('PIPEWRAP');
36 assert.strictEqual(pipes.length, 1);
40 pipe1 = pipes[0];
61 const pipes = hooks.activitiesOfTypes('PIPEWRAP');
64 assert.strictEqual(pipes.length, 2);
66 pipe2 = pipes[1];
Dtest-pipewrap.js28 const pipes = hooks.activitiesOfTypes('PIPEWRAP'); constant
30 assert.strictEqual(pipes.length, 3);
33 const pipe1 = pipes[0];
34 const pipe2 = pipes[1];
35 const pipe3 = pipes[2];
/third_party/python/Doc/library/
Dpipes.rst1 :mod:`pipes` --- Interface to shell pipelines
4 .. module:: pipes
10 **Source code:** :source:`Lib/pipes.py`
14 The :mod:`pipes` module defines a class to abstract the concept of a *pipeline*
22 The :mod:`pipes` module defines the following class:
31 >>> import pipes
32 >>> t = pipes.Template()
/third_party/toybox/toys/other/
Doneit.c66 int i, pid, pipes[] = {SIGUSR1, SIGUSR2, SIGTERM, SIGINT}; in oneit_main() local
69 for (i = 0; i<ARRAY_LEN(pipes); i++) xsignal(pipes[i], oneit_signaled); in oneit_main()
76 xpipe(pipes); in oneit_main()
/third_party/skia/third_party/externals/opengl-registry/extensions/SGIX/
DGLX_SGIX_hyperpipe.txt37 pipes; the image outputs of these pipes must then be assembled into
38 a single display output. This group of pipes is termed a hyperpipe;
39 the pipes involved must be physically cabled together in some way
41 of the pipes to assemble the rendered images and drive the display.
49 use a subset of the pipes connected to a hyperpipe network if desired.
52 of rendering pipes which work together to produce a single display.
68 For example, on a hyperpipe network consisting of five pipes, it
70 with each slice being rendered by two pipes; thus using four total
71 pipes. (The fifth pipe would not be used in the hyperpipe, and
75 spatial subdivision, swap cannot occur until all pipes rendering
[all …]
/third_party/openGLES/extensions/SGIX/
DGLX_SGIX_hyperpipe.txt37 pipes; the image outputs of these pipes must then be assembled into
38 a single display output. This group of pipes is termed a hyperpipe;
39 the pipes involved must be physically cabled together in some way
41 of the pipes to assemble the rendered images and drive the display.
49 use a subset of the pipes connected to a hyperpipe network if desired.
52 of rendering pipes which work together to produce a single display.
68 For example, on a hyperpipe network consisting of five pipes, it
70 with each slice being rendered by two pipes; thus using four total
71 pipes. (The fifth pipe would not be used in the hyperpipe, and
75 spatial subdivision, swap cannot occur until all pipes rendering
[all …]
/third_party/openssl/ssl/record/
Dssl3_buffer.c156 size_t pipes; in ssl3_release_write_buffer() local
158 pipes = s->rlayer.numwpipes; in ssl3_release_write_buffer()
159 while (pipes > 0) { in ssl3_release_write_buffer()
160 wb = &RECORD_LAYER_get_wbuf(&s->rlayer)[pipes - 1]; in ssl3_release_write_buffer()
164 pipes--; in ssl3_release_write_buffer()
/third_party/ltp/testcases/kernel/syscalls/pipe/
Dpipe07.c60 int pipes[2], max_fd = 0; in main() local
72 ret = pipe(pipes); in main()
82 max_fd = MAX(pipes[0], max_fd); in main()
83 max_fd = MAX(pipes[1], max_fd); in main()
Dpipe06.c53 int pipe_ret, pipes[2]; variable
70 TEST(pipe(pipes)); in main()
102 pipe_ret = pipe(pipes); in setup()
/third_party/node/deps/npm/node_modules/sorted-union-stream/node_modules/readable-stream/lib/
D_stream_readable.js81 this.pipes = null;
505 state.pipes = dest;
508 state.pipes = [state.pipes, dest];
511 state.pipes.push(dest);
655 if (dest && dest !== state.pipes)
659 dest = state.pipes;
662 state.pipes = null;
674 var dests = state.pipes;
676 state.pipes = null;
686 var i = indexOf(state.pipes, dest);
[all …]

123456789