diff options
| author | Kali Kaneko <kali@leap.se> | 2016-05-01 13:58:28 -0400 |
|---|---|---|
| committer | drebs <drebs@leap.se> | 2016-05-03 10:52:25 -0300 |
| commit | b7b7ddaeca42a9cde43c99cf6e3f9a937e5490a8 (patch) | |
| tree | cf1fe5b7b8ff56341a318f5519b5fbb4b4d469e4 /client/src/leap | |
| parent | 33ecd8375e80e452486b727c2ef54d67d330505c (diff) | |
[feature] use deferred semaphore
Diffstat (limited to 'client/src/leap')
| -rw-r--r-- | client/src/leap/soledad/client/adbapi.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/client/src/leap/soledad/client/adbapi.py b/client/src/leap/soledad/client/adbapi.py index 77822247..c2fbb06e 100644 --- a/client/src/leap/soledad/client/adbapi.py +++ b/client/src/leap/soledad/client/adbapi.py @@ -24,9 +24,9 @@ import sys import logging from functools import partial -from threading import BoundedSemaphore from twisted.enterprise import adbapi +from twisted.internet.defer import DeferredSemaphore from twisted.python import log from zope.proxy import ProxyBase, setProxiedObject from pysqlcipher.dbapi2 import OperationalError @@ -204,7 +204,7 @@ class U1DBConnectionPool(adbapi.ConnectionPool): :rtype: twisted.internet.defer.Deferred """ meth = "u1db_%s" % meth - semaphore = BoundedSemaphore(SQLCIPHER_MAX_RETRIES - 1) + semaphore = DeferredSemaphore(SQLCIPHER_MAX_RETRIES - 1) def _run_interaction(): return self.runInteraction( |