g_free (src->device);
g_mutex_clear (&src->alsa_lock);
- g_mutex_clear (&src->delay_lock);
G_OBJECT_CLASS (parent_class)->finalize (object);
}
alsasrc->driver_timestamps = FALSE;
g_mutex_init (&alsasrc->alsa_lock);
- g_mutex_init (&alsasrc->delay_lock);
}
#define CHECK(call, error) \
GST_ALSA_SRC_LOCK (asrc);
while (cptr > 0) {
- GST_DELAY_SRC_LOCK (asrc);
- err = snd_pcm_readi (alsa->handle, ptr, cptr);
- GST_DELAY_SRC_UNLOCK (asrc);
-
- if (err < 0) {
+ if ((err = snd_pcm_readi (alsa->handle, ptr, cptr)) < 0) {
if (err == -EAGAIN) {
GST_DEBUG_OBJECT (asrc, "Read error: %s", snd_strerror (err));
continue;
alsa = GST_ALSA_SRC (asrc);
- GST_DELAY_SRC_LOCK (asrc);
res = snd_pcm_delay (alsa->handle, &delay);
- GST_DELAY_SRC_UNLOCK (asrc);
if (G_UNLIKELY (res < 0)) {
GST_DEBUG_OBJECT (alsa, "snd_pcm_delay returned %d", res);
delay = 0;
#define GST_ALSA_SRC_LOCK(obj) (g_mutex_lock (GST_ALSA_SRC_GET_LOCK (obj)))
#define GST_ALSA_SRC_UNLOCK(obj) (g_mutex_unlock (GST_ALSA_SRC_GET_LOCK (obj)))
-#define GST_DELAY_SRC_GET_LOCK(obj) (&GST_ALSA_SRC_CAST (obj)->delay_lock)
-#define GST_DELAY_SRC_LOCK(obj) (g_mutex_lock (GST_DELAY_SRC_GET_LOCK (obj)))
-#define GST_DELAY_SRC_UNLOCK(obj) (g_mutex_unlock (GST_DELAY_SRC_GET_LOCK (obj)))
-
typedef struct _GstAlsaSrc GstAlsaSrc;
typedef struct _GstAlsaSrcClass GstAlsaSrcClass;
snd_pcm_uframes_t period_size;
GMutex alsa_lock;
- GMutex delay_lock;
};
struct _GstAlsaSrcClass {