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

Fix Kodi crash by committing to DB frequently

Browse source 
- Hopefully fixes #531
This commit is contained in:
croneter 2018-08-30 12:27:16 +02:00
parent 04558ae73c
commit 535163b675
1 changed files with 14 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
resources/lib/library_sync/process_metadata.py
View file

@ -12,6 +12,11 @@ from . import sync_info
###############################################################################
LOG = getLogger("PLEX." + __name__)
# Commit to DB happens only after leaving respective itemtypes context manager
# with item_fct() as item_class:
# After how many items shall we additionally commit? Otherwise, Kodi
# crashes if we sync thousands of items without a single commit.
COMMIT_AFTER_N_ITEMS = 1000
###############################################################################
@ -57,14 +62,12 @@ class ThreadedProcessMetadata(Thread):
LOG.debug('Processing thread started')
# Constructs the method name, e.g. itemtypes.Movies
item_fct = getattr(itemtypes, self.item_class)
# cache local variables because it's faster
queue = self.queue
stopped = self.stopped
n = 0
with item_fct() as item_class:
while stopped() is False:
while self.stopped() is False:
# grabs item from queue
try:
item = queue.get(block=False)
item = self.queue.get(block=False)
except Empty:
sleep(20)
continue
@ -83,6 +86,11 @@ class ThreadedProcessMetadata(Thread):
with sync_info.LOCK:
sync_info.PROCESS_METADATA_COUNT += 1
sync_info.PROCESSING_VIEW_NAME = item['title']
queue.task_done()
n += 1
if n == COMMIT_AFTER_N_ITEMS:
n = 0
item_class.plexconn.commit()
item_class.kodiconn.commit()
self.queue.task_done()
self.terminate_now()
LOG.debug('Processing thread terminated')