comparison src/alsa/audio.c @ 1727:9d6de95dd7ed

Clean up and rework xrun/suspend handling, and add myself to Copyright holders. Closes Ubuntu #123571.

1726:0a689ca43d7a

 *  Copyright (C) 2001-2003 Matthieu Sozeau <[e-mail]>
 *  Copyright (C) 1998-2003  Peter Alm, Mikael Alm, Olle Hallnas,
 *                           Thomas Nilsson and 4Front Technologies
 *  Copyright (C) 1999-2006  Haavard Kvaalen
 *  Copyright (C) 2005       Takashi Iwai
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.

		return FALSE;

	return snd_pcm_state(alsa_pcm) == SND_PCM_STATE_RUNNING;
}

static int xrun_recover(void)
{
	if (alsa_cfg.debug)
	{
		snd_pcm_status_t *alsa_status;
		snd_pcm_status_alloca(&alsa_status);
		if (snd_pcm_status(alsa_pcm, alsa_status) < 0)

		{
			printf("Status:\n");
			snd_pcm_status_dump(alsa_status, logs);
		}
	}
	return snd_pcm_prepare(alsa_pcm);
}

static int suspend_recover(void)
{
	int err;

	while ((err = snd_pcm_resume(alsa_pcm)) == -EAGAIN)
		/* wait until suspend flag is released */
		g_usleep(1000000);
	if (err < 0)
	{
		g_warning("alsa_handle_error(): "
			  "snd_pcm_resume() failed.");
		return snd_pcm_prepare(alsa_pcm);
	}
	return err;
}

/* handle generic errors */
static int alsa_handle_error(int err)
{
	switch (err)
	{
		case -EPIPE:
			return xrun_recover();
		case -ESTRPIPE:
			return suspend_recover();
	}

	return err;
}

/* update and get the available space on h/w buffer (in frames) */
static snd_pcm_sframes_t alsa_get_avail(void)
{

	if (alsa_pcm == NULL)
		return 0;

	while ((ret = snd_pcm_avail_update(alsa_pcm)) < 0)
	{
		ret = alsa_handle_error(ret);
		if (ret < 0)
		{
			g_warning("alsa_get_avail(): snd_pcm_avail_update() failed: %s",
				  snd_strerror(ret));
			return 0;

			data += written;
			alsa_hw_written += written;
		}
		else
		{
			int err = alsa_handle_error((int)written_frames);
			if (err < 0)
			{
				g_warning("alsa_write_audio(): write error: %s",
					  snd_strerror(err));
				break;

			{
				alsa_write_out_thread_data();
			}
			else if (wr < 0)
			{
				alsa_handle_error(wr);
			}
		}
		else
			g_usleep(10000);

1727:9d6de95dd7ed

 *  Copyright (C) 2001-2003 Matthieu Sozeau <[e-mail]>
 *  Copyright (C) 1998-2003  Peter Alm, Mikael Alm, Olle Hallnas,
 *                           Thomas Nilsson and 4Front Technologies
 *  Copyright (C) 1999-2006  Haavard Kvaalen
 *  Copyright (C) 2005       Takashi Iwai
 *  Copyright (C) 2007       William Pitcock
 *
 *  This program is free software; you can redistribute it and/or modify
 *  it under the terms of the GNU General Public License as published by
 *  the Free Software Foundation; either version 2 of the License, or
 *  (at your option) any later version.

		return FALSE;

	return snd_pcm_state(alsa_pcm) == SND_PCM_STATE_RUNNING;
}

static int
alsa_recovery(int err)
{
	int err2;

	/* if debug mode is enabled, dump ALSA state to console */
	if (alsa_cfg.debug)
	{
		snd_pcm_status_t *alsa_status;
		snd_pcm_status_alloca(&alsa_status);
		if (snd_pcm_status(alsa_pcm, alsa_status) < 0)

		{
			printf("Status:\n");
			snd_pcm_status_dump(alsa_status, logs);
		}
	}

	/*
	 * specifically handle -EPIPE and -ESTRPIPE to recover 
	 * PCM fragment periods without losing data.
	 */
	switch (err)
	{
	case -ESTRPIPE:   /* "suspend": wait until ALSA is "running" again. */
		while ((err2 = snd_pcm_resume(alsa_pcm)) == -EAGAIN)
			g_usleep(100000);

		if (err2 < 0)
			return snd_pcm_prepare(alsa_pcm);

		break;

	case -EPIPE:      /* under-run and the I/O pipe closed on us */
		return snd_pcm_prepare(alsa_pcm);
		break;

	default:
		g_warning("Unhandled ALSA exception code %d (%s), trying hard restart.", err, snd_strerror(err));
		return snd_pcm_prepare(alsa_pcm);
		break;
	}

	return 0;
}

/* update and get the available space on h/w buffer (in frames) */
static snd_pcm_sframes_t alsa_get_avail(void)
{

	if (alsa_pcm == NULL)
		return 0;

	while ((ret = snd_pcm_avail_update(alsa_pcm)) < 0)
	{
		ret = alsa_recovery(ret);
		if (ret < 0)
		{
			g_warning("alsa_get_avail(): snd_pcm_avail_update() failed: %s",
				  snd_strerror(ret));
			return 0;

			data += written;
			alsa_hw_written += written;
		}
		else
		{
			int err = alsa_recovery((int)written_frames);
			if (err < 0)
			{
				g_warning("alsa_write_audio(): write error: %s",
					  snd_strerror(err));
				break;

			{
				alsa_write_out_thread_data();
			}
			else if (wr < 0)
			{
				alsa_recovery(wr);
			}
		}
		else
			g_usleep(10000);