Merge 4.x branch

CHANGES.rst

@@ -10,13 +10,12 @@ See 4.4.2.
 5.0.0a3 (2016-07-01)
 ====================
 
-Added IMultiCommitStorage to directly represent the changes in the 4.4.0
-release and to make complient storages introspectable.
+See 4.4.1.
 
 5.0.0a2 (2016-07-01)
 ====================
 
-See the 4.4.x releases.
+See 4.4.0.
 
 5.0.0a1 (2016-06-20)
 ====================
@@ -38,7 +37,7 @@ Concurrency Control (MVCC) implementation:
 ==================
 
 Better support of the new commit protocol. This fixes issues with blobs and
-undo. See https://github.com/zopefoundation/ZODB/pull/77
+undo. See pull requests #77, #80, #83
 
 4.4.1 (2016-07-01)
 ==================

src/ZODB/ConflictResolution.py

@@ -28,7 +28,7 @@ from pickle import PicklingError
 
 logger = logging.getLogger('ZODB.ConflictResolution')
 
-ResolvedSerial = b'rs' # deprecated: store/tpc_finish should just use True
+ResolvedSerial = b'rs' # deprecated: see IMultiCommitStorage.tpc_vote
 
 class BadClassName(Exception):
     pass

src/ZODB/Connection.py

@@ -589,7 +589,7 @@ class Connection(ExportImport, object):
 
             self._handle_serial(oid, s)
 
-    def _handle_serial(self, oid, serial=True, change=True):
+    def _handle_serial(self, oid, serial=ResolvedSerial, change=True):
 
         # if we write an object, we don't want to check if it was read
         # while current.  This is a convenient choke point to do this.
@@ -597,10 +597,7 @@ class Connection(ExportImport, object):
 
         if not serial:
             return
-        if serial is True:
-            serial = ResolvedSerial
-        elif not isinstance(serial, bytes):
-            raise serial
+        assert isinstance(serial, bytes), serial
         obj = self._cache.get(oid, None)
         if obj is None:
             return

src/ZODB/tests/testDemoStorage.py

@@ -49,8 +49,6 @@ from ZODB.ConflictResolution import ResolvedSerial
 
 class DemoStorage(ZODB.DemoStorage.DemoStorage):
 
-    delayed_store = False
-
     def tpc_begin(self, *args):
         super(DemoStorage, self).tpc_begin(*args)
         self.__stored = []
@@ -60,8 +58,6 @@ class DemoStorage(ZODB.DemoStorage.DemoStorage):
         if s != ResolvedSerial:
             assert type(s) is bytes, s
             return
-        if not self.delayed_store:
-            return True
         self.__stored.append(oid)
 
     tpc_vote = property(lambda self: self._tpc_vote, lambda *_: None)
@@ -69,7 +65,7 @@ class DemoStorage(ZODB.DemoStorage.DemoStorage):
     def _tpc_vote(self, transaction):
         s = self.changes.tpc_vote(transaction)
         assert s is None, s
-        return self.__stored if self.delayed_store else s
+        return self.__stored
 
     def tpc_finish(self, transaction, func = lambda tid: None):
         r = []
@@ -146,11 +142,6 @@ class DemoStorageTests(
         self._checkHistory(base_and_changes())
         self._storage = self._storage.pop()
 
-    def checkResolveLate(self):
-        self._storage.delayed_store = True
-        self.checkResolve()
-
-
 class DemoStorageHexTests(DemoStorageTests):
 
     def setUp(self):