summaryrefslogtreecommitdiffstats
path: root/Lib
diff options
context:
space:
mode:
authorPetri Lehtinen <petri@digip.org>2011-11-05 07:50:37 (GMT)
committerPetri Lehtinen <petri@digip.org>2011-11-05 07:50:37 (GMT)
commit49aa72ed4c48fb613893388b470aa5b5464c1952 (patch)
treefd89d82285b9a43d66b9c8d12b27849dfeaf5116 /Lib
parent5d19b9a1e809ee20ba4f26e4aa04922452d0f15f (diff)
downloadcpython-49aa72ed4c48fb613893388b470aa5b5464c1952.zip
cpython-49aa72ed4c48fb613893388b470aa5b5464c1952.tar.gz
cpython-49aa72ed4c48fb613893388b470aa5b5464c1952.tar.bz2
Fix Maildir initialization so that maildir contents are read correctly.
Closes #13254.
Diffstat (limited to 'Lib')
-rw-r--r--Lib/mailbox.py8
-rw-r--r--Lib/test/test_mailbox.py21
2 files changed, 24 insertions, 5 deletions
diff --git a/Lib/mailbox.py b/Lib/mailbox.py
index a9d9c28..0efd743 100644
--- a/Lib/mailbox.py
+++ b/Lib/mailbox.py
@@ -247,11 +247,9 @@ class Maildir(Mailbox):
else:
raise NoSuchMailboxError(self._path)
self._toc = {}
- self._toc_mtimes = {}
- for subdir in ('cur', 'new'):
- self._toc_mtimes[subdir] = os.path.getmtime(self._paths[subdir])
- self._last_read = time.time() # Records last time we read cur/new
- self._skewfactor = 0.1 # Adjust if os/fs clocks are skewing
+ self._toc_mtimes = {'cur': 0, 'new': 0}
+ self._last_read = 0 # Records last time we read cur/new
+ self._skewfactor = 0.1 # Adjust if os/fs clocks are skewing
def add(self, message):
"""Add message and return assigned key."""
diff --git a/Lib/test/test_mailbox.py b/Lib/test/test_mailbox.py
index 1124979..97d3047 100644
--- a/Lib/test/test_mailbox.py
+++ b/Lib/test/test_mailbox.py
@@ -683,6 +683,25 @@ class TestMaildir(TestMailbox):
key1: os.path.join('new', key1),
key2: os.path.join('new', key2)})
+ def test_refresh_after_safety_period(self):
+ # Issue #13254: Call _refresh after the "file system safety
+ # period" of 2 seconds has passed; _toc should still be
+ # updated because this is the first call to _refresh.
+ key0 = self._box.add(self._template % 0)
+ key1 = self._box.add(self._template % 1)
+
+ self._box = self._factory(self._path)
+ self.assertEqual(self._box._toc, {})
+
+ # Emulate sleeping. Instead of sleeping for 2 seconds, use the
+ # skew factor to make _refresh think that the filesystem
+ # safety period has passed and re-reading the _toc is only
+ # required if mtimes differ.
+ self._box._skewfactor = -2
+
+ self._box._refresh()
+ self.assertEqual(sorted(self._box._toc.keys()), sorted([key0, key1]))
+
def test_lookup(self):
# Look up message subpaths in the TOC
self.assertRaises(KeyError, lambda: self._box._lookup('foo'))
@@ -758,6 +777,8 @@ class TestMaildir(TestMailbox):
self.assertFalse((perms & 0111)) # Execute bits should all be off.
def test_reread(self):
+ # Do an initial unconditional refresh
+ self._box._refresh()
# Put the last modified times more than two seconds into the past
# (because mtime may have only a two second granularity).