openstack/swift
Code Issues Proposed changes

Fix for object auditor invalidate hashes location bug

Browse Source
This commit is contained in:
David Goetz
2011-03-08 23:02:17 +00:00
committed by Tarmac
parent 00d2477e9f e7672dded2
commit a29b1da65c
1 changed files with 13 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
swift/obj/auditor.py
View File

@@ -15,9 +15,10 @@
import os import os
import time import time
import uuid
import errno
from hashlib import md5 from hashlib import md5
from random import random from random import random
from swift.obj import server as object_server from swift.obj import server as object_server
from swift.obj.replicator import invalidate_hash from swift.obj.replicator import invalidate_hash
from swift.common.utils import get_logger, renamer, audit_location_generator, \ from swift.common.utils import get_logger, renamer, audit_location_generator, \
@@ -148,10 +149,17 @@ class AuditorWorker(object):
self.quarantines += 1 self.quarantines += 1
self.logger.error(_('ERROR Object %(obj)s failed audit and will ' self.logger.error(_('ERROR Object %(obj)s failed audit and will '
'be quarantined: %(err)s'), {'obj': path, 'err': err}) 'be quarantined: %(err)s'), {'obj': path, 'err': err})
invalidate_hash(os.path.dirname(path)) object_dir = os.path.dirname(path)
invalidate_hash(os.path.dirname(object_dir))
renamer_path = os.path.dirname(path) renamer_path = os.path.dirname(path)
renamer(renamer_path, os.path.join(self.devices, device, to_path = os.path.join(self.devices, device, 'quarantined',
'quarantined', 'objects', os.path.basename(renamer_path))) 'objects', os.path.basename(renamer_path))
try:
renamer(renamer_path, to_path)
except OSError, e:
if e.errno == errno.EEXIST:
to_path = "%s-%s" % (to_path, uuid.uuid4().hex)
renamer(renamer_path, to_path)
return return
except Exception: except Exception:
self.errors += 1 self.errors += 1
@@ -165,6 +173,7 @@ class ObjectAuditor(Daemon):
def __init__(self, conf, **options): def __init__(self, conf, **options):
self.conf = conf self.conf = conf
self.logger = get_logger(conf, log_route='object-auditor')
self.conf_zero_byte_fps = int(conf.get( self.conf_zero_byte_fps = int(conf.get(
'zero_byte_files_per_second', 50)) 'zero_byte_files_per_second', 50))