'Disable replication on the given volume.'

def _disable_replication(self, volume):

    vol_name = utils.convert_str(volume.name)
    with RBDVolumeProxy(self, vol_name) as image:
        image.mirror_image_disable(False)
        driver_data = json.loads(volume.replication_driver_data)
        if (not driver_data['had_journaling']):
            image.update_features(self.rbd.RBD_FEATURE_JOURNALING, False)
        if (not driver_data['had_exclusive_lock']):
            image.update_features(self.rbd.RBD_FEATURE_EXCLUSIVE_LOCK, False)
    return {'replication_status': fields.ReplicationStatus.DISABLED, 'replication_driver_data': None}
