]> git-server-git.apps.pok.os.sepia.ceph.com Git - radosgw-agent.git/commitdiff
set the params for versioned operations before using them
authorAlfredo Deza <adeza@redhat.com>
Thu, 5 Feb 2015 16:37:20 +0000 (11:37 -0500)
committerAlfredo Deza <adeza@redhat.com>
Thu, 5 Feb 2015 16:37:20 +0000 (11:37 -0500)
Signed-off-by: Alfredo Deza <adeza@redhat.com>
radosgw_agent/client.py

index d40d10b6706c6fca63f9fa1d4c98536e477af5fa..9a731d618b66a563852b4e817c6c6a1cb3250f28 100644 (file)
@@ -297,14 +297,17 @@ def sync_object_intra_region(connection, bucket_name, obj, src_zone,
 
     if is_versioned(obj):
         log.debug('detected obj as versioned: %s' % obj.name)
+
+        # set the extra params to support versioned operations
+        params['rgwx-version-id'] = obj.version_id
+        params['rgwx-versioned-epoch'] = obj.VersionedEpoch
+
         # delete_marker may not exist in the obj
         if getattr(obj, 'delete_marker', None) is True:
             log.debug('obj %s has a delete_marker, marking for deletion' % obj.name)
             # when the object has a delete marker we need to create it with
             # a delete marker on the destination rather than copying
             return mark_delete_object(connection, bucket_name, obj, params=params)
-        params['rgwx-version-id'] = obj.version_id
-        params['rgwx-versioned-epoch'] = obj.VersionedEpoch
 
     path = u'{bucket}/{object}'.format(
         bucket=bucket_name,