Differential D11039 Diff 29187 devel/allegro/files/sndio.c

Changeset View

Standalone View

devel/allegro/files/sndio.c

This file was added.

Property	Old Value	New Value
fbsd:nokeywords	null	yes \ No newline at end of property
svn:eol-style	null	native \ No newline at end of property
svn:mime-type	null	text/plain \ No newline at end of property

				/*
				* Copyright (c) 2010 Jacob Meuser <jakemsr@sdf.lonestar.org>
				*
				* Permission to use, copy, modify, and distribute this software for any
				* purpose with or without fee is hereby granted, provided that the above
				* copyright notice and this permission notice appear in all copies.
				*
				* THE SOFTWARE IS PROVIDED "AS IS" AND THE AUTHOR DISCLAIMS ALL WARRANTIES
				* WITH REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF
				* MERCHANTABILITY AND FITNESS. IN NO EVENT SHALL THE AUTHOR BE LIABLE FOR
				* ANY SPECIAL, DIRECT, INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES
				* WHATSOEVER RESULTING FROM LOSS OF USE, DATA OR PROFITS, WHETHER IN AN
				* ACTION OF CONTRACT, NEGLIGENCE OR OTHER TORTIOUS ACTION, ARISING OUT OF
				* OR IN CONNECTION WITH THE USE OR PERFORMANCE OF THIS SOFTWARE.
				*/


				#include "allegro.h"

				#if (defined ALLEGRO_WITH_SNDIODIGI) && ((!defined ALLEGRO_WITH_MODULES) \|\| (defined ALLEGRO_MODULE))

				#include "allegro/internal/aintern.h"
				#include "allegro/platform/aintunix.h"

				#include <stdlib.h>
				#include <stdio.h>
				#include <limits.h>
				#include <unistd.h>
				#include <poll.h>
				#include <sndio.h>

				static int sndio_detect(int input);
				static int sndio_init(int input, int voices);
				static void sndio_exit(int input);
				static int sndio_set_mixer_volume(int volume);
				static int sndio_get_mixer_volume(void);

				static int sndio_buffer_size(void);

				static int sndio_rec_cap_rate(int bits, int stereo);
				static int sndio_rec_cap_parm(int rate, int bits, int stereo);
				static int sndio_rec_source(int source);
				static int sndio_rec_start(int rate, int bits, int stereo);
				static void sndio_rec_stop(void);
				static int sndio_rec_read(void *buf);

				static int open_sndio_device(int input);
				static void sndio_update(int threaded);
				static void movecb(void *addr, int delta);
				static void volcb(void *addr, unsigned vol);

				static struct sio_hdl *hdl;
				static struct sio_par par;
				static int sndio_signed;
				static int sndio_play_bufsize, sndio_play_round, sndio_play_appbufsz;
				static unsigned char *sndio_play_bufdata;
				static char sndio_desc[256] = EMPTY_STRING;
				long long sndio_realpos, sndio_playpos;
				int sndio_volume;

				static int sndio_save_bits, sndio_save_stereo, sndio_save_freq;
				static int sndio_rec_bufsize, sndio_rec_round, sndio_rec_appbufsz;
				static unsigned char *sndio_rec_bufdata;

				DIGI_DRIVER digi_sndio =
				{
				DIGI_SNDIO,
				empty_string,
				empty_string,
				"sndio",
				0,
				0,
				MIXER_MAX_SFX,
				MIXER_DEF_SFX,

				/* setup routines */
				sndio_detect,
				sndio_init,
				sndio_exit,
				sndio_set_mixer_volume,
				sndio_get_mixer_volume,

				/* for use by the audiostream functions */
				NULL,
				NULL,
				sndio_buffer_size,

				/* voice control functions */
				_mixer_init_voice,
				_mixer_release_voice,
				_mixer_start_voice,
				_mixer_stop_voice,
				_mixer_loop_voice,

				/* position control functions */
				_mixer_get_position,
				_mixer_set_position,

				/* volume control functions */
				_mixer_get_volume,
				_mixer_set_volume,
				_mixer_ramp_volume,
				_mixer_stop_volume_ramp,

				/* pitch control functions */
				_mixer_get_frequency,
				_mixer_set_frequency,
				_mixer_sweep_frequency,
				_mixer_stop_frequency_sweep,

				/* pan control functions */
				_mixer_get_pan,
				_mixer_set_pan,
				_mixer_sweep_pan,
				_mixer_stop_pan_sweep,

				/* effect control functions */
				_mixer_set_echo,
				_mixer_set_tremolo,
				_mixer_set_vibrato,

				/* input functions */
				0,
				0,
				sndio_rec_cap_rate,
				sndio_rec_cap_parm,
				sndio_rec_source,
				sndio_rec_start,
				sndio_rec_stop,
				sndio_rec_read
				};


				/* used to probe and to configure the device. don't use sio_start() here. */
				static int
				open_sndio_device(int input)
				{
				hdl = sio_open(NULL, (input ? SIO_REC : SIO_PLAY), 0);
				if (hdl == NULL) {
				uszprintf(allegro_error, ALLEGRO_ERROR_SIZE,
				get_config_text("sio_opn failed"));
				return -1;
				}

				sio_initpar(&par);
				par.bits = (_sound_bits == 8) ? 8 : 16;
				par.sig = (_sound_bits == 8) ? 0 : 1;
				if (input)
				par.rchan = (_sound_stereo) ? 2 : 1;
				else
				par.pchan = (_sound_stereo) ? 2 : 1;
				par.rate = (_sound_freq > 0) ? _sound_freq : 48000;
				par.le = SIO_LE_NATIVE;
				/* allegro wants small blocks */
				par.round = 512;
				par.appbufsz = par.rate / 10;

				if (!sio_setpar(hdl, &par) \|\| !sio_getpar(hdl, &par) \|\|
				(par.bits != 8 && par.bits != 16) \|\|
				(par.bits == 8 && par.sig) \|\|
				(par.bits == 16 && !par.sig) \|\|
				(par.bits == 16 && par.le != SIO_LE_NATIVE) \|\|
				(input && (par.rchan != 1 && par.rchan != 2)) \|\|
				(!input && (par.pchan != 1 && par.pchan != 2))) {
				ustrzcpy(allegro_error, ALLEGRO_ERROR_SIZE,
				get_config_text("could not set sndio parameters"));
				sio_close(hdl);
				return -1;
				}

				_sound_bits = par.bits;
				_sound_stereo = input ? par.rchan == 2 : par.pchan == 2;
				_sound_freq = par.rate;

				if (input) {
				sndio_rec_round = par.round;
				sndio_rec_appbufsz = par.appbufsz;
				sndio_rec_bufsize = par.round * par.bps * par.rchan;
				} else {
				sndio_play_round = par.round;
				sndio_play_appbufsz = par.appbufsz;
				sndio_play_bufsize = sndio_play_round * par.bps * par.pchan;
				}
				sndio_signed = par.sig ? 1 : 0;

				return 0;
				}


				static int
				sndio_detect(int input)
				{
				if (input) {
				if (digi_driver != digi_input_driver) {
				ustrzcpy(allegro_error, ALLEGRO_ERROR_SIZE,
				get_config_text("sndio output driver must be installed before input can be read"));
				return FALSE;
				}
				return TRUE;
				}

				if (open_sndio_device(0) != 0)
				return FALSE;

				sio_close(hdl);
				return TRUE;
				}


				/* number of samples per channel in a block */
				static int
				sndio_buffer_size(void)
				{
				return sndio_play_round;
				}


				/* callback for data movement notification */
				static void
				movecb(void *addr, int delta)
				{
				sndio_realpos += delta;
				}


				/* callback for volume change notification */
				static void
				volcb(void *addr, unsigned vol)
				{
				sndio_volume = vol;
				}


				/* write as many blocks as is currently possible */
				static void
				sndio_update(int threaded)
				{
				struct pollfd pfd;
				nfds_t nfds;
				int i, nblocks, nbytes;

				/* make sure counters have been updated */
				nfds = sio_pollfd(hdl, &pfd, POLLOUT);
				poll(&pfd, nfds, 0);
				if (!(sio_revents(hdl, &pfd) & POLLOUT))
				return;

				nblocks = (sndio_play_appbufsz - (sndio_playpos - sndio_realpos)) /
				sndio_play_round;

				/* we got POLLOUT, so we can write something. if we don't
				* write anything, we could underrun.
				*/
				if (nblocks < 1)
				nblocks = 1;

				for (i = 0; i < nblocks; i++) {
				sio_write(hdl, sndio_play_bufdata, sndio_play_bufsize);
				sndio_playpos += sndio_play_round;
				if (sio_eof(hdl)) {
				/* print error message? */
				return;
				}
				_mix_some_samples((uintptr_t) sndio_play_bufdata, 0, sndio_signed);
				}
				}


				static int
				sndio_init(int input, int voices)
				{
				char tmp1[128], tmp2[128];

				if (input) {
				digi_driver->rec_cap_bits = 16;
				digi_driver->rec_cap_stereo = TRUE;
				return 0;
				}

				if (open_sndio_device(0) != 0)
				return -1;

				sndio_play_bufdata = _AL_MALLOC_ATOMIC(sndio_play_bufsize);
				if (sndio_play_bufdata == 0) {
				ustrzcpy(allegro_error, ALLEGRO_ERROR_SIZE,
				get_config_text("Can not allocate audio buffer"));
				sio_close(hdl);
				return -1;
				}

				sndio_realpos = sndio_playpos = 0;
				sio_onmove(hdl, movecb, NULL);

				sndio_volume = 127;
				sio_onvol(hdl, volcb, NULL);

				if (!sio_start(hdl)) {
				ustrzcpy(allegro_error, ALLEGRO_ERROR_SIZE,
				get_config_text("Can not start sndio"));
				sio_close(hdl);
				return -1;
				}

				digi_sndio.voices = voices;

				/* first arg is total number of samples */
				if (_mixer_init(sndio_play_round * (_sound_stereo ? 2 : 1),
				_sound_freq, _sound_stereo, ((_sound_bits == 16) ? 1 : 0),
				&digi_sndio.voices) != 0) {
				ustrzcpy(allegro_error, ALLEGRO_ERROR_SIZE,
				get_config_text("Can not init software mixer"));
				sio_close(hdl);
				return -1;
				}

				_mix_some_samples((uintptr_t) sndio_play_bufdata, 0, sndio_signed);

				/* Add audio interrupt. */
				_unix_bg_man->register_func(sndio_update);

				uszprintf(sndio_desc, sizeof(sndio_desc),
				get_config_text("%s: %d bits, %s, %d Hz, %s"),
				"sndio device",
				_sound_bits,
				uconvert_ascii((sndio_signed ? "signed" : "unsigned"), tmp1),
				_sound_freq,
				uconvert_ascii((par.pchan == 2 ? "stereo" : "mono"), tmp2));

				digi_driver->desc = sndio_desc;

				return 0;
				}


				static void
				sndio_exit(int input)
				{
				if (input)
				return;

				_unix_bg_man->unregister_func(sndio_update);

				_AL_FREE(sndio_play_bufdata);
				sndio_play_bufdata = 0;

				_mixer_exit();

				if (hdl != NULL)
				sio_close(hdl);
				hdl = NULL;
				}


				/* 'volume' is 0-255 */
				static int
				sndio_set_mixer_volume(int volume)
				{
				if (!sio_setvol(hdl, volume / 2))
				return -1;

				return 0;
				}


				/* should return 0-255 */
				static int
				sndio_get_mixer_volume(void)
				{
				return sndio_volume * 2;
				}


				/* Returns maximum recording sampling rate. */
				static int
				sndio_rec_cap_rate(int bits, int stereo)
				{
				/* should use sio_getcap() */
				return 48000;
				}


				/* Returns whether the specified parameters can be set. */
				static int
				sndio_rec_cap_parm(int rate, int bits, int stereo)
				{
				/* should use sio_getcap() */
				return 1;
				}


				/* Sets the sampling source for audio recording. */
				static int
				sndio_rec_source(int source)
				{
				/* not implemented in sndio */

				switch (source) {
				case SOUND_INPUT_MIC:
				break;
				case SOUND_INPUT_LINE:
				break;
				case SOUND_INPUT_CD:
				break;
				default:
				return -1;
				}

				return 0;
				}


				/*
				* Re-opens device with read-mode and starts recording (half-duplex).
				* Returns the DMA buffer size if successful.
				*/
				static int
				sndio_rec_start(int rate, int bits, int stereo)
				{
				sndio_save_bits = _sound_bits;
				sndio_save_stereo = _sound_stereo;
				sndio_save_freq = _sound_freq;

				_unix_bg_man->unregister_func(sndio_update);

				if (hdl != NULL)
				sio_close(hdl);
				hdl = NULL;

				_sound_bits = bits;
				_sound_stereo = stereo;
				_sound_freq = rate;

				if (open_sndio_device(1) != 0)
				return 0;

				sndio_volume = 127;
				sio_onvol(hdl, volcb, NULL);

				if (!sio_start(hdl)) {
				ustrzcpy(allegro_error, ALLEGRO_ERROR_SIZE,
				get_config_text("Can not start sndio for recording"));
				sio_close(hdl);
				return 0;
				}

				return sndio_rec_bufsize;
				}


				/* Stops recording and switches the device back to the original mode. */
				static void
				sndio_rec_stop(void)
				{
				if (hdl != NULL)
				sio_close(hdl);
				hdl = NULL;

				_sound_bits = sndio_save_bits;
				_sound_stereo = sndio_save_stereo;
				_sound_freq = sndio_save_freq;

				if (open_sndio_device(0) != 0)
				return;

				sndio_realpos = sndio_playpos = 0;
				sio_onmove(hdl, movecb, NULL);

				sndio_volume = 127;
				sio_onvol(hdl, volcb, NULL);

				if (!sio_start(hdl)) {
				ustrzcpy(allegro_error, ALLEGRO_ERROR_SIZE,
				get_config_text("Can not start sndio"));
				sio_close(hdl);
				return;
				}

				_unix_bg_man->register_func(sndio_update);
				}


				/* Retrieves the just recorded buffer, if there is one. */
				static int
				sndio_rec_read(void *buf)
				{
				struct pollfd pfd;
				nfds_t nfds;
				int ret, nbytes, offset = 0;

				/* make sure counters have been updated */
				nfds = sio_pollfd(hdl, &pfd, POLLIN);
				poll(&pfd, nfds, 0);
				sio_revents(hdl, &pfd);
				if (!(sio_revents(hdl, &pfd) & POLLIN))
				return 0;

				nbytes = sndio_rec_bufsize;
				while (nbytes) {
				ret = sio_read(hdl, buf + offset, nbytes);
				if (sio_eof(hdl))
				return 0;
				offset += ret;
				nbytes -= ret;
				}

				return 1;
				}

				#endif /* ALLEGRO_WITH_SNDIODIGI */