Add tornado ioloop support

python2/examples/transient_file_tornado.py

@@ -0,0 +1,19 @@
+import pyinotify
+from tornado.ioloop import IOLoop
+
+wm = pyinotify.WatchManager() # Watch Manager
+mask = pyinotify.IN_MODIFY
+
+class EventHandler(pyinotify.ProcessEvent):
+    def process_IN_MODIFY(self, event):
+        # We have explicitely registered for this kind of event.
+        print '\t', event.pathname, ' -> written'
+    def process_default(self, event):
+        print event
+
+ioloop = IOLoop.instance()
+notifier = pyinotify.TornadoAsyncNotifier(wm, ioloop)
+#daemon.pids['nginx']
+wdd = wm.watch_transient_file('/tmp/test_file', pyinotify.IN_MODIFY, EventHandler)
+
+ioloop.start()

python2/pyinotify.py

@@ -1539,6 +1539,25 @@ def handle_read(self):
         self.read_events()
         self.process_events()
 
+class TornadoAsyncNotifier(Notifier):
+    """
+    Tornado ioloop adapter
+    """
+    def __init__(self, watch_manager, ioloop, default_proc_fun=None, read_freq=0,
+                 threshold=0, timeout=None, channel_map=None):
+        Notifier.__init__(self, watch_manager, default_proc_fun, read_freq,
+                          threshold, timeout)
+        ioloop.add_handler(os.dup(self._fd), self.handle_read, ioloop.READ)
+    def handle_read(self,*args,**kwargs):
+        """
+        When asyncore tells us we can read from the fd, we proceed processing
+        events. This method can be overridden for handling a notification
+        differently.
+
+        """
+        self.read_events()
+        self.process_events()
+
 
 class Watch:
     """