diff --git a/python_apps/media-monitor2/media/monitor/eventcontractor.py b/python_apps/media-monitor2/media/monitor/eventcontractor.py index 0ac0e3278..cbc1f5c90 100644 --- a/python_apps/media-monitor2/media/monitor/eventcontractor.py +++ b/python_apps/media-monitor2/media/monitor/eventcontractor.py @@ -46,7 +46,6 @@ class EventContractor(Loggable): self.store[ evt.path ] = evt return True # We actually added something, hence we return true. - # events are unregistered automatically no need to screw around with them def __unregister(self, evt): try: del self.store[evt.path] except Exception as e: self.unexpected_exception(e) diff --git a/python_apps/media-monitor2/media/monitor/watchersyncer.py b/python_apps/media-monitor2/media/monitor/watchersyncer.py index faea2600d..c400ad6d5 100644 --- a/python_apps/media-monitor2/media/monitor/watchersyncer.py +++ b/python_apps/media-monitor2/media/monitor/watchersyncer.py @@ -2,7 +2,6 @@ import threading import time import copy -import traceback from media.monitor.handler import ReportHandler from media.monitor.log import Loggable @@ -47,9 +46,7 @@ class RequestSync(threading.Thread,Loggable): except BadSongFile as e: self.logger.info("This should never occur anymore!!!") self.logger.info("Bad song file: '%s'" % e.path) - except Exception as e: - self.logger.info("An evil exception occured") - self.logger.error( traceback.format_exc() ) + except Exception as e: self.unexpected_exception( e ) def make_req(): self.apiclient.send_media_monitor_requests( packed_requests ) for try_index in range(0,self.retries): @@ -102,16 +99,14 @@ class TimeoutWatcher(threading.Thread,Loggable): class WatchSyncer(ReportHandler,Loggable): def __init__(self, signal, chunking_number = 100, timeout=15): - self.timeout = float(timeout) - self.chunking_number = int(chunking_number) - self.__reset_queue() - # Even though we are not blocking on the http requests, we are still - # trying to send the http requests in order - self.__requests = [] - self.request_running = False - # we don't actually use this "private" instance variable anywhere + self.timeout = float(timeout) + self.chunking_number = int(chunking_number) + self.request_running = False self.__current_thread = None - self.contractor = EventContractor() + self.__requests = [] + self.contractor = EventContractor() + self.__reset_queue() + tc = TimeoutWatcher(self, self.timeout) tc.daemon = True tc.start()