Congegni
/
sintonia
7
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

-clean up comments..

This commit is contained in:
martin 2011-07-04 19:01:06 -04:00
parent 0757fda479
commit 275dfd0cd0
2 changed files with 1 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
python_apps/media-monitor/MediaMonitor.py
View File

@ -67,7 +67,6 @@ try:
logger.info("Added watch to %s", storage_directory) logger.info("Added watch to %s", storage_directory)
logger.info("wdd result %s", wdd[storage_directory]) logger.info("wdd result %s", wdd[storage_directory])
#register signal before process forks and exits.
signal.signal(signal.SIGTERM, handleSigTERM) signal.signal(signal.SIGTERM, handleSigTERM)
notifier.loop(callback=pe.notifier_loop_callback) notifier.loop(callback=pe.notifier_loop_callback)

6
python_apps/media-monitor/airtimefilemonitor/airtimeprocessevent.py
View File

@ -205,13 +205,11 @@ class AirtimeProcessEvent(ProcessEvent):
#event.name #event.name
#event.pathname: pathname (str): Concatenation of 'path' and 'name'. #event.pathname: pathname (str): Concatenation of 'path' and 'name'.
def process_IN_CREATE(self, event): def process_IN_CREATE(self, event):
self.logger.debug("PROCESS_IN_CREATE")
self.handle_created_file(event.dir, event.name, event.pathname) self.handle_created_file(event.dir, event.name, event.pathname)
def handle_created_file(self, dir, name, pathname): def handle_created_file(self, dir, name, pathname):
self.logger.debug("PROCESS_IN_CREATE")
self.logger.debug("dir: %s, name: %s, pathname: %s ", dir, name, pathname) self.logger.debug("dir: %s, name: %s, pathname: %s ", dir, name, pathname)
storage_directory = self.config.storage_directory storage_directory = self.config.storage_directory
if not dir: if not dir:
@ -329,12 +327,10 @@ class AirtimeProcessEvent(ProcessEvent):
f.close() f.close()
def notifier_loop_callback(self, notifier): def notifier_loop_callback(self, notifier):
if len(self.file_events) > 0: if len(self.file_events) > 0:
for event in self.file_events: for event in self.file_events:
self.multi_queue.put(event) self.multi_queue.put(event)
self.file_events = [] self.file_events = []
#check for any events recieved from Airtime. #check for any events recieved from Airtime.