update_usage(u);
for (;;) {
+ void *p;
pa_memchunk *memchunk = NULL;
snd_pcm_sframes_t frames;
else
memchunk = &u->memchunk;
}
-
assert(memchunk->memblock);
- assert(memchunk->memblock->data);
assert(memchunk->length);
- assert(memchunk->memblock->length);
assert((memchunk->length % u->frame_size) == 0);
- if ((frames = snd_pcm_writei(u->pcm_handle, (uint8_t*) memchunk->memblock->data + memchunk->index, memchunk->length / u->frame_size)) < 0) {
+ p = pa_memblock_acquire(memchunk->memblock);
+
+ if ((frames = snd_pcm_writei(u->pcm_handle, (uint8_t*) p + memchunk->index, memchunk->length / u->frame_size)) < 0) {
+ pa_memblock_release(memchunk->memblock);
+
if (frames == -EAGAIN)
return;
return;
}
+ pa_memblock_release(memchunk->memblock);
+
if (memchunk == &u->memchunk) {
size_t l = frames * u->frame_size;
memchunk->index += l;