Commit ab653c7e authored by Jim Fulton's avatar Jim Fulton

Removed unneeded loadEx.

Removed unused supportsTransactionalUndo.

Simplified and fixed a bug in getTid.  Now handles undo of object
creation.

Added note that record_iternext doesn't work with versions.
parent edc70235
...@@ -515,32 +515,6 @@ class FileStorage(BaseStorage.BaseStorage, ...@@ -515,32 +515,6 @@ class FileStorage(BaseStorage.BaseStorage,
except TypeError: except TypeError:
raise TypeError("invalid oid %r" % (oid,)) raise TypeError("invalid oid %r" % (oid,))
def loadEx(self, oid, version):
# A variant of load() that also returns the version string.
# ZEO wants this for managing its cache.
self._lock_acquire()
try:
pos = self._lookup_pos(oid)
h = self._read_data_header(pos, oid)
if h.version and h.version != version:
# Return data and tid from pnv (non-version data).
# If we return the old record's transaction id, then
# it will look to the cache like old data is current.
# The tid for the current data must always be greater
# than any non-current data.
data = self._loadBack_impl(oid, h.pnv)[0]
return data, h.tid, ""
if h.plen:
data = self._file.read(h.plen)
return data, h.tid, h.version
else:
# Get the data from the backpointer, but tid from
# currnt txn.
data = self._loadBack_impl(oid, h.back)[0]
return data, h.tid, h.version
finally:
self._lock_release()
def load(self, oid, version): def load(self, oid, version):
"""Return pickle data and serial number.""" """Return pickle data and serial number."""
self._lock_acquire() self._lock_acquire()
...@@ -940,9 +914,6 @@ class FileStorage(BaseStorage.BaseStorage, ...@@ -940,9 +914,6 @@ class FileStorage(BaseStorage.BaseStorage,
self._file.truncate(self._pos) self._file.truncate(self._pos)
self._nextpos=0 self._nextpos=0
def supportsTransactionalUndo(self):
return 1
def _undoDataInfo(self, oid, pos, tpos): def _undoDataInfo(self, oid, pos, tpos):
"""Return the tid, data pointer, data, and version for the oid """Return the tid, data pointer, data, and version for the oid
record at pos""" record at pos"""
...@@ -974,17 +945,17 @@ class FileStorage(BaseStorage.BaseStorage, ...@@ -974,17 +945,17 @@ class FileStorage(BaseStorage.BaseStorage,
result = self._get_cached_tid(oid) result = self._get_cached_tid(oid)
if result is None: if result is None:
pos = self._lookup_pos(oid) pos = self._lookup_pos(oid)
result = self._getTid(oid, pos) h = self._read_data_header(pos, oid)
if h.plen == 0 and h.back == 0:
# Undone creation
raise POSKeyError(oid)
else:
result = h.tid
self._oid2tid[oid] = result
return result return result
finally: finally:
self._lock_release() self._lock_release()
def _getTid(self, oid, pos):
self._file.seek(pos)
h = self._file.read(16)
assert oid == h[:8]
return h[8:]
def _getVersion(self, oid, pos): def _getVersion(self, oid, pos):
h = self._read_data_header(pos, oid) h = self._read_data_header(pos, oid)
if h.version: if h.version:
...@@ -1440,7 +1411,10 @@ class FileStorage(BaseStorage.BaseStorage, ...@@ -1440,7 +1411,10 @@ class FileStorage(BaseStorage.BaseStorage,
except ValueError: # "empty tree" error except ValueError: # "empty tree" error
next_oid = None next_oid = None
data, tid = self.load(oid, "") # ignore versions # ignore versions
# XXX if the object was created in a version, this will fail.
data, tid = self.load(oid, "")
return oid, tid, data, next_oid return oid, tid, data, next_oid
......
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