dinislage/CouchPotatoServer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Lock while editing listeners

Browse Source
This commit is contained in:
Ruud
2013-09-01 00:24:18 +02:00
parent f6c836157d
commit 1e5d6bad2a
1 changed files with 4 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files
couchpotato/core/notifications/core/main.py
+4
View File
@@ -188,11 +188,14 @@ class CoreNotifier(Notification):
'result': messages, 'result': messages,
}) })
self.m_lock.acquire()
self.listeners.append((callback, last_id)) self.listeners.append((callback, last_id))
self.m_lock.release()
def removeListener(self, callback): def removeListener(self, callback):
self.m_lock.acquire()
for list_tuple in self.listeners: for list_tuple in self.listeners:
try: try:
listener, last_id = list_tuple listener, last_id = list_tuple
@@ -200,6 +203,7 @@ class CoreNotifier(Notification):
self.listeners.remove(list_tuple) self.listeners.remove(list_tuple)
except: except:
log.debug('Failed removing listener: %s', traceback.format_exc()) log.debug('Failed removing listener: %s', traceback.format_exc())
self.m_lock.release()
def cleanMessages(self): def cleanMessages(self):