a180a41bba1d50822df23fff0099e90b86638b89vboxsync/* -*- c-basic-offset: 8 -*-
a180a41bba1d50822df23fff0099e90b86638b89vboxsync rdesktop: A Remote Desktop Protocol client.
a180a41bba1d50822df23fff0099e90b86638b89vboxsync Sound Channel Process Functions - libao-driver
a180a41bba1d50822df23fff0099e90b86638b89vboxsync Copyright (C) Matthew Chapman <matthewc.unsw.edu.au> 2003-2008
a180a41bba1d50822df23fff0099e90b86638b89vboxsync Copyright (C) GuoJunBo <guojunbo@ict.ac.cn> 2003
a180a41bba1d50822df23fff0099e90b86638b89vboxsync Copyright (C) Michael Gernoth <mike@zerfleddert.de> 2005-2008
a180a41bba1d50822df23fff0099e90b86638b89vboxsync Copyright (C) 2013 Henrik Andersson
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync This program is free software: you can redistribute it and/or modify
a180a41bba1d50822df23fff0099e90b86638b89vboxsync it under the terms of the GNU General Public License as published by
a180a41bba1d50822df23fff0099e90b86638b89vboxsync the Free Software Foundation, either version 3 of the License, or
a180a41bba1d50822df23fff0099e90b86638b89vboxsync (at your option) any later version.
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync This program is distributed in the hope that it will be useful,
a180a41bba1d50822df23fff0099e90b86638b89vboxsync but WITHOUT ANY WARRANTY; without even the implied warranty of
a180a41bba1d50822df23fff0099e90b86638b89vboxsync MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
a180a41bba1d50822df23fff0099e90b86638b89vboxsync GNU General Public License for more details.
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync You should have received a copy of the GNU General Public License
a180a41bba1d50822df23fff0099e90b86638b89vboxsync along with this program. If not, see <http://www.gnu.org/licenses/>.
a180a41bba1d50822df23fff0099e90b86638b89vboxsync*/
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
6e9aa255e3376b2da5824c09c4c62bc233463bfevboxsync/*
6e9aa255e3376b2da5824c09c4c62bc233463bfevboxsync * Oracle GPL Disclaimer: For the avoidance of doubt, except that if any license choice
6e9aa255e3376b2da5824c09c4c62bc233463bfevboxsync * other than GPL or LGPL is available it will apply instead, Oracle elects to use only
6e9aa255e3376b2da5824c09c4c62bc233463bfevboxsync * the General Public License version 2 (GPLv2) at this time for any software where
6e9aa255e3376b2da5824c09c4c62bc233463bfevboxsync * a choice of GPL license versions is made available with the language indicating
6e9aa255e3376b2da5824c09c4c62bc233463bfevboxsync * that GPLv2 or any later version may be used, or where a choice of which version
6e9aa255e3376b2da5824c09c4c62bc233463bfevboxsync * of the GPL is applied is otherwise unspecified.
6e9aa255e3376b2da5824c09c4c62bc233463bfevboxsync */
6e9aa255e3376b2da5824c09c4c62bc233463bfevboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync#include "rdesktop.h"
a180a41bba1d50822df23fff0099e90b86638b89vboxsync#include "rdpsnd.h"
a180a41bba1d50822df23fff0099e90b86638b89vboxsync#include "rdpsnd_dsp.h"
a180a41bba1d50822df23fff0099e90b86638b89vboxsync#include <unistd.h>
a180a41bba1d50822df23fff0099e90b86638b89vboxsync#include <fcntl.h>
a180a41bba1d50822df23fff0099e90b86638b89vboxsync#include <errno.h>
a180a41bba1d50822df23fff0099e90b86638b89vboxsync#include <ao/ao.h>
a180a41bba1d50822df23fff0099e90b86638b89vboxsync#include <sys/time.h>
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync#define WAVEOUTLEN 16
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncstatic ao_device *o_device = NULL;
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncstatic int default_driver;
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncstatic RD_BOOL reopened;
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncstatic char *libao_device = NULL;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncvoid libao_play(void);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncvoid
a180a41bba1d50822df23fff0099e90b86638b89vboxsynclibao_add_fds(int *n, fd_set * rfds, fd_set * wfds, struct timeval *tv)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync{
a180a41bba1d50822df23fff0099e90b86638b89vboxsync /* We need to be called rather often... */
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (o_device != NULL && !rdpsnd_queue_empty())
a180a41bba1d50822df23fff0099e90b86638b89vboxsync FD_SET(0, wfds);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync}
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncvoid
a180a41bba1d50822df23fff0099e90b86638b89vboxsynclibao_check_fds(fd_set * rfds, fd_set * wfds)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync{
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (o_device == NULL)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync return;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (!rdpsnd_queue_empty())
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_play();
a180a41bba1d50822df23fff0099e90b86638b89vboxsync}
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncRD_BOOL
a180a41bba1d50822df23fff0099e90b86638b89vboxsynclibao_open(void)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync{
a180a41bba1d50822df23fff0099e90b86638b89vboxsync ao_sample_format format;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync ao_initialize();
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (libao_device)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync default_driver = ao_driver_id(libao_device);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync else
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync default_driver = ao_default_driver_id();
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync memset(&format, 0, sizeof(format));
a180a41bba1d50822df23fff0099e90b86638b89vboxsync format.bits = 16;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync format.channels = 2;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync format.rate = 44100;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync format.byte_format = AO_FMT_NATIVE;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync o_device = ao_open_live(default_driver, &format, NULL);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (o_device == NULL)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync return False;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync reopened = True;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync return True;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync}
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncvoid
a180a41bba1d50822df23fff0099e90b86638b89vboxsynclibao_close(void)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync{
a180a41bba1d50822df23fff0099e90b86638b89vboxsync /* Ack all remaining packets */
a180a41bba1d50822df23fff0099e90b86638b89vboxsync while (!rdpsnd_queue_empty())
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync rdpsnd_queue_next(0);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (o_device != NULL)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync ao_close(o_device);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync o_device = NULL;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync ao_shutdown();
a180a41bba1d50822df23fff0099e90b86638b89vboxsync}
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncRD_BOOL
a180a41bba1d50822df23fff0099e90b86638b89vboxsynclibao_set_format(RD_WAVEFORMATEX * pwfx)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync{
a180a41bba1d50822df23fff0099e90b86638b89vboxsync ao_sample_format format;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync memset(&format, 0, sizeof(format));
a180a41bba1d50822df23fff0099e90b86638b89vboxsync format.bits = pwfx->wBitsPerSample;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync format.channels = pwfx->nChannels;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync format.rate = 44100;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync format.byte_format = AO_FMT_NATIVE;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (o_device != NULL)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync ao_close(o_device);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync o_device = ao_open_live(default_driver, &format, NULL);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (o_device == NULL)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync return False;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (rdpsnd_dsp_resample_set(44100, pwfx->wBitsPerSample, pwfx->nChannels) == False)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync return False;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync reopened = True;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync return True;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync}
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncvoid
a180a41bba1d50822df23fff0099e90b86638b89vboxsynclibao_play(void)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync{
a180a41bba1d50822df23fff0099e90b86638b89vboxsync struct audio_packet *packet;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync STREAM out;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync int len;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync static long prev_s, prev_us;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync unsigned int duration;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync struct timeval tv;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync int next_tick;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (reopened)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync reopened = False;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync gettimeofday(&tv, NULL);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync prev_s = tv.tv_sec;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync prev_us = tv.tv_usec;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync /* We shouldn't be called if the queue is empty, but still */
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (rdpsnd_queue_empty())
a180a41bba1d50822df23fff0099e90b86638b89vboxsync return;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync packet = rdpsnd_queue_current_packet();
a180a41bba1d50822df23fff0099e90b86638b89vboxsync out = &packet->s;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync next_tick = rdpsnd_queue_next_tick();
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync len = (WAVEOUTLEN > (out->end - out->p)) ? (out->end - out->p) : WAVEOUTLEN;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync ao_play(o_device, (char *) out->p, len);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync out->p += len;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync gettimeofday(&tv, NULL);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync duration = ((tv.tv_sec - prev_s) * 1000000 + (tv.tv_usec - prev_us)) / 1000;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (packet->tick > next_tick)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync next_tick += 65536;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if ((out->p == out->end) || duration > next_tick - packet->tick + 500)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync unsigned int delay_us;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync prev_s = tv.tv_sec;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync prev_us = tv.tv_usec;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (abs((next_tick - packet->tick) - duration) > 20)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync DEBUG(("duration: %d, calc: %d, ", duration, next_tick - packet->tick));
a180a41bba1d50822df23fff0099e90b86638b89vboxsync DEBUG(("last: %d, is: %d, should: %d\n", packet->tick,
a180a41bba1d50822df23fff0099e90b86638b89vboxsync (packet->tick + duration) % 65536, next_tick % 65536));
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync delay_us = ((out->size / 4) * (1000000 / 44100));
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync rdpsnd_queue_next(delay_us);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync}
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsyncstruct audio_driver *
a180a41bba1d50822df23fff0099e90b86638b89vboxsynclibao_register(char *options)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync{
a180a41bba1d50822df23fff0099e90b86638b89vboxsync static struct audio_driver libao_driver;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync memset(&libao_driver, 0, sizeof(libao_driver));
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.name = "libao";
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.description = "libao output driver, default device: system dependent";
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.add_fds = libao_add_fds;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.check_fds = libao_check_fds;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.wave_out_open = libao_open;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.wave_out_close = libao_close;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.wave_out_format_supported = rdpsnd_dsp_resample_supported;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.wave_out_set_format = libao_set_format;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.wave_out_volume = rdpsnd_dsp_softvol_set;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.need_byteswap_on_be = 1;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_driver.need_resampling = 1;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync if (options)
a180a41bba1d50822df23fff0099e90b86638b89vboxsync {
a180a41bba1d50822df23fff0099e90b86638b89vboxsync libao_device = xstrdup(options);
a180a41bba1d50822df23fff0099e90b86638b89vboxsync }
a180a41bba1d50822df23fff0099e90b86638b89vboxsync
a180a41bba1d50822df23fff0099e90b86638b89vboxsync return &libao_driver;
a180a41bba1d50822df23fff0099e90b86638b89vboxsync}