Commit 5a5320e6 authored by Jim Fulton's avatar Jim Fulton

Merge remote-tracking branch 'origin/asyncio' into client-side-conflict-resolution

Conflicts:
	src/ZEO/ClientStorage.py
	src/ZEO/StorageServer.py
parents 92e49851 1eb086da
...@@ -115,7 +115,7 @@ setup(name="ZEO", ...@@ -115,7 +115,7 @@ setup(name="ZEO",
tests_require = tests_require, tests_require = tests_require,
extras_require = dict(test=tests_require), extras_require = dict(test=tests_require),
install_requires = [ install_requires = [
'ZODB >= 5.0.0a1', 'ZODB >= 5.0.0a5',
'six', 'six',
'transaction >= 1.6.0', 'transaction >= 1.6.0',
'persistent >= 4.1.0', 'persistent >= 4.1.0',
......
...@@ -745,6 +745,12 @@ class ClientStorage(ZODB.ConflictResolution.ConflictResolvingStorage): ...@@ -745,6 +745,12 @@ class ClientStorage(ZODB.ConflictResolution.ConflictResolvingStorage):
vote_attempts += 1 vote_attempts += 1
except POSException.StorageTransactionError:
# Hm, we got disconnected and reconnected bwtween
# _check_trans and voting. Let's chack the transaction again:
self._check_trans(txn, 'tpc_vote')
raise
except POSException.ConflictError as err: except POSException.ConflictError as err:
oid = getattr(err, 'oid', None) oid = getattr(err, 'oid', None)
if oid is not None: if oid is not None:
...@@ -757,11 +763,6 @@ class ClientStorage(ZODB.ConflictResolution.ConflictResolvingStorage): ...@@ -757,11 +763,6 @@ class ClientStorage(ZODB.ConflictResolution.ConflictResolvingStorage):
# cache entry is bad and invalidate it. # cache entry is bad and invalidate it.
self._cache.invalidate(oid, None) self._cache.invalidate(oid, None)
raise raise
except POSException.StorageTransactionError:
# Hm, we got disconnected and reconnected bwtween
# _check_trans and voting. Let's chack the transaction again:
tbuf = self._check_trans(txn, 'tpc_vote')
raise
if tbuf.exception: if tbuf.exception:
raise tbuf.exception raise tbuf.exception
......
...@@ -1333,11 +1333,6 @@ class Serving(ServerEvent): ...@@ -1333,11 +1333,6 @@ class Serving(ServerEvent):
class Closed(ServerEvent): class Closed(ServerEvent):
pass pass
default_cert_authenticate = 'SIGNED'
def ssl_config(section):
from .sslconfig import ssl_config
return ssl_config(section, True)
def never_resolve_conflict(oid, committedSerial, oldSerial, newpickle, def never_resolve_conflict(oid, committedSerial, oldSerial, newpickle,
committedData=b''): committedData=b''):
raise ConflictError(oid=oid, serials=(committedSerial, oldSerial), raise ConflictError(oid=oid, serials=(committedSerial, oldSerial),
......
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