commit ad162ba5a9f91481b71f233d1f4f8c15b01de644
author Sree Kuchibhotla <sreek@google.com> Mon Jun 06 16:23:37 2016 -0700
committer Sree Kuchibhotla <sreek@google.com> Mon Jun 06 16:23:37 2016 -0700
tree d73c09ef4718d3a3e28f245dddfc172ead333db1
parent e5012bac7a57df6b1993a1eaa9b8b3c4d7671975

Core review comments and remove 'kicked_specifically' field as its not
needed

src/core/lib/iomgr/ev_epoll_linux.c

diff --git a/src/core/lib/iomgr/ev_epoll_linux.c b/src/core/lib/iomgr/ev_epoll_linux.c
index f7ac4ae..d5aac96 100644
--- a/src/core/lib/iomgr/ev_epoll_linux.c
+++ b/src/core/lib/iomgr/ev_epoll_linux.c
@@ -145,7 +145,6 @@
  * Pollset Declarations
  */
 struct grpc_pollset_worker {
-  int kicked_specifically;
   pthread_t pt_id; /* Thread id of this worker */
   struct grpc_pollset_worker *next;
   struct grpc_pollset_worker *prev;
@@ -235,18 +234,16 @@
   size_t i;
 
   for (i = 0; i < pi->fd_cnt; i++) {
-    if (remove_fd_refs) {
-      GRPC_FD_UNREF(pi->fds[i], "polling_island");
-    }
-
     err = epoll_ctl(pi->epoll_fd, EPOLL_CTL_DEL, pi->fds[i]->fd, NULL);
     if (err < 0 && errno != ENOENT) {
-      gpr_log(GPR_ERROR,
-              "epoll_ctl delete for fds[i]: %d failed with error: %s", i,
-              pi->fds[i]->fd, strerror(errno));
       /* TODO: sreek - We need a better way to bubble up this error instead of
-       * just logging a message */
-      continue;
+      * just logging a message */
+      gpr_log(GPR_ERROR, "epoll_ctl deleting fds[%d]: %d failed with error: %s",
+              i, pi->fds[i]->fd, strerror(errno));
+    }
+
+    if (remove_fd_refs) {
+      GRPC_FD_UNREF(pi->fds[i], "polling_island");
     }
   }
 
@@ -264,7 +261,7 @@
   if (!is_fd_closed) {
     err = epoll_ctl(pi->epoll_fd, EPOLL_CTL_DEL, fd->fd, NULL);
     if (err < 0 && errno != ENOENT) {
-      gpr_log(GPR_ERROR, "epoll_ctl delete for fd: %d failed with error; %s",
+      gpr_log(GPR_ERROR, "epoll_ctl deleting fd: %d failed with error; %s",
               fd->fd, strerror(errno));
     }
   }
@@ -867,7 +864,6 @@
       GPR_TIMER_END("pollset_kick.broadcast", 0);
     } else {
       GPR_TIMER_MARK("kicked_specifically", 0);
-      worker->kicked_specifically = true;
       pthread_kill(worker->pt_id, SIGUSR1);
     }
   } else {
@@ -1100,7 +1096,6 @@
 
   grpc_pollset_worker worker;
   worker.next = worker.prev = NULL;
-  worker.kicked_specifically = 0;
   worker.pt_id = pthread_self();
 
   *worker_hdl = &worker;