Home
last modified time | relevance | path

Searched refs:read_fd (Results 1 – 25 of 41) sorted by relevance

12

/external/grpc-grpc/src/core/lib/iomgr/
Dwakeup_fd_cv.cc63 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()
Dwakeup_fd_eventfd.cc39 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()
Dwakeup_fd_pipe.cc48 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()
Dwakeup_fd_posix.h77 int read_fd; member
84 #define GRPC_WAKEUP_FD_GET_READ_FD(fd_info) ((fd_info)->read_fd)
/external/grpc-grpc/test/core/iomgr/
Dwakeup_fd_cv_test.cc110 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()
Dev_epollsig_linux_test.cc269 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/
Dtime-schedule.c72 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/ltp/testcases/kernel/syscalls/ftruncate/
Dftruncate03.c31 static int sock_fd, read_fd, fd; variable
40 {&read_fd, 4, EINVAL},
69 read_fd = SAFE_OPEN(TESTFILE1, O_RDONLY | O_CREAT, 0644); in setup()
79 if (read_fd > 0) in cleanup()
80 SAFE_CLOSE(read_fd); in cleanup()
/external/grpc-grpc/test/core/network_benchmarks/
Dlow_level_ping_pong.cc49 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/python/cffi/testing/
Dsupport.py49 self.read_fd, self.write_fd = os.pipe()
59 self._value = os.read(self.read_fd, 512)
60 os.close(self.read_fd)
/external/ltp/testcases/kernel/ipc/pipeio/
Dpipeio.c122 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/
Dtest_thread.py223 self.read_fd, self.write_fd = os.pipe()
238 os.close(self.read_fd)
249 self.assertEqual(os.read(self.read_fd, 2), b"OK",
255 os.close(self.read_fd)
/external/python/cpython2/Lib/test/
Dtest_thread.py230 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/
Dstrings.c52 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/linux-kselftest/tools/testing/selftests/powerpc/pmu/
Dlib.c38 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()
Dlib.h16 int read_fd; member
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_pollset.cc144 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/android-clat/
Dclatd_test.cpp445 int read_fd, write_fd; in do_translate_packet() local
451 read_fd = fds[1]; in do_translate_packet()
456 read_fd = fds[0]; in do_translate_packet()
475 int len = readv(read_fd, iov, 2); in do_translate_packet()
487 *outlen = read(read_fd, out, *outlen); in do_translate_packet()
Dclatd.c350 void read_packet(int read_fd, int write_fd, int to_ipv6) { in read_packet() argument
354 readlen = read(read_fd, buf, PACKETLEN); in read_packet()
/external/llvm/utils/unittest/googletest/src/
Dgtest-death-test.cc350 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-7.0/llvm/utils/unittest/googletest/src/
Dgtest-death-test.cc398 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/perfetto/src/profiling/symbolizer/
Dlocal_symbolizer.h58 int read_fd() { return output_pipe_.rd.get(); } in read_fd() function
/external/google-breakpad/src/testing/gtest/src/
Dgtest-death-test.cc385 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/boringssl/src/crypto/fipsmodule/rand/
Durandom_test.cc243 const int read_fd = regs.rdi; in GetTrace() local
244 if (urandom_fd >= 0 && urandom_fd == read_fd) { in GetTrace()
/external/libcxx/src/filesystem/
Doperations.cpp642 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()

12