diff options
author | 2017-06-09 11:13:56 -0700 | |
---|---|---|
committer | 2017-06-09 11:13:56 -0700 | |
commit | ca4fc667ad3a72b6c531713ec55d6573efd34f85 (patch) | |
tree | b82734df37f3cfeaab2184f0bfba5e968e5f4328 /src | |
parent | b19c58acb33928d2abfff4a97e6c13641f762889 (diff) |
Add symbolic constant
Diffstat (limited to 'src')
-rw-r--r-- | src/core/lib/iomgr/ev_epollex_linux.c | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/core/lib/iomgr/ev_epollex_linux.c b/src/core/lib/iomgr/ev_epollex_linux.c index 918080c6f1..a56b22f52e 100644 --- a/src/core/lib/iomgr/ev_epollex_linux.c +++ b/src/core/lib/iomgr/ev_epollex_linux.c @@ -170,6 +170,7 @@ struct grpc_pollset_worker { }; #define MAX_EPOLL_EVENTS 100 +#define MAX_EPOLL_EVENTS_HANDLED_EACH_POLL_CALL 5 struct grpc_pollset { pollable pollable; @@ -710,8 +711,9 @@ static grpc_error *pollset_process_events(grpc_exec_ctx *exec_ctx, grpc_pollset *pollset, bool drain) { static const char *err_desc = "pollset_process_events"; grpc_error *error = GRPC_ERROR_NONE; - for (int i = 0; - (drain || i < 5) && pollset->event_cursor != pollset->event_count; i++) { + for (int i = 0; (drain || i < MAX_EPOLL_EVENTS_HANDLED_EACH_POLL_CALL) && + pollset->event_cursor != pollset->event_count; + i++) { int n = pollset->event_cursor++; struct epoll_event *ev = &pollset->events[n]; void *data_ptr = ev->data.ptr; |