audio: split ctl_* functions into enable_* and volume_*

This way we no longer need vararg functions, improving compile time
error detection.  Also now it's possible to check actually what commands
are supported, without needing to manually update ctl_caps.

Signed-off-by: Kővágó, Zoltán <DirtY.iCE.hu@gmail.com>
Message-id: 2b08b3773569c5be055d0a0fb2f29ff64e79f0f4.1568927990.git.DirtY.iCE.hu@gmail.com
Signed-off-by: Gerd Hoffmann <kraxel@redhat.com>
This commit is contained in:
Kővágó, Zoltán 2019-09-19 23:24:22 +02:00 committed by Gerd Hoffmann
parent 857271a29c
commit 571a8c522e
12 changed files with 222 additions and 320 deletions

View file

@ -731,34 +731,28 @@ static int alsa_voice_ctl (snd_pcm_t *handle, const char *typ, int ctl)
return 0; return 0;
} }
static int alsa_ctl_out (HWVoiceOut *hw, int cmd, ...) static void alsa_enable_out(HWVoiceOut *hw, bool enable)
{ {
ALSAVoiceOut *alsa = (ALSAVoiceOut *) hw; ALSAVoiceOut *alsa = (ALSAVoiceOut *) hw;
AudiodevAlsaPerDirectionOptions *apdo = alsa->dev->u.alsa.out; AudiodevAlsaPerDirectionOptions *apdo = alsa->dev->u.alsa.out;
switch (cmd) { if (enable) {
case VOICE_ENABLE: bool poll_mode = apdo->try_poll;
{
bool poll_mode = apdo->try_poll;
ldebug ("enabling voice\n"); ldebug("enabling voice\n");
if (poll_mode && alsa_poll_out (hw)) { if (poll_mode && alsa_poll_out(hw)) {
poll_mode = 0; poll_mode = 0;
}
hw->poll_mode = poll_mode;
return alsa_voice_ctl (alsa->handle, "playback", VOICE_CTL_PREPARE);
} }
hw->poll_mode = poll_mode;
case VOICE_DISABLE: alsa_voice_ctl(alsa->handle, "playback", VOICE_CTL_PREPARE);
ldebug ("disabling voice\n"); } else {
ldebug("disabling voice\n");
if (hw->poll_mode) { if (hw->poll_mode) {
hw->poll_mode = 0; hw->poll_mode = 0;
alsa_fini_poll (&alsa->pollhlp); alsa_fini_poll(&alsa->pollhlp);
} }
return alsa_voice_ctl (alsa->handle, "playback", VOICE_CTL_PAUSE); alsa_voice_ctl(alsa->handle, "playback", VOICE_CTL_PAUSE);
} }
return -1;
} }
static int alsa_init_in(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque) static int alsa_init_in(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque)
@ -841,35 +835,29 @@ static size_t alsa_read(HWVoiceIn *hw, void *buf, size_t len)
return pos; return pos;
} }
static int alsa_ctl_in (HWVoiceIn *hw, int cmd, ...) static void alsa_enable_in(HWVoiceIn *hw, bool enable)
{ {
ALSAVoiceIn *alsa = (ALSAVoiceIn *) hw; ALSAVoiceIn *alsa = (ALSAVoiceIn *) hw;
AudiodevAlsaPerDirectionOptions *apdo = alsa->dev->u.alsa.in; AudiodevAlsaPerDirectionOptions *apdo = alsa->dev->u.alsa.in;
switch (cmd) { if (enable) {
case VOICE_ENABLE: bool poll_mode = apdo->try_poll;
{
bool poll_mode = apdo->try_poll;
ldebug ("enabling voice\n"); ldebug("enabling voice\n");
if (poll_mode && alsa_poll_in (hw)) { if (poll_mode && alsa_poll_in(hw)) {
poll_mode = 0; poll_mode = 0;
}
hw->poll_mode = poll_mode;
return alsa_voice_ctl (alsa->handle, "capture", VOICE_CTL_START);
} }
hw->poll_mode = poll_mode;
case VOICE_DISABLE: alsa_voice_ctl(alsa->handle, "capture", VOICE_CTL_START);
} else {
ldebug ("disabling voice\n"); ldebug ("disabling voice\n");
if (hw->poll_mode) { if (hw->poll_mode) {
hw->poll_mode = 0; hw->poll_mode = 0;
alsa_fini_poll (&alsa->pollhlp); alsa_fini_poll(&alsa->pollhlp);
} }
return alsa_voice_ctl (alsa->handle, "capture", VOICE_CTL_PAUSE); alsa_voice_ctl(alsa->handle, "capture", VOICE_CTL_PAUSE);
} }
return -1;
} }
static void alsa_init_per_direction(AudiodevAlsaPerDirectionOptions *apdo) static void alsa_init_per_direction(AudiodevAlsaPerDirectionOptions *apdo)
@ -924,12 +912,12 @@ static struct audio_pcm_ops alsa_pcm_ops = {
.init_out = alsa_init_out, .init_out = alsa_init_out,
.fini_out = alsa_fini_out, .fini_out = alsa_fini_out,
.write = alsa_write, .write = alsa_write,
.ctl_out = alsa_ctl_out, .enable_out = alsa_enable_out,
.init_in = alsa_init_in, .init_in = alsa_init_in,
.fini_in = alsa_fini_in, .fini_in = alsa_fini_in,
.read = alsa_read, .read = alsa_read,
.ctl_in = alsa_ctl_in, .enable_in = alsa_enable_in,
}; };
static struct audio_driver alsa_audio_driver = { static struct audio_driver alsa_audio_driver = {

View file

@ -636,7 +636,7 @@ static size_t audio_pcm_sw_read(SWVoiceIn *sw, void *buf, size_t size)
total += isamp; total += isamp;
} }
if (!(hw->ctl_caps & VOICE_VOLUME_CAP)) { if (!hw->pcm_ops->volume_in) {
mixeng_volume (sw->buf, ret, &sw->vol); mixeng_volume (sw->buf, ret, &sw->vol);
} }
@ -723,7 +723,7 @@ static size_t audio_pcm_sw_write(SWVoiceOut *sw, void *buf, size_t size)
if (swlim) { if (swlim) {
sw->conv (sw->buf, buf, swlim); sw->conv (sw->buf, buf, swlim);
if (!(sw->hw->ctl_caps & VOICE_VOLUME_CAP)) { if (!sw->hw->pcm_ops->volume_out) {
mixeng_volume (sw->buf, swlim, &sw->vol); mixeng_volume (sw->buf, swlim, &sw->vol);
} }
} }
@ -890,7 +890,9 @@ void AUD_set_active_out (SWVoiceOut *sw, int on)
if (!hw->enabled) { if (!hw->enabled) {
hw->enabled = 1; hw->enabled = 1;
if (s->vm_running) { if (s->vm_running) {
hw->pcm_ops->ctl_out(hw, VOICE_ENABLE); if (hw->pcm_ops->enable_out) {
hw->pcm_ops->enable_out(hw, true);
}
audio_reset_timer (s); audio_reset_timer (s);
} }
} }
@ -935,7 +937,9 @@ void AUD_set_active_in (SWVoiceIn *sw, int on)
if (!hw->enabled) { if (!hw->enabled) {
hw->enabled = 1; hw->enabled = 1;
if (s->vm_running) { if (s->vm_running) {
hw->pcm_ops->ctl_in(hw, VOICE_ENABLE); if (hw->pcm_ops->enable_in) {
hw->pcm_ops->enable_in(hw, true);
}
audio_reset_timer (s); audio_reset_timer (s);
} }
} }
@ -952,7 +956,9 @@ void AUD_set_active_in (SWVoiceIn *sw, int on)
if (nb_active == 1) { if (nb_active == 1) {
hw->enabled = 0; hw->enabled = 0;
hw->pcm_ops->ctl_in (hw, VOICE_DISABLE); if (hw->pcm_ops->enable_in) {
hw->pcm_ops->enable_in(hw, false);
}
} }
} }
} }
@ -1105,7 +1111,9 @@ static void audio_run_out (AudioState *s)
#endif #endif
hw->enabled = 0; hw->enabled = 0;
hw->pending_disable = 0; hw->pending_disable = 0;
hw->pcm_ops->ctl_out (hw, VOICE_DISABLE); if (hw->pcm_ops->enable_out) {
hw->pcm_ops->enable_out(hw, false);
}
for (sc = hw->cap_head.lh_first; sc; sc = sc->entries.le_next) { for (sc = hw->cap_head.lh_first; sc; sc = sc->entries.le_next) {
sc->sw.active = 0; sc->sw.active = 0;
audio_recalc_and_notify_capture (sc->cap); audio_recalc_and_notify_capture (sc->cap);
@ -1470,15 +1478,18 @@ static void audio_vm_change_state_handler (void *opaque, int running,
AudioState *s = opaque; AudioState *s = opaque;
HWVoiceOut *hwo = NULL; HWVoiceOut *hwo = NULL;
HWVoiceIn *hwi = NULL; HWVoiceIn *hwi = NULL;
int op = running ? VOICE_ENABLE : VOICE_DISABLE;
s->vm_running = running; s->vm_running = running;
while ((hwo = audio_pcm_hw_find_any_enabled_out(s, hwo))) { while ((hwo = audio_pcm_hw_find_any_enabled_out(s, hwo))) {
hwo->pcm_ops->ctl_out(hwo, op); if (hwo->pcm_ops->enable_out) {
hwo->pcm_ops->enable_out(hwo, running);
}
} }
while ((hwi = audio_pcm_hw_find_any_enabled_in(s, hwi))) { while ((hwi = audio_pcm_hw_find_any_enabled_in(s, hwi))) {
hwi->pcm_ops->ctl_in(hwi, op); if (hwi->pcm_ops->enable_in) {
hwi->pcm_ops->enable_in(hwi, running);
}
} }
audio_reset_timer (s); audio_reset_timer (s);
} }
@ -1498,8 +1509,8 @@ static void free_audio_state(AudioState *s)
QLIST_FOREACH_SAFE(hwo, &s->hw_head_out, entries, hwon) { QLIST_FOREACH_SAFE(hwo, &s->hw_head_out, entries, hwon) {
SWVoiceCap *sc; SWVoiceCap *sc;
if (hwo->enabled) { if (hwo->enabled && hwo->pcm_ops->enable_out) {
hwo->pcm_ops->ctl_out (hwo, VOICE_DISABLE); hwo->pcm_ops->enable_out(hwo, false);
} }
hwo->pcm_ops->fini_out (hwo); hwo->pcm_ops->fini_out (hwo);
@ -1515,8 +1526,8 @@ static void free_audio_state(AudioState *s)
} }
QLIST_FOREACH_SAFE(hwi, &s->hw_head_in, entries, hwin) { QLIST_FOREACH_SAFE(hwi, &s->hw_head_in, entries, hwin) {
if (hwi->enabled) { if (hwi->enabled && hwi->pcm_ops->enable_in) {
hwi->pcm_ops->ctl_in (hwi, VOICE_DISABLE); hwi->pcm_ops->enable_in(hwi, false);
} }
hwi->pcm_ops->fini_in (hwi); hwi->pcm_ops->fini_in (hwi);
QLIST_REMOVE(hwi, entries); QLIST_REMOVE(hwi, entries);
@ -1838,8 +1849,8 @@ void AUD_set_volume_out (SWVoiceOut *sw, int mute, uint8_t lvol, uint8_t rvol)
sw->vol.l = nominal_volume.l * lvol / 255; sw->vol.l = nominal_volume.l * lvol / 255;
sw->vol.r = nominal_volume.r * rvol / 255; sw->vol.r = nominal_volume.r * rvol / 255;
if (hw->pcm_ops->ctl_out) { if (hw->pcm_ops->volume_out) {
hw->pcm_ops->ctl_out (hw, VOICE_VOLUME, sw); hw->pcm_ops->volume_out(hw, &sw->vol);
} }
} }
} }
@ -1853,8 +1864,8 @@ void AUD_set_volume_in (SWVoiceIn *sw, int mute, uint8_t lvol, uint8_t rvol)
sw->vol.l = nominal_volume.l * lvol / 255; sw->vol.l = nominal_volume.l * lvol / 255;
sw->vol.r = nominal_volume.r * rvol / 255; sw->vol.r = nominal_volume.r * rvol / 255;
if (hw->pcm_ops->ctl_in) { if (hw->pcm_ops->volume_in) {
hw->pcm_ops->ctl_in (hw, VOICE_VOLUME, sw); hw->pcm_ops->volume_in(hw, &sw->vol);
} }
} }
} }

View file

@ -74,7 +74,6 @@ typedef struct HWVoiceOut {
size_t samples; size_t samples;
QLIST_HEAD (sw_out_listhead, SWVoiceOut) sw_head; QLIST_HEAD (sw_out_listhead, SWVoiceOut) sw_head;
QLIST_HEAD (sw_cap_listhead, SWVoiceCap) cap_head; QLIST_HEAD (sw_cap_listhead, SWVoiceCap) cap_head;
int ctl_caps;
struct audio_pcm_ops *pcm_ops; struct audio_pcm_ops *pcm_ops;
QLIST_ENTRY (HWVoiceOut) entries; QLIST_ENTRY (HWVoiceOut) entries;
} HWVoiceOut; } HWVoiceOut;
@ -96,7 +95,6 @@ typedef struct HWVoiceIn {
size_t samples; size_t samples;
QLIST_HEAD (sw_in_listhead, SWVoiceIn) sw_head; QLIST_HEAD (sw_in_listhead, SWVoiceIn) sw_head;
int ctl_caps;
struct audio_pcm_ops *pcm_ops; struct audio_pcm_ops *pcm_ops;
QLIST_ENTRY (HWVoiceIn) entries; QLIST_ENTRY (HWVoiceIn) entries;
} HWVoiceIn; } HWVoiceIn;
@ -148,7 +146,6 @@ struct audio_driver {
int max_voices_in; int max_voices_in;
int voice_size_out; int voice_size_out;
int voice_size_in; int voice_size_in;
int ctl_caps;
QLIST_ENTRY(audio_driver) next; QLIST_ENTRY(audio_driver) next;
}; };
@ -168,14 +165,16 @@ struct audio_pcm_ops {
* size may be smaller * size may be smaller
*/ */
size_t (*put_buffer_out)(HWVoiceOut *hw, void *buf, size_t size); size_t (*put_buffer_out)(HWVoiceOut *hw, void *buf, size_t size);
int (*ctl_out) (HWVoiceOut *hw, int cmd, ...); void (*enable_out)(HWVoiceOut *hw, bool enable);
void (*volume_out)(HWVoiceOut *hw, struct mixeng_volume *vol);
int (*init_in) (HWVoiceIn *hw, audsettings *as, void *drv_opaque); int (*init_in) (HWVoiceIn *hw, audsettings *as, void *drv_opaque);
void (*fini_in) (HWVoiceIn *hw); void (*fini_in) (HWVoiceIn *hw);
size_t (*read) (HWVoiceIn *hw, void *buf, size_t size); size_t (*read) (HWVoiceIn *hw, void *buf, size_t size);
void *(*get_buffer_in)(HWVoiceIn *hw, size_t *size); void *(*get_buffer_in)(HWVoiceIn *hw, size_t *size);
void (*put_buffer_in)(HWVoiceIn *hw, void *buf, size_t size); void (*put_buffer_in)(HWVoiceIn *hw, void *buf, size_t size);
int (*ctl_in) (HWVoiceIn *hw, int cmd, ...); void (*enable_in)(HWVoiceIn *hw, bool enable);
void (*volume_in)(HWVoiceIn *hw, struct mixeng_volume *vol);
}; };
void *audio_generic_get_buffer_in(HWVoiceIn *hw, size_t *size); void *audio_generic_get_buffer_in(HWVoiceIn *hw, size_t *size);
@ -251,12 +250,6 @@ void audio_rate_start(RateCtl *rate);
size_t audio_rate_get_bytes(struct audio_pcm_info *info, RateCtl *rate, size_t audio_rate_get_bytes(struct audio_pcm_info *info, RateCtl *rate,
size_t bytes_avail); size_t bytes_avail);
#define VOICE_ENABLE 1
#define VOICE_DISABLE 2
#define VOICE_VOLUME 3
#define VOICE_VOLUME_CAP (1 << VOICE_VOLUME)
static inline size_t audio_ring_dist(size_t dst, size_t src, size_t len) static inline size_t audio_ring_dist(size_t dst, size_t src, size_t len)
{ {
return (dst >= src) ? (dst - src) : (len - src + dst); return (dst >= src) ? (dst - src) : (len - src + dst);

View file

@ -254,7 +254,6 @@ static HW *glue(audio_pcm_hw_add_new_, TYPE)(AudioState *s,
hw->s = s; hw->s = s;
hw->pcm_ops = drv->pcm_ops; hw->pcm_ops = drv->pcm_ops;
hw->ctl_caps = drv->ctl_caps;
QLIST_INIT (&hw->sw_head); QLIST_INIT (&hw->sw_head);
#ifdef DAC #ifdef DAC

View file

@ -648,13 +648,12 @@ static void coreaudio_fini_out (HWVoiceOut *hw)
} }
} }
static int coreaudio_ctl_out (HWVoiceOut *hw, int cmd, ...) static void coreaudio_enable_out(HWVoiceOut *hw, bool enable)
{ {
OSStatus status; OSStatus status;
coreaudioVoiceOut *core = (coreaudioVoiceOut *) hw; coreaudioVoiceOut *core = (coreaudioVoiceOut *) hw;
switch (cmd) { if (enable) {
case VOICE_ENABLE:
/* start playback */ /* start playback */
if (!isPlaying(core->outputDeviceID)) { if (!isPlaying(core->outputDeviceID)) {
status = AudioDeviceStart(core->outputDeviceID, core->ioprocid); status = AudioDeviceStart(core->outputDeviceID, core->ioprocid);
@ -662,9 +661,7 @@ static int coreaudio_ctl_out (HWVoiceOut *hw, int cmd, ...)
coreaudio_logerr (status, "Could not resume playback\n"); coreaudio_logerr (status, "Could not resume playback\n");
} }
} }
break; } else {
case VOICE_DISABLE:
/* stop playback */ /* stop playback */
if (!audio_is_cleaning_up()) { if (!audio_is_cleaning_up()) {
if (isPlaying(core->outputDeviceID)) { if (isPlaying(core->outputDeviceID)) {
@ -675,9 +672,7 @@ static int coreaudio_ctl_out (HWVoiceOut *hw, int cmd, ...)
} }
} }
} }
break;
} }
return 0;
} }
static void *coreaudio_audio_init(Audiodev *dev) static void *coreaudio_audio_init(Audiodev *dev)
@ -695,7 +690,7 @@ static struct audio_pcm_ops coreaudio_pcm_ops = {
.write = coreaudio_write, .write = coreaudio_write,
.get_buffer_out = coreaudio_get_buffer_out, .get_buffer_out = coreaudio_get_buffer_out,
.put_buffer_out = coreaudio_put_buffer_out_nowrite, .put_buffer_out = coreaudio_put_buffer_out_nowrite,
.ctl_out = coreaudio_ctl_out .enable_out = coreaudio_enable_out
}; };
static struct audio_driver coreaudio_audio_driver = { static struct audio_driver coreaudio_audio_driver = {

View file

@ -361,7 +361,7 @@ static int dsound_open (dsound *s)
return 0; return 0;
} }
static int dsound_ctl_out (HWVoiceOut *hw, int cmd, ...) static void dsound_enable_out(HWVoiceOut *hw, bool enable)
{ {
HRESULT hr; HRESULT hr;
DWORD status; DWORD status;
@ -371,18 +371,17 @@ static int dsound_ctl_out (HWVoiceOut *hw, int cmd, ...)
if (!dsb) { if (!dsb) {
dolog ("Attempt to control voice without a buffer\n"); dolog ("Attempt to control voice without a buffer\n");
return 0; return;
} }
switch (cmd) { if (enable) {
case VOICE_ENABLE:
if (dsound_get_status_out (dsb, &status, s)) { if (dsound_get_status_out (dsb, &status, s)) {
return -1; return;
} }
if (status & DSBSTATUS_PLAYING) { if (status & DSBSTATUS_PLAYING) {
dolog ("warning: Voice is already playing\n"); dolog ("warning: Voice is already playing\n");
return 0; return;
} }
dsound_clear_sample (hw, dsb, s); dsound_clear_sample (hw, dsb, s);
@ -390,28 +389,24 @@ static int dsound_ctl_out (HWVoiceOut *hw, int cmd, ...)
hr = IDirectSoundBuffer_Play (dsb, 0, 0, DSBPLAY_LOOPING); hr = IDirectSoundBuffer_Play (dsb, 0, 0, DSBPLAY_LOOPING);
if (FAILED (hr)) { if (FAILED (hr)) {
dsound_logerr (hr, "Could not start playing buffer\n"); dsound_logerr (hr, "Could not start playing buffer\n");
return -1; return;
} }
break; } else {
case VOICE_DISABLE:
if (dsound_get_status_out (dsb, &status, s)) { if (dsound_get_status_out (dsb, &status, s)) {
return -1; return;
} }
if (status & DSBSTATUS_PLAYING) { if (status & DSBSTATUS_PLAYING) {
hr = IDirectSoundBuffer_Stop (dsb); hr = IDirectSoundBuffer_Stop (dsb);
if (FAILED (hr)) { if (FAILED (hr)) {
dsound_logerr (hr, "Could not stop playing buffer\n"); dsound_logerr (hr, "Could not stop playing buffer\n");
return -1; return;
} }
} }
else { else {
dolog ("warning: Voice is not playing\n"); dolog ("warning: Voice is not playing\n");
} }
break;
} }
return 0;
} }
static void *dsound_get_buffer_out(HWVoiceOut *hw, size_t *size) static void *dsound_get_buffer_out(HWVoiceOut *hw, size_t *size)
@ -461,7 +456,7 @@ static size_t dsound_put_buffer_out(HWVoiceOut *hw, void *buf, size_t len)
return len; return len;
} }
static int dsound_ctl_in (HWVoiceIn *hw, int cmd, ...) static void dsound_enable_in(HWVoiceIn *hw, bool enable)
{ {
HRESULT hr; HRESULT hr;
DWORD status; DWORD status;
@ -470,18 +465,17 @@ static int dsound_ctl_in (HWVoiceIn *hw, int cmd, ...)
if (!dscb) { if (!dscb) {
dolog ("Attempt to control capture voice without a buffer\n"); dolog ("Attempt to control capture voice without a buffer\n");
return -1; return;
} }
switch (cmd) { if (enable) {
case VOICE_ENABLE:
if (dsound_get_status_in (dscb, &status)) { if (dsound_get_status_in (dscb, &status)) {
return -1; return;
} }
if (status & DSCBSTATUS_CAPTURING) { if (status & DSCBSTATUS_CAPTURING) {
dolog ("warning: Voice is already capturing\n"); dolog ("warning: Voice is already capturing\n");
return 0; return;
} }
/* clear ?? */ /* clear ?? */
@ -489,28 +483,24 @@ static int dsound_ctl_in (HWVoiceIn *hw, int cmd, ...)
hr = IDirectSoundCaptureBuffer_Start (dscb, DSCBSTART_LOOPING); hr = IDirectSoundCaptureBuffer_Start (dscb, DSCBSTART_LOOPING);
if (FAILED (hr)) { if (FAILED (hr)) {
dsound_logerr (hr, "Could not start capturing\n"); dsound_logerr (hr, "Could not start capturing\n");
return -1; return;
} }
break; } else {
case VOICE_DISABLE:
if (dsound_get_status_in (dscb, &status)) { if (dsound_get_status_in (dscb, &status)) {
return -1; return;
} }
if (status & DSCBSTATUS_CAPTURING) { if (status & DSCBSTATUS_CAPTURING) {
hr = IDirectSoundCaptureBuffer_Stop (dscb); hr = IDirectSoundCaptureBuffer_Stop (dscb);
if (FAILED (hr)) { if (FAILED (hr)) {
dsound_logerr (hr, "Could not stop capturing\n"); dsound_logerr (hr, "Could not stop capturing\n");
return -1; return;
} }
} }
else { else {
dolog ("warning: Voice is not capturing\n"); dolog ("warning: Voice is not capturing\n");
} }
break;
} }
return 0;
} }
static void *dsound_get_buffer_in(HWVoiceIn *hw, size_t *size) static void *dsound_get_buffer_in(HWVoiceIn *hw, size_t *size)
@ -674,14 +664,14 @@ static struct audio_pcm_ops dsound_pcm_ops = {
.write = audio_generic_write, .write = audio_generic_write,
.get_buffer_out = dsound_get_buffer_out, .get_buffer_out = dsound_get_buffer_out,
.put_buffer_out = dsound_put_buffer_out, .put_buffer_out = dsound_put_buffer_out,
.ctl_out = dsound_ctl_out, .enable_out = dsound_enable_out,
.init_in = dsound_init_in, .init_in = dsound_init_in,
.fini_in = dsound_fini_in, .fini_in = dsound_fini_in,
.read = audio_generic_read, .read = audio_generic_read,
.get_buffer_in = dsound_get_buffer_in, .get_buffer_in = dsound_get_buffer_in,
.put_buffer_in = dsound_put_buffer_in, .put_buffer_in = dsound_put_buffer_in,
.ctl_in = dsound_ctl_in .enable_in = dsound_enable_in,
}; };
static struct audio_driver dsound_audio_driver = { static struct audio_driver dsound_audio_driver = {

View file

@ -62,14 +62,13 @@ static void no_fini_out (HWVoiceOut *hw)
(void) hw; (void) hw;
} }
static int no_ctl_out (HWVoiceOut *hw, int cmd, ...) static void no_enable_out(HWVoiceOut *hw, bool enable)
{ {
NoVoiceOut *no = (NoVoiceOut *) hw; NoVoiceOut *no = (NoVoiceOut *) hw;
if (cmd == VOICE_ENABLE) { if (enable) {
audio_rate_start(&no->rate); audio_rate_start(&no->rate);
} }
return 0;
} }
static int no_init_in(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque) static int no_init_in(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque)
@ -96,14 +95,13 @@ static size_t no_read(HWVoiceIn *hw, void *buf, size_t size)
return bytes; return bytes;
} }
static int no_ctl_in (HWVoiceIn *hw, int cmd, ...) static void no_enable_in(HWVoiceIn *hw, bool enable)
{ {
NoVoiceIn *no = (NoVoiceIn *) hw; NoVoiceIn *no = (NoVoiceIn *) hw;
if (cmd == VOICE_ENABLE) { if (enable) {
audio_rate_start(&no->rate); audio_rate_start(&no->rate);
} }
return 0;
} }
static void *no_audio_init(Audiodev *dev) static void *no_audio_init(Audiodev *dev)
@ -120,12 +118,12 @@ static struct audio_pcm_ops no_pcm_ops = {
.init_out = no_init_out, .init_out = no_init_out,
.fini_out = no_fini_out, .fini_out = no_fini_out,
.write = no_write, .write = no_write,
.ctl_out = no_ctl_out, .enable_out = no_enable_out,
.init_in = no_init_in, .init_in = no_init_in,
.fini_in = no_fini_in, .fini_in = no_fini_in,
.read = no_read, .read = no_read,
.ctl_in = no_ctl_in .enable_in = no_enable_in
}; };
static struct audio_driver no_audio_driver = { static struct audio_driver no_audio_driver = {

View file

@ -563,60 +563,50 @@ static int oss_init_out(HWVoiceOut *hw, struct audsettings *as,
return 0; return 0;
} }
static int oss_ctl_out (HWVoiceOut *hw, int cmd, ...) static void oss_enable_out(HWVoiceOut *hw, bool enable)
{ {
int trig; int trig;
OSSVoiceOut *oss = (OSSVoiceOut *) hw; OSSVoiceOut *oss = (OSSVoiceOut *) hw;
AudiodevOssPerDirectionOptions *opdo = oss->dev->u.oss.out; AudiodevOssPerDirectionOptions *opdo = oss->dev->u.oss.out;
switch (cmd) { if (enable) {
case VOICE_ENABLE: bool poll_mode = opdo->try_poll;
{
bool poll_mode = opdo->try_poll;
ldebug ("enabling voice\n"); ldebug("enabling voice\n");
if (poll_mode) { if (poll_mode) {
oss_poll_out (hw); oss_poll_out(hw);
poll_mode = 0; poll_mode = 0;
}
hw->poll_mode = poll_mode;
if (!oss->mmapped) {
return 0;
}
audio_pcm_info_clear_buf(
&hw->info, hw->buf_emul, hw->mix_buf->size);
trig = PCM_ENABLE_OUTPUT;
if (ioctl (oss->fd, SNDCTL_DSP_SETTRIGGER, &trig) < 0) {
oss_logerr (
errno,
"SNDCTL_DSP_SETTRIGGER PCM_ENABLE_OUTPUT failed\n"
);
return -1;
}
} }
break; hw->poll_mode = poll_mode;
case VOICE_DISABLE: if (!oss->mmapped) {
return;
}
audio_pcm_info_clear_buf(&hw->info, hw->buf_emul, hw->mix_buf->size);
trig = PCM_ENABLE_OUTPUT;
if (ioctl(oss->fd, SNDCTL_DSP_SETTRIGGER, &trig) < 0) {
oss_logerr(errno,
"SNDCTL_DSP_SETTRIGGER PCM_ENABLE_OUTPUT failed\n");
return;
}
} else {
if (hw->poll_mode) { if (hw->poll_mode) {
qemu_set_fd_handler (oss->fd, NULL, NULL, NULL); qemu_set_fd_handler (oss->fd, NULL, NULL, NULL);
hw->poll_mode = 0; hw->poll_mode = 0;
} }
if (!oss->mmapped) { if (!oss->mmapped) {
return 0; return;
} }
ldebug ("disabling voice\n"); ldebug ("disabling voice\n");
trig = 0; trig = 0;
if (ioctl (oss->fd, SNDCTL_DSP_SETTRIGGER, &trig) < 0) { if (ioctl (oss->fd, SNDCTL_DSP_SETTRIGGER, &trig) < 0) {
oss_logerr (errno, "SNDCTL_DSP_SETTRIGGER 0 failed\n"); oss_logerr (errno, "SNDCTL_DSP_SETTRIGGER 0 failed\n");
return -1; return;
} }
break;
} }
return 0;
} }
static int oss_init_in(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque) static int oss_init_in(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque)
@ -703,32 +693,25 @@ static size_t oss_read(HWVoiceIn *hw, void *buf, size_t len)
return pos; return pos;
} }
static int oss_ctl_in (HWVoiceIn *hw, int cmd, ...) static void oss_enable_in(HWVoiceIn *hw, bool enable)
{ {
OSSVoiceIn *oss = (OSSVoiceIn *) hw; OSSVoiceIn *oss = (OSSVoiceIn *) hw;
AudiodevOssPerDirectionOptions *opdo = oss->dev->u.oss.out; AudiodevOssPerDirectionOptions *opdo = oss->dev->u.oss.out;
switch (cmd) { if (enable) {
case VOICE_ENABLE: bool poll_mode = opdo->try_poll;
{
bool poll_mode = opdo->try_poll;
if (poll_mode) { if (poll_mode) {
oss_poll_in (hw); oss_poll_in(hw);
poll_mode = 0; poll_mode = 0;
}
hw->poll_mode = poll_mode;
} }
break; hw->poll_mode = poll_mode;
} else {
case VOICE_DISABLE:
if (hw->poll_mode) { if (hw->poll_mode) {
hw->poll_mode = 0; hw->poll_mode = 0;
qemu_set_fd_handler (oss->fd, NULL, NULL, NULL); qemu_set_fd_handler (oss->fd, NULL, NULL, NULL);
} }
break;
} }
return 0;
} }
static void oss_init_per_direction(AudiodevOssPerDirectionOptions *opdo) static void oss_init_per_direction(AudiodevOssPerDirectionOptions *opdo)
@ -767,12 +750,12 @@ static struct audio_pcm_ops oss_pcm_ops = {
.write = oss_write, .write = oss_write,
.get_buffer_out = oss_get_buffer_out, .get_buffer_out = oss_get_buffer_out,
.put_buffer_out = oss_put_buffer_out, .put_buffer_out = oss_put_buffer_out,
.ctl_out = oss_ctl_out, .enable_out = oss_enable_out,
.init_in = oss_init_in, .init_in = oss_init_in,
.fini_in = oss_fini_in, .fini_in = oss_fini_in,
.read = oss_read, .read = oss_read,
.ctl_in = oss_ctl_in .enable_in = oss_enable_in
}; };
static struct audio_driver oss_audio_driver = { static struct audio_driver oss_audio_driver = {

View file

@ -452,7 +452,7 @@ static void qpa_fini_in (HWVoiceIn *hw)
} }
} }
static int qpa_ctl_out (HWVoiceOut *hw, int cmd, ...) static void qpa_volume_out(HWVoiceOut *hw, struct mixeng_volume *vol)
{ {
PAVoiceOut *pa = (PAVoiceOut *) hw; PAVoiceOut *pa = (PAVoiceOut *) hw;
pa_operation *op; pa_operation *op;
@ -463,49 +463,36 @@ static int qpa_ctl_out (HWVoiceOut *hw, int cmd, ...)
pa_cvolume_init (&v); /* function is present in 0.9.13+ */ pa_cvolume_init (&v); /* function is present in 0.9.13+ */
#endif #endif
switch (cmd) { v.channels = 2;
case VOICE_VOLUME: v.values[0] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * vol->l) / UINT32_MAX;
{ v.values[1] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * vol->r) / UINT32_MAX;
SWVoiceOut *sw;
va_list ap;
va_start (ap, cmd); pa_threaded_mainloop_lock(c->mainloop);
sw = va_arg (ap, SWVoiceOut *);
va_end (ap);
v.channels = 2; op = pa_context_set_sink_input_volume(c->context,
v.values[0] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * sw->vol.l) / UINT32_MAX; pa_stream_get_index(pa->stream),
v.values[1] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * sw->vol.r) / UINT32_MAX; &v, NULL, NULL);
if (!op) {
pa_threaded_mainloop_lock(c->mainloop); qpa_logerr(pa_context_errno(c->context),
"set_sink_input_volume() failed\n");
op = pa_context_set_sink_input_volume(c->context, } else {
pa_stream_get_index (pa->stream), pa_operation_unref(op);
&v, NULL, NULL);
if (!op) {
qpa_logerr(pa_context_errno(c->context),
"set_sink_input_volume() failed\n");
} else {
pa_operation_unref(op);
}
op = pa_context_set_sink_input_mute(c->context,
pa_stream_get_index (pa->stream),
sw->vol.mute, NULL, NULL);
if (!op) {
qpa_logerr(pa_context_errno(c->context),
"set_sink_input_mute() failed\n");
} else {
pa_operation_unref(op);
}
pa_threaded_mainloop_unlock(c->mainloop);
}
} }
return 0;
op = pa_context_set_sink_input_mute(c->context,
pa_stream_get_index(pa->stream),
vol->mute, NULL, NULL);
if (!op) {
qpa_logerr(pa_context_errno(c->context),
"set_sink_input_mute() failed\n");
} else {
pa_operation_unref(op);
}
pa_threaded_mainloop_unlock(c->mainloop);
} }
static int qpa_ctl_in (HWVoiceIn *hw, int cmd, ...) static void qpa_volume_in(HWVoiceIn *hw, struct mixeng_volume *vol)
{ {
PAVoiceIn *pa = (PAVoiceIn *) hw; PAVoiceIn *pa = (PAVoiceIn *) hw;
pa_operation *op; pa_operation *op;
@ -516,46 +503,33 @@ static int qpa_ctl_in (HWVoiceIn *hw, int cmd, ...)
pa_cvolume_init (&v); pa_cvolume_init (&v);
#endif #endif
switch (cmd) { v.channels = 2;
case VOICE_VOLUME: v.values[0] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * vol->l) / UINT32_MAX;
{ v.values[1] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * vol->r) / UINT32_MAX;
SWVoiceIn *sw;
va_list ap;
va_start (ap, cmd); pa_threaded_mainloop_lock(c->mainloop);
sw = va_arg (ap, SWVoiceIn *);
va_end (ap);
v.channels = 2; op = pa_context_set_source_output_volume(c->context,
v.values[0] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * sw->vol.l) / UINT32_MAX; pa_stream_get_index(pa->stream),
v.values[1] = ((PA_VOLUME_NORM - PA_VOLUME_MUTED) * sw->vol.r) / UINT32_MAX; &v, NULL, NULL);
if (!op) {
pa_threaded_mainloop_lock(c->mainloop); qpa_logerr(pa_context_errno(c->context),
"set_source_output_volume() failed\n");
op = pa_context_set_source_output_volume(c->context, } else {
pa_stream_get_index(pa->stream), pa_operation_unref(op);
&v, NULL, NULL);
if (!op) {
qpa_logerr(pa_context_errno(c->context),
"set_source_output_volume() failed\n");
} else {
pa_operation_unref(op);
}
op = pa_context_set_source_output_mute(c->context,
pa_stream_get_index (pa->stream),
sw->vol.mute, NULL, NULL);
if (!op) {
qpa_logerr(pa_context_errno(c->context),
"set_source_output_mute() failed\n");
} else {
pa_operation_unref (op);
}
pa_threaded_mainloop_unlock(c->mainloop);
}
} }
return 0;
op = pa_context_set_source_output_mute(c->context,
pa_stream_get_index(pa->stream),
vol->mute, NULL, NULL);
if (!op) {
qpa_logerr(pa_context_errno(c->context),
"set_source_output_mute() failed\n");
} else {
pa_operation_unref(op);
}
pa_threaded_mainloop_unlock(c->mainloop);
} }
static int qpa_validate_per_direction_opts(Audiodev *dev, static int qpa_validate_per_direction_opts(Audiodev *dev,
@ -724,12 +698,12 @@ static struct audio_pcm_ops qpa_pcm_ops = {
.init_out = qpa_init_out, .init_out = qpa_init_out,
.fini_out = qpa_fini_out, .fini_out = qpa_fini_out,
.write = qpa_write, .write = qpa_write,
.ctl_out = qpa_ctl_out, .volume_out = qpa_volume_out,
.init_in = qpa_init_in, .init_in = qpa_init_in,
.fini_in = qpa_fini_in, .fini_in = qpa_fini_in,
.read = qpa_read, .read = qpa_read,
.ctl_in = qpa_ctl_in .volume_in = qpa_volume_in
}; };
static struct audio_driver pa_audio_driver = { static struct audio_driver pa_audio_driver = {
@ -743,7 +717,6 @@ static struct audio_driver pa_audio_driver = {
.max_voices_in = INT_MAX, .max_voices_in = INT_MAX,
.voice_size_out = sizeof (PAVoiceOut), .voice_size_out = sizeof (PAVoiceOut),
.voice_size_in = sizeof (PAVoiceIn), .voice_size_in = sizeof (PAVoiceIn),
.ctl_caps = VOICE_VOLUME_CAP
}; };
static void register_audio_pa(void) static void register_audio_pa(void)

View file

@ -285,20 +285,9 @@ static int sdl_init_out(HWVoiceOut *hw, struct audsettings *as,
return 0; return 0;
} }
static int sdl_ctl_out (HWVoiceOut *hw, int cmd, ...) static void sdl_enable_out(HWVoiceOut *hw, bool enable)
{ {
(void) hw; SDL_PauseAudio(!enable);
switch (cmd) {
case VOICE_ENABLE:
SDL_PauseAudio (0);
break;
case VOICE_DISABLE:
SDL_PauseAudio (1);
break;
}
return 0;
} }
static void *sdl_audio_init(Audiodev *dev) static void *sdl_audio_init(Audiodev *dev)
@ -334,7 +323,7 @@ static struct audio_pcm_ops sdl_pcm_ops = {
.write = sdl_write, .write = sdl_write,
.get_buffer_out = sdl_get_buffer_out, .get_buffer_out = sdl_get_buffer_out,
.put_buffer_out = sdl_put_buffer_out_nowrite, .put_buffer_out = sdl_put_buffer_out_nowrite,
.ctl_out = sdl_ctl_out, .enable_out = sdl_enable_out,
}; };
static struct audio_driver sdl_audio_driver = { static struct audio_driver sdl_audio_driver = {

View file

@ -153,22 +153,20 @@ static size_t line_out_put_buffer(HWVoiceOut *hw, void *buf, size_t size)
return size; return size;
} }
static int line_out_ctl (HWVoiceOut *hw, int cmd, ...) static void line_out_enable(HWVoiceOut *hw, bool enable)
{ {
SpiceVoiceOut *out = container_of (hw, SpiceVoiceOut, hw); SpiceVoiceOut *out = container_of (hw, SpiceVoiceOut, hw);
switch (cmd) { if (enable) {
case VOICE_ENABLE:
if (out->active) { if (out->active) {
break; return;
} }
out->active = 1; out->active = 1;
audio_rate_start(&out->rate); audio_rate_start(&out->rate);
spice_server_playback_start (&out->sin); spice_server_playback_start (&out->sin);
break; } else {
case VOICE_DISABLE:
if (!out->active) { if (!out->active) {
break; return;
} }
out->active = 0; out->active = 0;
if (out->frame) { if (out->frame) {
@ -177,30 +175,22 @@ static int line_out_ctl (HWVoiceOut *hw, int cmd, ...)
out->frame = NULL; out->frame = NULL;
} }
spice_server_playback_stop (&out->sin); spice_server_playback_stop (&out->sin);
break;
case VOICE_VOLUME:
{
#if ((SPICE_INTERFACE_PLAYBACK_MAJOR >= 1) && (SPICE_INTERFACE_PLAYBACK_MINOR >= 2))
SWVoiceOut *sw;
va_list ap;
uint16_t vol[2];
va_start (ap, cmd);
sw = va_arg (ap, SWVoiceOut *);
va_end (ap);
vol[0] = sw->vol.l / ((1ULL << 16) + 1);
vol[1] = sw->vol.r / ((1ULL << 16) + 1);
spice_server_playback_set_volume (&out->sin, 2, vol);
spice_server_playback_set_mute (&out->sin, sw->vol.mute);
#endif
break;
}
} }
return 0;
} }
#if ((SPICE_INTERFACE_PLAYBACK_MAJOR >= 1) && (SPICE_INTERFACE_PLAYBACK_MINOR >= 2))
static void line_out_volume(HWVoiceOut *hw, struct mixeng_volume *vol)
{
SpiceVoiceOut *out = container_of(hw, SpiceVoiceOut, hw);
uint16_t svol[2];
svol[0] = vol->l / ((1ULL << 16) + 1);
svol[1] = vol->r / ((1ULL << 16) + 1);
spice_server_playback_set_volume(&out->sin, 2, svol);
spice_server_playback_set_mute(&out->sin, vol->mute);
}
#endif
/* record */ /* record */
static int line_in_init(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque) static int line_in_init(HWVoiceIn *hw, struct audsettings *as, void *drv_opaque)
@ -251,61 +241,58 @@ static size_t line_in_read(HWVoiceIn *hw, void *buf, size_t len)
return ready << 2; return ready << 2;
} }
static int line_in_ctl (HWVoiceIn *hw, int cmd, ...) static void line_in_enable(HWVoiceIn *hw, bool enable)
{ {
SpiceVoiceIn *in = container_of (hw, SpiceVoiceIn, hw); SpiceVoiceIn *in = container_of (hw, SpiceVoiceIn, hw);
switch (cmd) { if (enable) {
case VOICE_ENABLE:
if (in->active) { if (in->active) {
break; return;
} }
in->active = 1; in->active = 1;
audio_rate_start(&in->rate); audio_rate_start(&in->rate);
spice_server_record_start (&in->sin); spice_server_record_start (&in->sin);
break; } else {
case VOICE_DISABLE:
if (!in->active) { if (!in->active) {
break; return;
} }
in->active = 0; in->active = 0;
spice_server_record_stop (&in->sin); spice_server_record_stop (&in->sin);
break;
case VOICE_VOLUME:
{
#if ((SPICE_INTERFACE_RECORD_MAJOR >= 2) && (SPICE_INTERFACE_RECORD_MINOR >= 2))
SWVoiceIn *sw;
va_list ap;
uint16_t vol[2];
va_start (ap, cmd);
sw = va_arg (ap, SWVoiceIn *);
va_end (ap);
vol[0] = sw->vol.l / ((1ULL << 16) + 1);
vol[1] = sw->vol.r / ((1ULL << 16) + 1);
spice_server_record_set_volume (&in->sin, 2, vol);
spice_server_record_set_mute (&in->sin, sw->vol.mute);
#endif
break;
}
} }
return 0;
} }
#if ((SPICE_INTERFACE_RECORD_MAJOR >= 2) && (SPICE_INTERFACE_RECORD_MINOR >= 2))
static void line_in_volume(HWVoiceIn *hw, struct mixeng_volume *vol)
{
SpiceVoiceIn *in = container_of(hw, SpiceVoiceIn, hw);
uint16_t svol[2];
svol[0] = vol->l / ((1ULL << 16) + 1);
svol[1] = vol->r / ((1ULL << 16) + 1);
spice_server_record_set_volume(&in->sin, 2, svol);
spice_server_record_set_mute(&in->sin, vol->mute);
}
#endif
static struct audio_pcm_ops audio_callbacks = { static struct audio_pcm_ops audio_callbacks = {
.init_out = line_out_init, .init_out = line_out_init,
.fini_out = line_out_fini, .fini_out = line_out_fini,
.write = audio_generic_write, .write = audio_generic_write,
.get_buffer_out = line_out_get_buffer, .get_buffer_out = line_out_get_buffer,
.put_buffer_out = line_out_put_buffer, .put_buffer_out = line_out_put_buffer,
.ctl_out = line_out_ctl, .enable_out = line_out_enable,
#if (SPICE_INTERFACE_PLAYBACK_MAJOR >= 1) && \
(SPICE_INTERFACE_PLAYBACK_MINOR >= 2)
.volume_out = line_out_volume,
#endif
.init_in = line_in_init, .init_in = line_in_init,
.fini_in = line_in_fini, .fini_in = line_in_fini,
.read = line_in_read, .read = line_in_read,
.ctl_in = line_in_ctl, .enable_in = line_in_enable,
#if ((SPICE_INTERFACE_RECORD_MAJOR >= 2) && (SPICE_INTERFACE_RECORD_MINOR >= 2))
.volume_in = line_in_volume,
#endif
}; };
static struct audio_driver spice_audio_driver = { static struct audio_driver spice_audio_driver = {
@ -318,9 +305,6 @@ static struct audio_driver spice_audio_driver = {
.max_voices_in = 1, .max_voices_in = 1,
.voice_size_out = sizeof (SpiceVoiceOut), .voice_size_out = sizeof (SpiceVoiceOut),
.voice_size_in = sizeof (SpiceVoiceIn), .voice_size_in = sizeof (SpiceVoiceIn),
#if ((SPICE_INTERFACE_PLAYBACK_MAJOR >= 1) && (SPICE_INTERFACE_PLAYBACK_MINOR >= 2))
.ctl_caps = VOICE_VOLUME_CAP
#endif
}; };
void qemu_spice_audio_init (void) void qemu_spice_audio_init (void)

View file

@ -173,14 +173,13 @@ static void wav_fini_out (HWVoiceOut *hw)
wav->f = NULL; wav->f = NULL;
} }
static int wav_ctl_out (HWVoiceOut *hw, int cmd, ...) static void wav_enable_out(HWVoiceOut *hw, bool enable)
{ {
WAVVoiceOut *wav = (WAVVoiceOut *) hw; WAVVoiceOut *wav = (WAVVoiceOut *) hw;
if (cmd == VOICE_ENABLE) { if (enable) {
audio_rate_start(&wav->rate); audio_rate_start(&wav->rate);
} }
return 0;
} }
static void *wav_audio_init(Audiodev *dev) static void *wav_audio_init(Audiodev *dev)
@ -198,7 +197,7 @@ static struct audio_pcm_ops wav_pcm_ops = {
.init_out = wav_init_out, .init_out = wav_init_out,
.fini_out = wav_fini_out, .fini_out = wav_fini_out,
.write = wav_write_out, .write = wav_write_out,
.ctl_out = wav_ctl_out, .enable_out = wav_enable_out,
}; };
static struct audio_driver wav_audio_driver = { static struct audio_driver wav_audio_driver = {