'Connect the volume.'

@utils.synchronized('connect_qb_volume')
def connect_volume(self, connection_info, disk_info, instance):

    data = connection_info['data']
    quobyte_volume = self._normalize_export(data['export'])
    mount_path = self._get_mount_path(connection_info)
    mounted = libvirt_utils.is_mounted(mount_path, ((SOURCE_PROTOCOL + '@') + quobyte_volume))
    if mounted:
        try:
            os.stat(mount_path)
        except OSError as exc:
            if (exc.errno == errno.ENOTCONN):
                mounted = False
                LOG.info('Fixing    previous    mount    %s    which    was    not    unmounted    correctly.', mount_path)
                umount_volume(mount_path)
    if (not mounted):
        mount_volume(quobyte_volume, mount_path, CONF.libvirt.quobyte_client_cfg)
    validate_volume(mount_path)
