Last commit broke kqueue

ask · May 22, 2012 · 60d8ac1 · 60d8ac1
1 parent 2478d6d
commit 60d8ac1
Showing 1 changed file with 12 additions and 11 deletions.
diff --git a/kombu/utils/eventio.py b/kombu/utils/eventio.py
@@ -140,17 +140,18 @@ def unwatch_file(self, fd):
         self._kcontrol([ev], 0)
 
     def _control(self, fd, events, flags):
-        if events:
-            kevents = []
-            if events & WRITE:
-                kevents.append(kevent(fd,
-                               filter=KQ_FILTER_WRITE,
-                               flags=flags))
-                if not kevents or events & READ:
-                    kevents.append(kevent(fd,
-                        filter=KQ_FILTER_READ, flags=flags))
-            control = self._kcontrol
-            [control([e], 0) for e in kevents]
+        if not events:
+            return
+        kevents = []
+        if events & WRITE:
+            kevents.append(kevent(fd,
+                           filter=KQ_FILTER_WRITE,
+                           flags=flags))
+        if not kevents or events & READ:
+            kevents.append(kevent(fd,
+                filter=KQ_FILTER_READ, flags=flags))
+        control = self._kcontrol
+        [control([e], 0) for e in kevents]
 
     def _poll(self, timeout):
         kevents = self._kcontrol(None, 1000, timeout)