Congegni
/
libretime
mirror of https://github.com/libretime/libretime.git
7
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

make ManagerTimeout provide the correct AirtimeInstance object.

This commit is contained in:
Rudi Grinberg 2012-11-15 12:11:48 -05:00
parent ab35263869
commit 15f4212360
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
python_apps/media-monitor2/media/monitor/manager.py
View File

@ -1,5 +1,4 @@
import pyinotify import pyinotify
import threading
import time import time
from pydispatch import dispatcher from pydispatch import dispatcher
@ -9,10 +8,11 @@ from media.monitor.log import Loggable
from media.monitor.listeners import StoreWatchListener, OrganizeListener from media.monitor.listeners import StoreWatchListener, OrganizeListener
from media.monitor.handler import ProblemFileHandler from media.monitor.handler import ProblemFileHandler
from media.monitor.organizer import Organizer from media.monitor.organizer import Organizer
from media.saas.thread import InstanceInheritingThread
import media.monitor.pure as mmp import media.monitor.pure as mmp
class ManagerTimeout(threading.Thread,Loggable): class ManagerTimeout(InstanceInheritingThread,Loggable):
""" The purpose of this class is to flush the organize directory """ The purpose of this class is to flush the organize directory
every 3 secnods. This used to be just a work around for cc-4235 every 3 secnods. This used to be just a work around for cc-4235
but recently became a permanent solution because it's "cheap" and but recently became a permanent solution because it's "cheap" and
@ -20,7 +20,7 @@ class ManagerTimeout(threading.Thread,Loggable):
def __init__(self, manager, interval=1.5): def __init__(self, manager, interval=1.5):
# TODO : interval should be read from config and passed here instead # TODO : interval should be read from config and passed here instead
# of just using the hard coded value # of just using the hard coded value
threading.Thread.__init__(self) super(ManagerTimeout, self).__init__()
self.manager = manager self.manager = manager
self.interval = interval self.interval = interval
def run(self): def run(self):