Home
last modified time | relevance | path

Searched refs:pipes (Results 1 - 25 of 43) sorted by relevance

12

/third_party/python/Lib/test/
H A Dtest_pipes.py9 pipes = import_deprecated("pipes") variable
13 raise unittest.SkipTest('pipes module only works on posix')
16 raise unittest.SkipTest('pipes module requires a shell')
31 t = pipes.Template()
32 t.append(s_command, pipes.STDIN_STDOUT)
43 t = pipes.Template()
44 t.append(s_command + ' < $IN > $OUT', pipes.FILEIN_FILEOUT)
54 t = pipes.Template()
55 t.append(s_command + ' < $IN', pipes
[all...]
/third_party/ltp/testcases/kernel/syscalls/splice/
H A 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(SAFE_WRITE_ALL, pipes[1], STR, sizeof(STR) - 1); in setup()
113 if (pipes[ in cleanup()
[all...]
H A 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/
H A 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(SAFE_WRITE_ALL, 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[ in cleanup()
[all...]
/third_party/node/deps/uv/src/unix/
H A 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()
540 /* Do not return ENOSYS after this point, as we may mutate pipes. */ in uv__spawn_set_posix_spawn_file_actions()
547 use_fd = pipes[f in uv__spawn_set_posix_spawn_file_actions()
256 uv__process_child_init(const uv_process_options_t* options, int stdio_count, int (*pipes)[2], int error_fd) uv__process_child_init() argument
511 uv__spawn_set_posix_spawn_file_actions( posix_spawn_file_actions_t* actions, const uv__posix_spawn_fncs_t* posix_spawn_fncs, const uv_process_options_t* options, int stdio_count, int (*pipes)[2]) uv__spawn_set_posix_spawn_file_actions() argument
748 uv__spawn_and_init_child_posix_spawn( const uv_process_options_t* options, int stdio_count, int (*pipes)[2], pid_t* pid, const uv__posix_spawn_fncs_t* posix_spawn_fncs) uv__spawn_and_init_child_posix_spawn() argument
789 uv__spawn_and_init_child_fork(const uv_process_options_t* options, int stdio_count, int (*pipes)[2], int error_fd, pid_t* pid) uv__spawn_and_init_child_fork() argument
830 uv__spawn_and_init_child( uv_loop_t* loop, const uv_process_options_t* options, int stdio_count, int (*pipes)[2], pid_t* pid) uv__spawn_and_init_child() argument
[all...]
/third_party/ltp/testcases/kernel/syscalls/vmsplice/
H A 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[ in setup()
[all...]
H A 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()
H A Dvmsplice03.c24 int pipes[2]; in vmsplice_test() local
29 SAFE_PIPE(pipes); in vmsplice_test()
30 SAFE_WRITE(SAFE_WRITE_ALL, 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()
H A 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/libuv/src/unix/
H A Dprocess.c279 int (*pipes)[2], in uv__process_child_init()
315 use_fd = pipes[fd][1]; in uv__process_child_init()
319 pipes[fd][1] = fcntl(use_fd, F_DUPFD_CLOEXEC, stdio_count); in uv__process_child_init()
321 pipes[fd][1] = fcntl(use_fd, F_DUPFD, stdio_count); in uv__process_child_init()
323 if (pipes[fd][1] == -1) in uv__process_child_init()
326 n = uv__cloexec(pipes[fd][1], 1); in uv__process_child_init()
334 use_fd = pipes[fd][1]; in uv__process_child_init()
536 int (*pipes)[2]) { in uv__spawn_set_posix_spawn_file_actions()
560 /* Do not return ENOSYS after this point, as we may mutate pipes. */ in uv__spawn_set_posix_spawn_file_actions()
567 use_fd = pipes[f in uv__spawn_set_posix_spawn_file_actions()
277 uv__process_child_init(const uv_process_options_t* options, int stdio_count, int (*pipes)[2], int error_fd) uv__process_child_init() argument
531 uv__spawn_set_posix_spawn_file_actions( posix_spawn_file_actions_t* actions, const uv__posix_spawn_fncs_t* posix_spawn_fncs, const uv_process_options_t* options, int stdio_count, int (*pipes)[2]) uv__spawn_set_posix_spawn_file_actions() argument
768 uv__spawn_and_init_child_posix_spawn( const uv_process_options_t* options, int stdio_count, int (*pipes)[2], pid_t* pid, const uv__posix_spawn_fncs_t* posix_spawn_fncs) uv__spawn_and_init_child_posix_spawn() argument
809 uv__spawn_and_init_child_fork(const uv_process_options_t* options, int stdio_count, int (*pipes)[2], int error_fd, pid_t* pid) uv__spawn_and_init_child_fork() argument
850 uv__spawn_and_init_child( uv_loop_t* loop, const uv_process_options_t* options, int stdio_count, int (*pipes)[2], pid_t* pid) uv__spawn_and_init_child() argument
[all...]
/third_party/toybox/lib/
H A Dxwrap.c223 // pipes[2]: Filehandle to move to stdin/stdout of new process.
227 pid_t xpopen_both(char **argv, int *pipes) in xpopen_both() argument
231 // Make the pipes? in xpopen_both()
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[ in xpopen_both()
322 xpclose_both(pid_t pid, int *pipes) xpclose_both() argument
335 int pipes[2], pid; xpopen() local
[all...]
/third_party/mesa3d/src/gallium/drivers/r300/
H A Dr300_texture_desc.c332 * With 2 pipes and an image of size 8xY, where Y >= 1, in r300_setup_hyperz_properties()
340 * With 4 pipes and an image of size 8xY, where Y >= 4, in r300_setup_hyperz_properties()
355 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 in r300_setup_hyperz_properties()
419 unsigned pipes, stride, cmask_num_dw, cmask_max_size; r300_setup_cmask_properties() local
[all...]
/third_party/node/test/async-hooks/
H A 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];
H A Dtest-pipewrap.js1 // NOTE: this also covers process wrap as one is created along with the pipes
28 const pipes = hooks.activitiesOfTypes('PIPEWRAP');
30 assert.strictEqual(pipes.length, 3);
33 const pipe1 = pipes[0];
34 const pipe2 = pipes[1];
35 const pipe3 = pipes[2];
/third_party/ltp/testcases/kernel/syscalls/fanotify/
H A Dfanotify14.c23 * The pipes test cases are regression tests for commit:
46 static int pipes[2] = {-1, -1}; variable
229 .pfd = pipes,
237 .pfd = pipes,
329 /* Create anonymous pipes to place marks on */ in do_setup()
330 SAFE_PIPE2(pipes, O_CLOEXEC); in do_setup()
337 if (pipes[0] != -1) in do_cleanup()
338 SAFE_CLOSE(pipes[0]); in do_cleanup()
339 if (pipes[1] != -1) in do_cleanup()
340 SAFE_CLOSE(pipes[ in do_cleanup()
[all...]
/third_party/toybox/toys/other/
H A 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/node/deps/openssl/openssl/ssl/record/
H A Dssl3_buffer.c168 size_t pipes; in ssl3_release_write_buffer() local
170 pipes = s->rlayer.numwpipes; in ssl3_release_write_buffer()
171 while (pipes > 0) { in ssl3_release_write_buffer()
172 wb = &RECORD_LAYER_get_wbuf(&s->rlayer)[pipes - 1]; in ssl3_release_write_buffer()
179 pipes--; in ssl3_release_write_buffer()
/third_party/openssl/ssl/record/
H A Dssl3_buffer.c168 size_t pipes; in ssl3_release_write_buffer() local
170 pipes = s->rlayer.numwpipes; in ssl3_release_write_buffer()
171 while (pipes > 0) { in ssl3_release_write_buffer()
172 wb = &RECORD_LAYER_get_wbuf(&s->rlayer)[pipes - 1]; in ssl3_release_write_buffer()
179 pipes--; in ssl3_release_write_buffer()
/third_party/node/tools/v8/
H A Dnode_common.py10 import pipes namespace
32 pipes.quote(DEPOT_TOOLS_URL),
33 pipes.quote(depot_tools)), shell=True)
/third_party/skia/third_party/externals/tint/src/utils/io/
H A Dcommand_posix.cc77 int pipes[2] = {}; in Pipe() local
78 if (pipe(pipes) == 0) { in Pipe()
79 read = File(pipes[0]); in Pipe()
80 write = File(pipes[1]); in Pipe()
156 output.err = "Command::Exec(): Failed to create pipes"; in Exec()
164 // The child process is responsible for hooking up the pipes to in Exec()
181 // Close the stdout and stderr writer pipes. in Exec()
239 // Redirect the stdin, stdout, stderr pipes for the execv process in Exec()
243 fprintf(stderr, "Command::Exec(): Failed to redirect pipes"); in Exec()
247 // Close the pipes, onc in Exec()
[all...]
/third_party/node/lib/internal/streams/
H A Dreadable.js184 this.pipes = [];
360 // when we have multiple pipes.
713 if (state.pipes.length === 1) {
722 state.pipes.push(dest);
723 debug('pipe count=%d opts=%j', state.pipes.length, pipeOpts);
786 if (state.pipes.length === 1 && state.pipes[0] === dest) {
790 } else if (state.pipes.length > 1 && state.pipes.includes(dest)) {
897 if (state.pipes
[all...]
/third_party/ltp/testcases/kernel/syscalls/pipe/
H A Dpipe05.c54 intptr_t pipes; variable
85 TEST(pipe((int *)pipes)); in main()
/third_party/mesa3d/src/amd/common/
H A Dac_surface_test_common.h160 int pipes; member
174 /* Just test a bunch of different numbers. (packers, pipes) */
202 S_0098F8_NUM_PIPES(testcase->pipes) | in get_radeon_info()
213 S_0098F8_NUM_PIPES(testcase->pipes) | in get_radeon_info()
/third_party/libdrm/tests/modetest/
H A Dmodetest.c1501 struct pipe_arg *pipes; in pipe_find_preferred() local
1517 pipes = calloc(connected, sizeof(struct pipe_arg)); in pipe_find_preferred()
1518 if (!pipes) in pipe_find_preferred()
1526 if (pipe_attempt_connector(dev, con, &pipes[attempted]) < 0) { in pipe_find_preferred()
1533 *out_pipes = pipes; in pipe_find_preferred()
1555 static void set_mode(struct device *dev, struct pipe_arg *pipes, unsigned int count) in set_mode() argument
1562 struct pipe_arg *pipe = &pipes[i]; in set_mode()
1580 pipes = pipe_args; in set_mode()
1585 struct pipe_arg *pipe = &pipes[i]; in set_mode()
1605 if (bo_fb_create(dev->fd, pipes[ in set_mode()
1667 atomic_clear_mode(struct device *dev, struct pipe_arg *pipes, unsigned int count) atomic_clear_mode() argument
1704 set_cursors(struct device *dev, struct pipe_arg *pipes, unsigned int count) set_cursors() argument
1757 test_page_flip(struct device *dev, struct pipe_arg *pipes, unsigned int count) test_page_flip() argument
[all...]
/third_party/mesa3d/src/amd/addrlib/src/r800/
H A Degbaddrlib.cpp771 UINT_32 pipes, ///< [in] pipes in HwlReduceBankWidthHeight()
812 (tileSize * pipes * pTileInfo->bankWidth) in HwlReduceBankWidthHeight()
892 UINT_32 pipes = HwlGetPipes(pTileInfo); in ComputeSurfaceAlignmentsMacroTiled() local
918 (tileSize * pipes * pTileInfo->bankWidth) in ComputeSurfaceAlignmentsMacroTiled()
928 pipes, in ComputeSurfaceAlignmentsMacroTiled()
934 macroTileWidth = MicroTileWidth * pTileInfo->bankWidth * pipes * in ComputeSurfaceAlignmentsMacroTiled()
955 pipes * pTileInfo->bankWidth * pTileInfo->banks * pTileInfo->bankHeight * tileSize; in ComputeSurfaceAlignmentsMacroTiled()
2351 UINT_32 pipes = HwlGetPipes(pTileInfo);
2362 (((addrBits / groupBits / pipes)
765 HwlReduceBankWidthHeight( UINT_32 tileSize, UINT_32 bpp, ADDR_SURFACE_FLAGS flags, UINT_32 numSamples, UINT_32 bankHeightAlign, UINT_32 pipes, ADDR_TILEINFO* pTileInfo ) const HwlReduceBankWidthHeight() argument
[all...]

Completed in 14 milliseconds

12