Searched refs:g_cvfds (Results 1 – 2 of 2) sorted by relevance
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | wakeup_fd_cv.cc | 40 extern grpc_cv_fd_table g_cvfds;
45 gpr_mu_lock(&g_cvfds.mu); in cv_fd_init()
46 if (!g_cvfds.free_fds) { in cv_fd_init()
47 newsize = GPR_MIN(g_cvfds.size * 2, g_cvfds.size + MAX_TABLE_RESIZE); in cv_fd_init()
48 g_cvfds.cvfds = static_cast<grpc_fd_node*>( in cv_fd_init()
49 gpr_realloc(g_cvfds.cvfds, sizeof(grpc_fd_node) * newsize)); in cv_fd_init()
50 for (i = g_cvfds.size; i < newsize; i++) { in cv_fd_init()
51 g_cvfds.cvfds[i].is_set = 0; in cv_fd_init()
52 g_cvfds.cvfds[i].cvs = nullptr; in cv_fd_init()
53 g_cvfds.cvfds[i].next_free = g_cvfds.free_fds; in cv_fd_init()
[all …]
|
| D | ev_poll_posix.cc | 307 grpc_cv_fd_table g_cvfds; variable
1446 gpr_ref(&g_cvfds.pollcount);
1534 gpr_cv_wait(&args->join, &g_cvfds.mu,
1569 int retval = g_cvfds.poll(result->fds, result->nfds, CV_POLL_PERIOD_MS);
1570 gpr_mu_lock(&g_cvfds.mu);
1590 gpr_cv_wait(&pargs->trigger, &g_cvfds.mu, deadline);
1597 gpr_mu_unlock(&g_cvfds.mu);
1600 if (gpr_unref(&g_cvfds.pollcount)) {
1601 gpr_cv_signal(&g_cvfds.shutdown_cv);
1604 gpr_cv_wait(&pargs->harvest, &g_cvfds.mu,
[all …]
|