diff options
author | Tim Peters <tim.peters@gmail.com> | 2003-07-13 02:22:03 +0000 |
---|---|---|
committer | Tim Peters <tim.peters@gmail.com> | 2003-07-13 02:22:03 +0000 |
commit | 4ea45f92091940ba853bcb333204b8631e9ddb1d (patch) | |
tree | 52e70d6b105b5e0afcd404d75366de5b29c2165f /Lib/dumbdbm.py | |
parent | da8c86d6a0348409ea0615140e43ad3d5e064b2b (diff) | |
download | cpython-4ea45f92091940ba853bcb333204b8631e9ddb1d.tar.gz |
Fixed critical shutdown race in _Database._commit.
Related to SF patch 723231 (which pointed out the problem, but didn't
fix it, just shut up the warning msg -- which was pointing out a dead-
serious bug!).
Bugfix candidate.
Diffstat (limited to 'Lib/dumbdbm.py')
-rw-r--r-- | Lib/dumbdbm.py | 24 |
1 files changed, 19 insertions, 5 deletions
diff --git a/Lib/dumbdbm.py b/Lib/dumbdbm.py index 8e2ec907fb..4e426f1c53 100644 --- a/Lib/dumbdbm.py +++ b/Lib/dumbdbm.py @@ -33,6 +33,17 @@ error = IOError # For anydbm class _Database(UserDict.DictMixin): + # The on-disk directory and data files can remain in mutually + # inconsistent states for an arbitrarily long time (see comments + # at the end of __setitem__). This is only repaired when _commit() + # gets called. One place _commit() gets called is from __del__(), + # and if that occurs at program shutdown time, module globals may + # already have gotten rebound to None. Since it's crucial that + # _commit() finish sucessfully, we can't ignore shutdown races + # here, and _commit() must not reference any globals. + _os = _os # for _commit() + _open = _open # for _commit() + def __init__(self, filebasename, mode): self._mode = mode @@ -78,17 +89,20 @@ class _Database(UserDict.DictMixin): # file (if any) is renamed with a .bak extension first. If a .bak # file currently exists, it's deleted. def _commit(self): + # CAUTION: It's vital that _commit() succeed, and _commit() can + # be called from __del__(). Therefore we must never reference a + # global in this routine. try: - _os.unlink(self._bakfile) - except _os.error: + self._os.unlink(self._bakfile) + except self._os.error: pass try: - _os.rename(self._dirfile, self._bakfile) - except _os.error: + self._os.rename(self._dirfile, self._bakfile) + except self._os.error: pass - f = _open(self._dirfile, 'w', self._mode) + f = self._open(self._dirfile, 'w', self._mode) for key, pos_and_siz_pair in self._index.iteritems(): f.write("%r, %r\n" % (key, pos_and_siz_pair)) f.close() |