Home
last modified time | relevance | path

Searched refs:wakeup_fd (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_pollset.cc141 grpc_wakeup_fd wakeup_fd; in BM_PollAddFd() local
143 GRPC_LOG_IF_ERROR("wakeup_fd_init", grpc_wakeup_fd_init(&wakeup_fd))); in BM_PollAddFd()
144 grpc_fd* fd = grpc_fd_create(wakeup_fd.read_fd, "xxx", false); in BM_PollAddFd()
223 grpc_wakeup_fd wakeup_fd; in BM_SingleThreadPollOneFd() local
224 GRPC_ERROR_UNREF(grpc_wakeup_fd_init(&wakeup_fd)); in BM_SingleThreadPollOneFd()
225 grpc_fd* wakeup = grpc_fd_create(wakeup_fd.read_fd, "wakeup_read", false); in BM_SingleThreadPollOneFd()
230 GRPC_ERROR_UNREF(grpc_wakeup_fd_consume_wakeup(&wakeup_fd)); in BM_SingleThreadPollOneFd()
235 GRPC_ERROR_UNREF(grpc_wakeup_fd_wakeup(&wakeup_fd)); in BM_SingleThreadPollOneFd()
239 GRPC_ERROR_UNREF(grpc_wakeup_fd_wakeup(&wakeup_fd)); in BM_SingleThreadPollOneFd()
246 wakeup_fd.read_fd = 0; in BM_SingleThreadPollOneFd()
[all …]
/external/grpc-grpc/test/core/iomgr/
Dev_epollsig_linux_test.cc222 grpc_wakeup_fd* wakeup_fd; member
249 "consume_wakeup", grpc_wakeup_fd_consume_wakeup(shared->wakeup_fd))); in test_threading_wakeup()
252 grpc_wakeup_fd_wakeup(shared->wakeup_fd))); in test_threading_wakeup()
268 shared.wakeup_fd = &fd; in test_threading()
280 grpc_wakeup_fd_wakeup(shared.wakeup_fd))); in test_threading()
Dpollset_set_test.cc99 grpc_wakeup_fd wakeup_fd; member
119 GPR_ASSERT(GRPC_ERROR_NONE == grpc_wakeup_fd_init(&tfds[i].wakeup_fd)); in init_test_fds()
120 tfds[i].fd = grpc_fd_create(GRPC_WAKEUP_FD_GET_READ_FD(&tfds[i].wakeup_fd), in init_test_fds()
142 grpc_wakeup_fd_destroy(&tfds[i].wakeup_fd); in cleanup_test_fds()
148 GPR_ASSERT(GRPC_ERROR_NONE == grpc_wakeup_fd_wakeup(&tfds[i].wakeup_fd)); in make_test_fds_readable()
159 grpc_wakeup_fd_consume_wakeup(&tfds[i].wakeup_fd)); in verify_readable_and_reset()
/external/python/cpython2/Modules/
Dsignalmodule.c89 static sig_atomic_t wakeup_fd = -1; variable
176 if (wakeup_fd != -1) in trip_signal()
177 write(wakeup_fd, "\0", 1); in trip_signal()
422 old_fd = wakeup_fd; in signal_set_wakeup_fd()
423 wakeup_fd = fd; in signal_set_wakeup_fd()
440 int old_fd = wakeup_fd; in PySignal_SetWakeupFd()
443 wakeup_fd = fd; in PySignal_SetWakeupFd()
/external/grpc-grpc/src/core/lib/iomgr/
Dev_poll_posix.cc188 grpc_cached_wakeup_fd* wakeup_fd; member
813 &error, grpc_wakeup_fd_wakeup(&specific_worker->wakeup_fd->fd));
824 grpc_wakeup_fd_wakeup(&specific_worker->wakeup_fd->fd));
832 grpc_wakeup_fd_wakeup(&specific_worker->wakeup_fd->fd));
854 &error, grpc_wakeup_fd_wakeup(&specific_worker->wakeup_fd->fd));
973 worker.wakeup_fd = pollset->local_wakeup_cache;
974 pollset->local_wakeup_cache = worker.wakeup_fd->next;
976 worker.wakeup_fd = static_cast<grpc_cached_wakeup_fd*>(
977 gpr_malloc(sizeof(*worker.wakeup_fd)));
978 error = grpc_wakeup_fd_init(&worker.wakeup_fd->fd);
[all …]
Dev_epollsig_linux.cc389 grpc_wakeup_fd* wakeup_fd, in polling_island_add_wakeup_fd_locked() argument
397 ev.data.ptr = wakeup_fd; in polling_island_add_wakeup_fd_locked()
399 GRPC_WAKEUP_FD_GET_READ_FD(wakeup_fd), &ev); in polling_island_add_wakeup_fd_locked()
404 pi->epoll_fd, GRPC_WAKEUP_FD_GET_READ_FD(wakeup_fd), errno, in polling_island_add_wakeup_fd_locked()
/external/grpc-grpc/doc/
Depoll-polling-engine.md105 …ent implementation (where every thread does a blocking `poll()` on its `wakeup_fd` and the `epoll_…
117 [^3]: The threads first do a blocking` poll()` with `[wakeup_fd, epoll_fd]`. If the `poll()` retur…
119 [^4]: `event_fd` is the linux platform specific implementation of `grpc_wakeup_fd`. A `wakeup_fd` …
/external/python/cpython3/Tools/c-globals/
Dignored-globals.txt134 wakeup_fd # main thread only