| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | wakeup_fd_cv.cc | 63 fd_info->read_fd = GRPC_IDX_TO_FD(idx); in cv_fd_init()
72 g_cvfds.cvfds[GRPC_FD_TO_IDX(fd_info->read_fd)].is_set = 1; in cv_fd_wakeup()
73 cvn = g_cvfds.cvfds[GRPC_FD_TO_IDX(fd_info->read_fd)].cvs; in cv_fd_wakeup()
84 g_cvfds.cvfds[GRPC_FD_TO_IDX(fd_info->read_fd)].is_set = 0; in cv_fd_consume()
90 if (fd_info->read_fd == 0) { in cv_fd_destroy()
95 GPR_ASSERT(!g_cvfds.cvfds[GRPC_FD_TO_IDX(fd_info->read_fd)].cvs); in cv_fd_destroy()
96 g_cvfds.cvfds[GRPC_FD_TO_IDX(fd_info->read_fd)].next_free = g_cvfds.free_fds; in cv_fd_destroy()
97 g_cvfds.free_fds = &g_cvfds.cvfds[GRPC_FD_TO_IDX(fd_info->read_fd)]; in cv_fd_destroy()
|
| D | wakeup_fd_eventfd.cc | 39 fd_info->read_fd = efd; in eventfd_create()
48 err = eventfd_read(fd_info->read_fd, &value); in eventfd_consume()
60 err = eventfd_write(fd_info->read_fd, 1); in eventfd_wakeup()
69 if (fd_info->read_fd != 0) close(fd_info->read_fd); in eventfd_destroy()
|
| D | wakeup_fd_pipe.cc | 48 fd_info->read_fd = pipefd[0]; in pipe_init()
58 r = read(fd_info->read_fd, buf, sizeof(buf)); in pipe_consume()
80 if (fd_info->read_fd != 0) close(fd_info->read_fd); in pipe_destroy()
86 fd.read_fd = fd.write_fd = -1; in pipe_check_availability()
|
| D | wakeup_fd_posix.h | 77 int read_fd; member
84 #define GRPC_WAKEUP_FD_GET_READ_FD(fd_info) ((fd_info)->read_fd)
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | wakeup_fd_cv_test.cc | 110 GPR_ASSERT(cvfd1.read_fd < 0); in test_poll_cv_trigger()
111 GPR_ASSERT(cvfd2.read_fd < 0); in test_poll_cv_trigger()
112 GPR_ASSERT(cvfd3.read_fd < 0); in test_poll_cv_trigger()
113 GPR_ASSERT(cvfd1.read_fd != cvfd2.read_fd); in test_poll_cv_trigger()
114 GPR_ASSERT(cvfd2.read_fd != cvfd3.read_fd); in test_poll_cv_trigger()
115 GPR_ASSERT(cvfd1.read_fd != cvfd3.read_fd); in test_poll_cv_trigger()
117 pfds[0].fd = cvfd1.read_fd; in test_poll_cv_trigger()
118 pfds[1].fd = cvfd2.read_fd; in test_poll_cv_trigger()
121 pfds[4].fd = cvfd3.read_fd; in test_poll_cv_trigger()
|
| D | ev_epollsig_linux_test.cc | 269 shared.wakeup_desc = grpc_fd_create(fd.read_fd, "wakeup", false); in test_threading()
284 fd.read_fd = 0; in test_threading()
|
| /external/ltp/testcases/kernel/sched/tool/ |
| D | time-schedule.c | 72 static void run_yielder(int use_threads, int read_fd);
75 static void run_low_priority(unsigned int num, int read_fd);
94 int read_fd = -1; in main() local
118 read_fd = fds[0]; in main()
154 run_low_priority(num_low_priority, read_fd); in main()
196 read(read_fd, &ch, 1); in main()
209 run_low_priority(num_low_priority, read_fd); in main()
211 run_yielder(use_threads, read_fd); in main()
227 read(read_fd, &ch, 1); in main()
308 static void run_yielder(int use_threads, int read_fd) in run_yielder() argument
[all …]
|
| /external/grpc-grpc/test/core/network_benchmarks/ |
| D | low_level_ping_pong.cc | 49 int read_fd; member
94 return read_bytes(args->fds.read_fd, buf, args->msg_size, 0); in blocking_read_bytes()
98 return read_bytes(args->fds.read_fd, buf, args->msg_size, 1); in spin_read_bytes()
136 return poll_read_bytes(args->fds.read_fd, buf, args->msg_size, 0); in poll_read_bytes_blocking()
140 return poll_read_bytes(args->fds.read_fd, buf, args->msg_size, 1); in poll_read_bytes_spin()
162 GPR_ASSERT(ev.data.fd == args->fds.read_fd); in epoll_read_bytes()
166 read(args->fds.read_fd, buf + bytes_read, read_size - bytes_read); in epoll_read_bytes()
220 grpc_set_socket_nonblocking(args->fds.read_fd, 1))) { in set_socket_nonblocking()
247 ev.data.fd = args->fds.read_fd; in epoll_setup()
248 if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, args->fds.read_fd, &ev) < 0) { in epoll_setup()
[all …]
|
| /external/ltp/testcases/kernel/ipc/pipeio/ |
| D | pipeio.c | 122 static int read_fd; variable
476 read_fd = fds[0]; in setup()
523 close(read_fd); in do_child()
626 read_fd = SAFE_OPEN(cleanup, pname, O_RDONLY); in do_parent()
627 if (ndelay && fcntl(read_fd, F_SETFL, O_NONBLOCK) == -1) { in do_parent()
665 nb = lio_read_buffer(read_fd, iotype, readbuf, size, in do_parent()
714 SAFE_CLOSE(cleanup, read_fd); in do_parent()
|
| /external/python/cpython3/Lib/test/ |
| D | test_thread.py | 227 self.read_fd, self.write_fd = os.pipe()
242 os.close(self.read_fd)
253 self.assertEqual(os.read(self.read_fd, 2), b"OK",
259 os.close(self.read_fd)
|
| /external/python/cpython2/Lib/test/ |
| D | test_thread.py | 230 self.read_fd, self.write_fd = os.pipe()
244 os.close(self.read_fd)
259 self.assertEqual(os.read(self.read_fd, 2), "OK",
265 os.close(self.read_fd)
|
| /external/elfutils/src/ |
| D | strings.c | 52 static int read_fd (int fd, const char *fname, off_t fdlen);
174 result = read_fd (STDIN_FILENO, in main()
202 result |= read_fd (fd, fname, fdlen); in main()
688 read_fd (int fd, const char *fname, off_t fdlen) in read_fd() function
705 return read_fd (fd, fname, fdlen); in read_elf()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_pollset.cc | 144 grpc_fd* fd = grpc_fd_create(wakeup_fd.read_fd, "xxx", false); in BM_PollAddFd()
225 grpc_fd* wakeup = grpc_fd_create(wakeup_fd.read_fd, "wakeup_read", false); in BM_SingleThreadPollOneFd()
246 wakeup_fd.read_fd = 0; in BM_SingleThreadPollOneFd()
|
| /external/linux-kselftest/tools/testing/selftests/powerpc/pmu/ |
| D | lib.c | 38 FAIL_IF(read(read_pipe.read_fd, &c, 1) != 1); in sync_with_child()
49 FAIL_IF(read(read_pipe.read_fd, &c, 1) != 1); in wait_for_parent()
|
| D | lib.h | 16 int read_fd; member
|
| /external/swiftshader/third_party/llvm-7.0/llvm/utils/unittest/googletest/src/ |
| D | gtest-death-test.cc | 398 int read_fd() const { return read_fd_; } in read_fd() function in testing::internal::DeathTestImpl
445 bytes_read = posix::Read(read_fd(), &flag, 1); in ReadAndInterpretStatusByte()
462 FailFromInternalError(read_fd()); // Does not return. in ReadAndInterpretStatusByte()
473 GTEST_DEATH_TEST_CHECK_SYSCALL_(posix::Close(read_fd())); in ReadAndInterpretStatusByte()
|
| /external/libaom/libaom/third_party/googletest/src/googletest/src/ |
| D | gtest-death-test.cc | 398 int read_fd() const { return read_fd_; } in read_fd() function in testing::internal::DeathTestImpl
445 bytes_read = posix::Read(read_fd(), &flag, 1); in ReadAndInterpretStatusByte()
462 FailFromInternalError(read_fd()); // Does not return. in ReadAndInterpretStatusByte()
473 GTEST_DEATH_TEST_CHECK_SYSCALL_(posix::Close(read_fd())); in ReadAndInterpretStatusByte()
|
| /external/mesa3d/src/gtest/src/ |
| D | gtest-death-test.cc | 398 int read_fd() const { return read_fd_; } in read_fd() function in testing::internal::DeathTestImpl
445 bytes_read = posix::Read(read_fd(), &flag, 1); in ReadAndInterpretStatusByte()
462 FailFromInternalError(read_fd()); // Does not return. in ReadAndInterpretStatusByte()
473 GTEST_DEATH_TEST_CHECK_SYSCALL_(posix::Close(read_fd())); in ReadAndInterpretStatusByte()
|
| /external/llvm/utils/unittest/googletest/src/ |
| D | gtest-death-test.cc | 350 int read_fd() const { return read_fd_; } in read_fd() function in testing::internal::DeathTestImpl
397 bytes_read = posix::Read(read_fd(), &flag, 1); in ReadAndInterpretStatusByte()
414 FailFromInternalError(read_fd()); // Does not return. in ReadAndInterpretStatusByte()
425 GTEST_DEATH_TEST_CHECK_SYSCALL_(posix::Close(read_fd())); in ReadAndInterpretStatusByte()
|
| /external/swiftshader/third_party/LLVM/utils/unittest/googletest/ |
| D | gtest-death-test.cc | 347 int read_fd() const { return read_fd_; } in read_fd() function in testing::internal::DeathTestImpl
394 bytes_read = posix::Read(read_fd(), &flag, 1); in ReadAndInterpretStatusByte()
411 FailFromInternalError(read_fd()); // Does not return. in ReadAndInterpretStatusByte()
422 GTEST_DEATH_TEST_CHECK_SYSCALL_(posix::Close(read_fd())); in ReadAndInterpretStatusByte()
|
| /external/google-breakpad/src/testing/gtest/src/ |
| D | gtest-death-test.cc | 385 int read_fd() const { return read_fd_; } in read_fd() function in testing::internal::DeathTestImpl
432 bytes_read = posix::Read(read_fd(), &flag, 1); in ReadAndInterpretStatusByte()
449 FailFromInternalError(read_fd()); // Does not return. in ReadAndInterpretStatusByte()
460 GTEST_DEATH_TEST_CHECK_SYSCALL_(posix::Close(read_fd())); in ReadAndInterpretStatusByte()
|
| /external/android-clat/ |
| D | clatd.c | 396 void read_packet(int read_fd, int write_fd, int to_ipv6) { in read_packet() argument
400 readlen = read(read_fd, buf, PACKETLEN); in read_packet()
|
| D | clatd_test.cpp | 446 int read_fd, write_fd; in do_translate_packet() local
452 read_fd = fds[1]; in do_translate_packet()
457 read_fd = fds[0]; in do_translate_packet()
476 int len = readv(read_fd, iov, 2); in do_translate_packet()
488 *outlen = read(read_fd, out, *outlen); in do_translate_packet()
|
| /external/libcxx/src/filesystem/ |
| D | operations.cpp | 642 bool copy_file_impl_sendfile(FileDescriptor& read_fd, FileDescriptor& write_fd, in copy_file_impl_sendfile() argument
645 size_t count = read_fd.get_stat().st_size; in copy_file_impl_sendfile()
648 if ((res = ::sendfile(write_fd.fd, read_fd.fd, nullptr, count)) == -1) { in copy_file_impl_sendfile()
660 bool copy_file_impl_copyfile(FileDescriptor& read_fd, FileDescriptor& write_fd,
673 if (fcopyfile(read_fd.fd, write_fd.fd, cfs.state, COPYFILE_DATA) < 0) {
685 __attribute__((unused)) bool copy_file_impl_default(FileDescriptor& read_fd, in copy_file_impl_default() argument
689 in.__open(read_fd.fd, ios::binary); in copy_file_impl_default()
|
| /external/libvpx/libvpx/third_party/googletest/src/src/ |
| D | gtest-death-test.cc | 414 int read_fd() const { return read_fd_; } in read_fd() function in testing::internal::DeathTestImpl
461 bytes_read = posix::Read(read_fd(), &flag, 1); in ReadAndInterpretStatusByte()
478 FailFromInternalError(read_fd()); // Does not return. in ReadAndInterpretStatusByte()
489 GTEST_DEATH_TEST_CHECK_SYSCALL_(posix::Close(read_fd())); in ReadAndInterpretStatusByte()
|