Commit b6b4c580 authored by Jim Fulton's avatar Jim Fulton

If there is a failure while FileStorage is finalizing a transaction,

the file storage is closed because it's internal meta data may be
invalid.
parent 53ac5f53
......@@ -812,22 +812,34 @@ class FileStorage(BaseStorage.BaseStorage,
self._lock_release()
def _finish(self, tid, u, d, e):
nextpos=self._nextpos
if nextpos:
file=self._file
# If self._nextpos is 0, then the transaction didn't write any
# data, so we don't bother writing anything to the file.
if self._nextpos:
# Clear the checkpoint flag
file.seek(self._pos+16)
file.write(self._tstatus)
file.flush()
if fsync is not None: fsync(file.fileno())
self._pos = nextpos
self._file.seek(self._pos+16)
self._file.write(self._tstatus)
try:
# At this point, we may have committed the data to disk.
# If we fail from here, we're in bad shape.
self._finish_finish(tid)
except:
# Ouch. This is bad. Let's try to get back to where we were
# and then roll over and die
logger.critical("Failure in _finish. Closing.", exc_info=True)
self.close()
raise
self._index.update(self._tindex)
self._vindex.update(self._tvindex)
def _finish_finish(self, tid):
# This is a separate method to allow tests to replace it with
# something broken. :)
self._file.flush()
if fsync is not None:
fsync(self._file.fileno())
self._pos = self._nextpos
self._index.update(self._tindex)
self._vindex.update(self._tvindex)
self._ltid = tid
def _abort(self):
......
......@@ -509,6 +509,60 @@ Of course, calling lastInvalidations on an empty storage refturns no data:
"""
def deal_with_finish_failures():
r"""
It's really bad to get errors in FileStorage's _finish method, as
that can cause the file storage to be in an inconsistent
state. The data file will be fine, but the internal data
structures might be hosed. For this reason, FileStorage will close
if there is an error after it has finished writing transaction
data. It bothers to do very little after writing this data, so
this should rarely, if ever, happen.
>>> fs = ZODB.FileStorage.FileStorage('data.fs')
>>> db = DB(fs)
>>> conn = db.open()
>>> conn.root()[1] = 1
>>> transaction.commit()
Now, we'll indentially break the file storage. It provides a hook
for this purpose. :)
>>> fs._finish_finish = lambda : None
>>> conn.root()[1] = 1
>>> import zope.testing.loggingsupport
>>> handler = zope.testing.loggingsupport.InstalledHandler(
... 'ZODB.FileStorage')
>>> transaction.commit()
Traceback (most recent call last):
...
TypeError: <lambda>() takes no arguments (1 given)
>>> print handler
ZODB.FileStorage CRITICAL
Failure in _finish. Closing.
>>> handler.uninstall()
>>> fs.load('\0'*8, '')
Traceback (most recent call last):
...
ValueError: I/O operation on closed file
>>> db.close()
>>> fs = ZODB.FileStorage.FileStorage('data.fs')
>>> db = DB(fs)
>>> conn = db.open()
>>> conn.root()
{1: 1}
>>> transaction.abort()
>>> db.close()
"""
def test_suite():
from zope.testing import doctest
......
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