| /netbsd-src/external/mit/libuv/dist/test/ |
| H A 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()
|
| H A D | test-fs.c | 3670 int pipe_fds[2]; in test_fs_partial() local
3698 ASSERT(0 == pipe(pipe_fds)); in test_fs_partial()
3700 ctx.fd = pipe_fds[doread]; in test_fs_partial()
3710 result = uv_fs_read(loop, &read_req, pipe_fds[0], read_iovs, iovcount, -1, NULL); in test_fs_partial()
3724 result = uv_fs_write(loop, &write_req, pipe_fds[1], iovs, iovcount, -1, NULL); in test_fs_partial()
3735 ASSERT(0 == close(pipe_fds[1])); in test_fs_partial()
3740 result = uv_fs_read(loop, &read_req, pipe_fds[0], iovs, 1, -1, NULL); in test_fs_partial()
3744 ASSERT(0 == close(pipe_fds[0])); in test_fs_partial()
|
| /netbsd-src/lib/libisns/ |
| H A D | isns_util.c | 54 return (int)write(cfg_p->pipe_fds[1], &cmd_type, 1); in isns_issue_cmd()
69 return (int)isns_file_writev(cfg_p->pipe_fds[1], iov, 2); in isns_issue_cmd_with_data()
97 cfg_p->pipe_fds[0] = -1; in isns_new_config()
98 cfg_p->pipe_fds[1] = -1; in isns_new_config()
144 if (cfg_p->pipe_fds[0] != -1) in isns_destroy_config()
145 close(cfg_p->pipe_fds[0]); in isns_destroy_config()
146 if (cfg_p->pipe_fds[1] != -1) in isns_destroy_config()
147 close(cfg_p->pipe_fds[1]); in isns_destroy_config()
|
| H A D | isns.c | 73 if ((rval = pipe(cfg_p->pipe_fds)) != 0) { in isns_init()
85 rval = isns_change_kevent_list(cfg_p, (uintptr_t)cfg_p->pipe_fds[0], in isns_init()
|
| H A D | isns_config.h | 61 int pipe_fds[2]; member
|
| H A D | isns_thread.c | 137 rbytes = read(cfg_p->pipe_fds[0], &cmd_type, in isns_kevent_pipe()
153 rbytes = read(cfg_p->pipe_fds[0], &trans_id, in isns_kevent_pipe()
|
| /netbsd-src/tests/lib/libc/sys/ |
| H A D | t_posix_fadvise.c | 92 int pipe_fds[2]; in ATF_TC_BODY() local
99 RL(pipe(pipe_fds)); in ATF_TC_BODY()
118 CE(posix_fadvise(pipe_fds[0], 0, 0, POSIX_FADV_NORMAL), ESPIPE); in ATF_TC_BODY()
|
| /netbsd-src/sys/external/bsd/compiler_rt/dist/lib/sanitizer_common/tests/ |
| H A D | sanitizer_linux_test.cc | 260 int pipe_fds[2]; in TEST() local
261 ASSERT_EQ(0, pipe(pipe_fds)); in TEST()
269 /* stdin */ kInvalidFd, /* stdout */ pipe_fds[1]); in TEST()
281 while (ReadFromFile(pipe_fds[0], ptr, 256, &bytes_read)) { in TEST()
291 internal_close(pipe_fds[0]); in TEST()
|
| /netbsd-src/external/mpl/dhcp/bind/dist/lib/isc/unix/ |
| H A D | socket.c | 397 int pipe_fds[2]; member
950 cc = write(mgr->threads[threadid].pipe_fds[1], buf, in select_poke()
982 cc = read(thread->pipe_fds[0], buf, sizeof(buf)); in select_readmsg()
1858 if (thread->maxfd < thread->pipe_fds[0]) { in socketclose()
1859 thread->maxfd = thread->pipe_fds[0]; in socketclose()
3320 if (events[i].ident == (uintptr_t)thread->pipe_fds[0]) { in process_fds()
3352 if (events[i].data.fd == thread->pipe_fds[0]) { in process_fds()
3396 if (events[i].fd == thread->pipe_fds[0]) { in process_fds()
3420 if (i == thread->pipe_fds[0] || i == thread->pipe_fds[1]) { in process_fds()
3505 ctlfd = thread->pipe_fds[0]; in netthread()
[all …]
|
| /netbsd-src/usr.bin/make/ |
| H A D | job.c | 533 int pipe_fds[2]; in JobSigUnlock()
535 if (pipe(pipe_fds) == -1)
540 fd = fcntl(pipe_fds[i], F_DUPFD, minfd); in JobCreatePipe()
542 close(pipe_fds[i]); in JobCreatePipe()
543 pipe_fds[i] = fd; in JobCreatePipe()
547 job->inPipe = pipe_fds[0]; in JobCreatePipe()
548 job->outPipe = pipe_fds[1]; in JobCreatePipe()
539 int pipe_fds[2]; JobCreatePipe() local
|