| /third_party/libwebsockets/lib/plat/windows/ |
| D | windows-spawn.c | 121 if (lsp->pipe_fds[n][!!(n == 0)]) { in lws_spawn_piped_destroy()
122 CloseHandle(lsp->pipe_fds[n][n == 0]); in lws_spawn_piped_destroy()
123 lsp->pipe_fds[n][n == 0] = NULL; in lws_spawn_piped_destroy()
268 if (wsi && lsp->pipe_fds[LWS_STDOUT][0] != NULL) { in windows_pipe_poll_hack()
269 if (!PeekNamedPipe(lsp->pipe_fds[LWS_STDOUT][0], &c, 1, &br, in windows_pipe_poll_hack()
274 lsp->pipe_fds[LWS_STDOUT][0] = NULL; in windows_pipe_poll_hack()
286 lsp->pipe_fds[LWS_STDIN][1] = NULL; in windows_pipe_poll_hack()
307 if (wsi1 && lsp->pipe_fds[LWS_STDERR][0]) { in windows_pipe_poll_hack()
308 if (!PeekNamedPipe(lsp->pipe_fds[LWS_STDERR][0], &c, 1, &br, in windows_pipe_poll_hack()
319 lsp->pipe_fds[LWS_STDERR][0] = NULL; in windows_pipe_poll_hack()
[all …]
|
| /third_party/pulseaudio/src/pulsecore/ |
| D | start-child.c | 48 int pipe_fds[2] = { -1, -1 }; in pa_start_child_for_read() local
50 if (pipe(pipe_fds) < 0) { in pa_start_child_for_read()
62 pa_assert_se(pa_close(pipe_fds[1]) == 0); in pa_start_child_for_read()
67 return pipe_fds[0]; in pa_start_child_for_read()
73 pa_assert_se(pa_close(pipe_fds[0]) == 0); in pa_start_child_for_read()
74 pa_assert_se(dup2(pipe_fds[1], STDOUT_FILENO) == STDOUT_FILENO); in pa_start_child_for_read()
76 if (pipe_fds[1] != STDOUT_FILENO) in pa_start_child_for_read()
77 pa_assert_se(pa_close(pipe_fds[1]) == 0); in pa_start_child_for_read()
109 pa_close_pipe(pipe_fds); in pa_start_child_for_read()
|
| /third_party/ltp/testcases/kernel/syscalls/pipe/ |
| D | pipe07.c | 19 static int *opened_fds, *pipe_fds; variable
57 pipe_fds = SAFE_MALLOC(max_fds * sizeof(int)); in setup()
70 pipe_fds[num_pipe_fds++] = fds[0]; in run()
71 pipe_fds[num_pipe_fds++] = fds[1]; in run()
79 SAFE_CLOSE(pipe_fds[i]); in run()
87 if (pipe_fds[i] > 0) in cleanup()
88 SAFE_CLOSE(pipe_fds[i]); in cleanup()
90 if (pipe_fds) in cleanup()
91 free(pipe_fds); in cleanup()
|
| /third_party/ltp/testcases/kernel/syscalls/pwrite/ |
| D | pwrite02.c | 30 static int pipe_fds[2]; variable
40 {buf, sizeof(buf), &pipe_fds[1], 0, ESPIPE},
81 SAFE_PIPE(pipe_fds); in setup()
95 if (pipe_fds[0] > 0) in cleanup()
96 SAFE_CLOSE(pipe_fds[0]); in cleanup()
98 if (pipe_fds[1] > 0) in cleanup()
99 SAFE_CLOSE(pipe_fds[1]); in cleanup()
|
| /third_party/libwebsockets/lib/plat/unix/ |
| D | unix-spawn.c | 129 if (lsp->pipe_fds[n][!!(n == 0)] == 0) in lws_spawn_piped_destroy()
132 if (lsp->pipe_fds[n][!!(n == 0)] >= 0) { in lws_spawn_piped_destroy()
133 close(lsp->pipe_fds[n][!!(n == 0)]); in lws_spawn_piped_destroy()
134 lsp->pipe_fds[n][!!(n == 0)] = LWS_SOCK_INVALID; in lws_spawn_piped_destroy()
358 lsp->pipe_fds[n][0] = -1; in lws_spawn_piped()
359 lsp->pipe_fds[n][1] = -1; in lws_spawn_piped()
365 if (pipe(lsp->pipe_fds[n]) == -1) in lws_spawn_piped()
367 lws_plat_apply_FD_CLOEXEC(lsp->pipe_fds[n][n == 0]); in lws_spawn_piped()
394 lsp->stdwsi[n], n, lsp->pipe_fds[n][n == 0], in lws_spawn_piped()
395 lsp->pipe_fds[n][n != 0]); in lws_spawn_piped()
[all …]
|
| /third_party/ltp/testcases/kernel/syscalls/fcntl/ |
| D | fcntl07.c | 69 static int file_fd, pipe_fds[2], fifo_fd; variable
78 {pipe_fds, "pipe (write end)"},
79 {pipe_fds+1, "pipe (read end)"},
171 SAFE_PIPE(cleanup, pipe_fds); in setup()
181 if (pipe_fds[0] > 0 && close(pipe_fds[0])) in cleanup()
184 if (pipe_fds[1] > 0 && close(pipe_fds[1])) in cleanup()
|
| D | fcntl31.c | 67 static int pipe_fds[2]; variable
108 SAFE_PIPE(cleanup, pipe_fds); in setup()
109 test_fd = pipe_fds[0]; in setup()
294 fd = pipe_fds[1]; in signal_parent()
295 close(pipe_fds[0]); in signal_parent()
365 if (pipe_fds[0] > 0 && close(pipe_fds[0]) == -1) in cleanup()
366 tst_resm(TWARN | TERRNO, "close(%d) failed", pipe_fds[0]); in cleanup()
367 if (pipe_fds[1] > 0 && close(pipe_fds[1]) == -1) in cleanup()
368 tst_resm(TWARN | TERRNO, "close(%d) failed", pipe_fds[1]); in cleanup()
|
| /third_party/libuv/test/ |
| D | test-eintr-handling.c | 42 int pipe_fds[2]; variable
54 nwritten = write(pipe_fds[1], test_buf, sizeof(test_buf)); in thread_main()
76 ASSERT(0 == pipe(pipe_fds)); in TEST_IMPL()
79 nread = uv_fs_read(loop, &read_req, pipe_fds[0], &iov, 1, -1, NULL); in TEST_IMPL()
86 ASSERT(0 == close(pipe_fds[0])); in TEST_IMPL()
87 ASSERT(0 == close(pipe_fds[1])); in TEST_IMPL()
|
| D | test-fs.c | 3523 int pipe_fds[2]; in test_fs_partial() local
3551 ASSERT(0 == pipe(pipe_fds)); in test_fs_partial()
3553 ctx.fd = pipe_fds[doread]; in test_fs_partial()
3563 result = uv_fs_read(loop, &read_req, pipe_fds[0], read_iovs, iovcount, -1, NULL); in test_fs_partial()
3577 result = uv_fs_write(loop, &write_req, pipe_fds[1], iovs, iovcount, -1, NULL); in test_fs_partial()
3588 ASSERT(0 == close(pipe_fds[1])); in test_fs_partial()
3593 result = uv_fs_read(loop, &read_req, pipe_fds[0], iovs, 1, -1, NULL); in test_fs_partial()
3597 ASSERT(0 == close(pipe_fds[0])); in test_fs_partial()
|
| /third_party/musl/libc-test/src/functionalext/supplement/linux/ |
| D | vmsplice.c | 27 int pipe_fds[pipe_size]; in vmsplice_0100() local
28 if (pipe(pipe_fds) != 0) { in vmsplice_0100()
38 size_t result = vmsplice(pipe_fds[1], v, sizeof(v) / sizeof(struct iovec), 0); in vmsplice_0100()
42 close(pipe_fds[1]); in vmsplice_0100()
44 FILE *fp = fdopen(pipe_fds[0], "r"); in vmsplice_0100()
|
| /third_party/python/Lib/test/ |
| D | test_pty.py | 361 pipe_fds = os.pipe()
362 self.fds.extend(pipe_fds)
363 return pipe_fds
|
| /third_party/libwebsockets/lib/core-net/ |
| D | private-lib-core-net.h | 910 lws_filefd_type pipe_fds[3][2]; member
|