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

Merge pull request #639 from croneter/websocket_lock_db

Browse source 
Don't lock Plex DB when processing websocket messages
This commit is contained in:
croneter 2019-01-29 08:26:55 +01:00 committed by GitHub
commit e566dc8515
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

6
resources/lib/library_sync/websocket.py
View file

@ -217,7 +217,7 @@ def store_activity_message(data):
# Likely a Plex id like /library/metadata/3/children # Likely a Plex id like /library/metadata/3/children
continue continue
# We're only looking at existing elements - have we synced yet? # We're only looking at existing elements - have we synced yet?
with PlexDB() as plexdb: with PlexDB(lock=False) as plexdb:
typus = plexdb.item_by_id(plex_id, plex_type=None) typus = plexdb.item_by_id(plex_id, plex_type=None)
if not typus: if not typus:
LOG.debug('plex_id %s not synced yet - skipping', plex_id) LOG.debug('plex_id %s not synced yet - skipping', plex_id)
@ -259,7 +259,7 @@ def process_playing(data):
session_key = message['sessionKey'] session_key = message['sessionKey']
# Do we already have a sessionKey stored? # Do we already have a sessionKey stored?
if session_key not in PLAYSTATE_SESSIONS: if session_key not in PLAYSTATE_SESSIONS:
with PlexDB() as plexdb: with PlexDB(lock=False) as plexdb:
typus = plexdb.item_by_id(plex_id, plex_type=None) typus = plexdb.item_by_id(plex_id, plex_type=None)
if not typus: if not typus:
# Item not (yet) in Kodi library # Item not (yet) in Kodi library
@ -360,7 +360,7 @@ def cache_artwork(plex_id, plex_type, kodi_id=None, kodi_type=None):
if not CACHING_ENALBED: if not CACHING_ENALBED:
return return
if not kodi_id: if not kodi_id:
with PlexDB() as plexdb: with PlexDB(lock=False) as plexdb:
item = plexdb.item_by_id(plex_id, plex_type) item = plexdb.item_by_id(plex_id, plex_type)
if not item: if not item:
LOG.error('Could not retrieve Plex db info for %s', plex_id) LOG.error('Could not retrieve Plex db info for %s', plex_id)