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

Rename method

Browse source
This commit is contained in:
croneter 2020-02-14 13:40:46 +01:00
parent 9b0075d6bb
commit d116bbdfe9
1 changed files with 4 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
resources/lib/backgroundthread.py
View file

@ -230,7 +230,7 @@ class ProcessingQueue(Queue.Queue, object):
self.unfinished_tasks += 1 self.unfinished_tasks += 1
if len(self._queues) == 1: if len(self._queues) == 1:
# queue was already exhausted! # queue was already exhausted!
self._switch_queues() self._activate_next_section()
self._counter = 0 self._counter = 0
self.not_empty.notify() self.not_empty.notify()
else: else:
@ -255,15 +255,15 @@ class ProcessingQueue(Queue.Queue, object):
OrderedQueue() if section.plex_type == v.PLEX_TYPE_ALBUM OrderedQueue() if section.plex_type == v.PLEX_TYPE_ALBUM
else Queue.Queue()) else Queue.Queue())
if self._current_section is None: if self._current_section is None:
self._switch_queues() self._activate_next_section()
def _init_next_section(self): def _init_next_section(self):
self._sections.popleft() self._sections.popleft()
self._queues.popleft() self._queues.popleft()
self._counter = 0 self._counter = 0
self._switch_queues() self._activate_next_section()
def _switch_queues(self): def _activate_next_section(self):
self._current_section = self._sections[0] if self._sections else None self._current_section = self._sections[0] if self._sections else None
self._current_queue = self._queues[0] if self._queues else None self._current_queue = self._queues[0] if self._queues else None