- wn->private_data = pad;
- if (!conf->samplerate_given && wng->samplerate)
- pad->samplerate = *wng->samplerate;
- else
- pad->samplerate = conf->samplerate_arg;
- if (!conf->channels_given && wng->channels)
- pad->channels = *wng->channels;
- else
- pad->channels = conf->channels_arg;
- PARA_INFO_LOG("%d channel(s), %dHz\n", pad->channels, pad->samplerate);
- tv_add(now, &(struct timeval){0, 100 * 1000}, &pad->next_chunk);
- return 1;
+ if (ret == 0)
+ return;
+ if (ret < 0 || !pad)
+ return sched_min_delay(s);
+ /*
+ * Data is available to be written to the alsa handle. Compute number
+ * of milliseconds until next buffer underrun would occur.
+ *
+ * snd_pcm_avail_update() updates the current available count of
+ * samples for writing. It is a light method to obtain current stream
+ * position, because it does not require the user <-> kernel context
+ * switch, but the value is less accurate, because ring buffer pointers
+ * are updated in kernel drivers only when an interrupt occurs.
+ */
+ avail = snd_pcm_avail_update(pad->handle);
+ if (avail < 0)
+ avail = 0;
+ underrun = (pad->buffer_frames - avail) * pad->buffer_time
+ / pad->buffer_frames / 1000;
+ if (underrun < 50)
+ underrun = 50;
+ underrun -= 50;
+ ms2tv(underrun, &tv);
+ sched_request_timeout(&tv, s);