

def _handle_sync_response(self, node, response, info, broker, http, different_region):
    parent = super(ContainerReplicator, self)
    if is_success(response.status):
        remote_info = json.loads(response.data)
        if incorrect_policy_index(info, remote_info):
            status_changed_at = Timestamp(time.time())
            broker.set_storage_policy_index(remote_info['storage_policy_index'], timestamp=status_changed_at.internal)
        sync_timestamps = ('created_at', 'put_timestamp', 'delete_timestamp')
        if any(((info[key] != remote_info[key]) for key in sync_timestamps)):
            broker.merge_timestamps(*(remote_info[key] for key in sync_timestamps))
    rv = parent._handle_sync_response(node, response, info, broker, http, different_region)
    return rv

dataset/ETHPy150Open openstack/swift/swift/container/replicator.py ContainerReplicator._handle_sync_response/original