Troplo/PlexKodiConnect
1
0
Fork 0
Code Issues Pull requests Projects Releases Wiki Activity

Clarify some comments

Browse source
This commit is contained in:
croneter 2018-07-07 18:57:09 +02:00
parent 641520dcbb
commit 33afc448fd
1 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
resources/lib/playlists.py
View file

@ -595,14 +595,15 @@ class PlaylistQueue(OrderedSetQueue):
class PlaylistObserver(Observer): class PlaylistObserver(Observer):
""" """
PKC implementation, overriding the dispatcher. PKC will wait for the PKC implementation, overriding the dispatcher. PKC will wait for the
duration timeout (in seconds) before dispatching. A new event will reset duration timeout (in seconds) AFTER receiving a filesystem event. A new
the timer. ("non-similar") event will reset the timer.
Creating and modifying will be regarded as equal. Creating and modifying will be regarded as equal.
""" """
def __init__(self, *args, **kwargs): def __init__(self, *args, **kwargs):
super(PlaylistObserver, self).__init__(*args, **kwargs) super(PlaylistObserver, self).__init__(*args, **kwargs)
# Drop the same events that get into the queue even if there are other # Drop the same events that get into the queue even if there are other
# events in between these similar events # events in between these similar events. Ignore directory events
# completely
self._event_queue = PlaylistQueue() self._event_queue = PlaylistQueue()
@staticmethod @staticmethod
@ -612,7 +613,7 @@ class PlaylistObserver(Observer):
elif (event1.src_path == event2.src_path and elif (event1.src_path == event2.src_path and
event1.event_type in SIMILAR_EVENTS and event1.event_type in SIMILAR_EVENTS and
event2.event_type in SIMILAR_EVENTS): event2.event_type in SIMILAR_EVENTS):
# Ignore a consecutive firing of created and modified events # Set created and modified events to equal
return True return True
return False return False
@ -637,14 +638,13 @@ class PlaylistObserver(Observer):
if self._pkc_similar_events(new_event, event): if self._pkc_similar_events(new_event, event):
continue continue
else: else:
# At least on Windows, a dir modified event will be
# triggered once the writing process is done. Fine though
yield event, watch yield event, watch
event, watch = new_event, new_watch event, watch = new_event, new_watch
yield event, watch yield event, watch
def dispatch_events(self, event_queue, timeout): def dispatch_events(self, event_queue, timeout):
for event, watch in self._dispatch_iterator(event_queue, timeout): for event, watch in self._dispatch_iterator(event_queue, timeout):
# This is copy-paste of original code
with self._lock: with self._lock:
# To allow unschedule/stop and safe removal of event handlers # To allow unschedule/stop and safe removal of event handlers
# within event handlers itself, check if the handler is still # within event handlers itself, check if the handler is still