From dfd61697c17eb5a44587635542293f4c1f9e50f3 Mon Sep 17 00:00:00 2001
From: gholt <gholt@rackspace.com>
Date: Tue, 2 Aug 2011 17:46:17 +0000
Subject: [PATCH] Fix bug; added test for quarantined a hash dir that becomes a
 file

---
 swift/common/db.py               |  6 ++++++
 swift/obj/replicator.py          |  2 +-
 test/unit/obj/test_replicator.py | 21 +++++++++++++++++++++
 3 files changed, 28 insertions(+), 1 deletion(-)

diff --git a/swift/common/db.py b/swift/common/db.py
index 2f939fbce4..1ca1151e57 100644
--- a/swift/common/db.py
+++ b/swift/common/db.py
@@ -258,6 +258,12 @@ class DatabaseBroker(object):
             conn.commit()
 
     def possibly_quarantine(self, exc_type, exc_value, exc_traceback):
+        """
+        Checks the exception info to see if it indicates a quarantine situation
+        (malformed or corrupted database). If not, the original exception will
+        be reraised. If so, the database will be quarantined and a new
+        sqlite3.DatabaseError will be raised indicating the action taken.
+        """
         if 'database disk image is malformed' in str(exc_value):
             exc_hint = 'malformed'
         elif 'file is encrypted or is not a database' in str(exc_value):
diff --git a/swift/obj/replicator.py b/swift/obj/replicator.py
index 9d072bf9d4..f4823776d6 100644
--- a/swift/obj/replicator.py
+++ b/swift/obj/replicator.py
@@ -80,7 +80,7 @@ def hash_suffix(path, reclaim_age):
         try:
             files = os.listdir(hsh_path)
         except OSError, err:
-            if err.ernno == errno.ENOTDIR:
+            if err.errno == errno.ENOTDIR:
                 partition_path = dirname(path)
                 objects_path = dirname(partition_path)
                 device_path = dirname(objects_path)
diff --git a/test/unit/obj/test_replicator.py b/test/unit/obj/test_replicator.py
index fc4a80524b..a9f5497226 100644
--- a/test/unit/obj/test_replicator.py
+++ b/test/unit/obj/test_replicator.py
@@ -205,6 +205,27 @@ class TestObjectReplicator(unittest.TestCase):
         self.assertEquals(hashed, 1)
         self.assert_('a83' in hashes)
 
+    def test_hash_suffix_hash_dir_is_file_quarantine(self):
+        df = DiskFile(self.devices, 'sda', '0', 'a', 'c', 'o', FakeLogger())
+        mkdirs(os.path.dirname(df.datadir))
+        open(df.datadir, 'wb').close()
+        ohash = hash_path('a', 'c', 'o')
+        data_dir = ohash[-3:]
+        whole_path_from = os.path.join(self.objects, '0', data_dir)
+        orig_quarantine_renamer = object_replicator.quarantine_renamer
+        called = [False]
+
+        def wrapped(*args, **kwargs):
+            called[0] = True
+            return orig_quarantine_renamer(*args, **kwargs)
+
+        try:
+            object_replicator.quarantine_renamer = wrapped
+            object_replicator.hash_suffix(whole_path_from, 101)
+        finally:
+            object_replicator.quarantine_renamer = orig_quarantine_renamer
+        self.assertTrue(called[0])
+
     def test_hash_suffix_one_file(self):
         df = DiskFile(self.devices, 'sda', '0', 'a', 'c', 'o', FakeLogger())
         mkdirs(df.datadir)