github/supysonic
1
0
Fork 0
mirror of https://github.com/spl0k/supysonic.git synced 2024-12-22 17:06:17 +00:00
Code Issues Releases Wiki Activity

Allow merging of events with move operation

Browse Source
This commit is contained in:
spl0k 2014-09-06 19:18:01 +02:00
parent f61a3a7937
commit 756f83f2ab
1 changed files with 21 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
bin/supysonic-watcher
View File

@ -62,19 +62,19 @@ class SupysonicWatcherEventHandler(PatternMatchingEventHandler):
def on_moved(self, event): def on_moved(self, event):
self.__logger.debug("File moved: '%s' -> '%s'", event.src_path, event.dest_path) self.__logger.debug("File moved: '%s' -> '%s'", event.src_path, event.dest_path)
self.__queue.put(event.src_path, OP_MOVE, event.dest_path) self.__queue.put(event.dest_path, OP_MOVE, src_path = event.src_path)
class Event(object): class Event(object):
def __init__(self, path, operation, dst_path = None): def __init__(self, path, operation, **kwargs):
if operation & (OP_SCAN | OP_REMOVE) == (OP_SCAN | OP_REMOVE): if operation & (OP_SCAN | OP_REMOVE) == (OP_SCAN | OP_REMOVE):
raise Exception("Flags SCAN and REMOVE both set") raise Exception("Flags SCAN and REMOVE both set")
self.__path = path self.__path = path
self.__time = time.time() self.__time = time.time()
self.__op = operation self.__op = operation
self.__dst = dst_path self.__src = kwargs.get("src_path")
def set(self, operation, dst_path = None): def set(self, operation, **kwargs):
if operation & (OP_SCAN | OP_REMOVE) == (OP_SCAN | OP_REMOVE): if operation & (OP_SCAN | OP_REMOVE) == (OP_SCAN | OP_REMOVE):
raise Exception("Flags SCAN and REMOVE both set") raise Exception("Flags SCAN and REMOVE both set")
@ -85,8 +85,9 @@ class Event(object):
self.__op &= ~OP_SCAN self.__op &= ~OP_SCAN
self.__op |= operation self.__op |= operation
if dst_path: src_path = kwargs.get("src_path")
self.__dst = dst_path if src_path:
self.__src = src_path
@property @property
def path(self): def path(self):
@ -101,8 +102,8 @@ class Event(object):
return self.__op return self.__op
@property @property
def dst_path(self): def src_path(self):
return self.__dst return self.__src
class ScannerProcessingQueue(Thread): class ScannerProcessingQueue(Thread):
def __init__(self, logger): def __init__(self, logger):
@ -137,8 +138,8 @@ class ScannerProcessingQueue(Thread):
item = self.__next_item() item = self.__next_item()
while item: while item:
if item.operation & OP_MOVE: if item.operation & OP_MOVE:
self.__logger.info("Moving: '%s' -> '%s'", item.path, item.dst_path) self.__logger.info("Moving: '%s' -> '%s'", item.src_path, item.path)
scanner.move_file(item.path, item.dst_path) scanner.move_file(item.src_path, item.path)
if item.operation & OP_SCAN: if item.operation & OP_SCAN:
self.__logger.info("Scanning: '%s'", item.path) self.__logger.info("Scanning: '%s'", item.path)
scanner.scan_file(item.path) scanner.scan_file(item.path)
@ -158,15 +159,22 @@ class ScannerProcessingQueue(Thread):
with self.__cond: with self.__cond:
self.__cond.notify() self.__cond.notify()
def put(self, path, operation, *args): def put(self, path, operation, **kwargs):
if not self.__running: if not self.__running:
raise RuntimeError("Trying to put an item in a stopped queue") raise RuntimeError("Trying to put an item in a stopped queue")
with self.__cond: with self.__cond:
if path in self.__queue: if path in self.__queue:
self.__queue[path].set(operation, *args) event = self.__queue[path]
event.set(operation, **kwargs)
else: else:
self.__queue[path] = Event(path, operation, *args) event = Event(path, operation, **kwargs)
self.__queue[path] = event
if operation & OP_MOVE and kwargs["src_path"] in self.__queue:
previous = self.__queue[kwargs["src_path"]]
event.set(previous.operation, src_path = previous.src_path)
del self.__queue[kwargs["src_path"]]
if self.__timer: if self.__timer:
self.__timer.cancel() self.__timer.cancel()