github/supysonic
1
0
Fork 0
mirror of https://github.com/spl0k/supysonic.git synced 2024-11-09 19:52:16 +00:00
Code Issues Releases Wiki Activity

Prevent put() from blocking when the scanner is running

Browse Source
This commit is contained in:
spl0k 2014-07-27 13:20:51 +02:00
parent 132d7b0c8b
commit 01c80fed16
1 changed files with 23 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

35
bin/supysonic-watcher
View File

@ -80,20 +80,19 @@ class ScannerProcessingQueue(Thread):
if not self.__queue:
continue
self.__logger.debug("Instantiating scanner")
scanner = Scanner(db.session)
self.__logger.debug("Instantiating scanner")
scanner = Scanner(db.session)
while self.__queue:
path = sorted(self.__queue.iteritems(), key = lambda i: i[1])[0][0]
self.__logger.info("Scanning: '%s'", path)
scanner.scan_file(path)
path = self.__next_item()
while path:
self.__logger.info("Scanning: '%s'", path)
scanner.scan_file(path)
path = self.__next_item()
del self.__queue[path]
db.session.commit()
db.session.remove()
self.__logger.debug("Freeing scanner")
del scanner
db.session.commit()
db.session.remove()
self.__logger.debug("Freeing scanner")
del scanner
def stop(self):
self.__running = False
@ -116,6 +115,18 @@ class ScannerProcessingQueue(Thread):
self.__cond.notify()
self.__timer = None
def __next_item(self):
with self.__cond:
if not self.__queue:
return None
next = sorted(self.__queue.iteritems(), key = lambda i: i[1])[0]
if not self.__running or next[1] + 5 < time.time():
del self.__queue[next[0]]
return next[0]
return None
if __name__ == "__main__":
if not config.check():
sys.exit(1)