Commit 50134569 authored by Julien Muchembled's avatar Julien Muchembled

threaded: make it possible to send packets from a connection filter

This could have been useful in testStorageFailureDuringTpcFinish:
close() could not be called from answerTransactionFinished because it
deadlocked while trying to send notifications.
parent c5913373
...@@ -425,7 +425,7 @@ class ConnectionFilter(object): ...@@ -425,7 +425,7 @@ class ConnectionFilter(object):
filtered_count = 0 filtered_count = 0
filter_list = [] filter_list = []
filter_queue = weakref.WeakKeyDictionary() filter_queue = weakref.WeakKeyDictionary()
lock = threading.Lock() lock = threading.RLock()
_addPacket = Connection._addPacket _addPacket = Connection._addPacket
@contextmanager @contextmanager
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment