diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-03-17 08:33:19 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2017-03-17 08:33:19 -0700 |
| commit | 185f6c9e047d67ffa8cc4cc9fc1844456e92edfe (patch) | |
| tree | 9d613449d113e16a052ed6e7c60fd57225422aca /src/core/lib/iomgr/ev_epoll_linux.c | |
| parent | 7b2dd93362099eef75b49fe33b93692bb148b93f (diff) | |
Fix rounding, reduce contention on global shared state
Diffstat (limited to 'src/core/lib/iomgr/ev_epoll_linux.c')
| -rw-r--r-- | src/core/lib/iomgr/ev_epoll_linux.c | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/core/lib/iomgr/ev_epoll_linux.c b/src/core/lib/iomgr/ev_epoll_linux.c index 11208b9ad1..400d4057a7 100644 --- a/src/core/lib/iomgr/ev_epoll_linux.c +++ b/src/core/lib/iomgr/ev_epoll_linux.c @@ -56,6 +56,7 @@ #include "src/core/lib/iomgr/ev_posix.h" #include "src/core/lib/iomgr/iomgr_internal.h" +#include "src/core/lib/iomgr/timer.h" #include "src/core/lib/iomgr/wakeup_fd_posix.h" #include "src/core/lib/iomgr/workqueue.h" #include "src/core/lib/profiling/timers.h" @@ -1669,6 +1670,7 @@ static void pollset_work_and_unlock(grpc_exec_ctx *exec_ctx, for (int i = 0; i < ep_rv; ++i) { void *data_ptr = ep_ev[i].data.ptr; if (data_ptr == &global_wakeup_fd) { + grpc_timer_consume_kick(); append_error(error, grpc_wakeup_fd_consume_wakeup(&global_wakeup_fd), err_desc); } else if (data_ptr == &pi->workqueue_wakeup_fd) { |