mirror of
https://gitlab.freedesktop.org/pulseaudio/pulseaudio.git
synced 2025-11-12 13:30:10 -05:00
ee2db62277
Color global mempools with a special mark. This special marking is needed for handling memfd-backed pools. To avoid fd leaks, memfd pools are registered with the connection pstream to create an ID<->memfd mapping on both PA endpoints. Such memory regions are then always referenced by their IDs and never by their fds, and so their fds can be safely closed later. Unfortunately this scheme cannot work with global pools since the registration ID<->memfd mechanism needs to happen for each newly connected client, and thus the need for a more special handling. That is, for the pool's fd to be always open :-( Almost all mempools are now created on a per-client basis. The only exception is the pa_core's mempool which is still shared between all clients of the system. Signed-off-by: Ahmed S. Darwish <darwish.07@gmail.com>
106 lines
2.7 KiB
C
106 lines
2.7 KiB
C
/***
|
|
This file is part of PulseAudio.
|
|
|
|
PulseAudio is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU Lesser General Public License as
|
|
published by the Free Software Foundation; either version 2.1 of the
|
|
License, or (at your option) any later version.
|
|
|
|
PulseAudio is distributed in the hope that it will be useful, but
|
|
WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
Lesser General Public License for more details.
|
|
|
|
You should have received a copy of the GNU Lesser General Public
|
|
License along with PulseAudio; if not, see <http://www.gnu.org/licenses/>.
|
|
***/
|
|
|
|
#ifdef HAVE_CONFIG_H
|
|
#include <config.h>
|
|
#endif
|
|
|
|
#include <unistd.h>
|
|
#include <sys/types.h>
|
|
#include <errno.h>
|
|
#include <string.h>
|
|
#include <stdlib.h>
|
|
#include <time.h>
|
|
|
|
#include <pulsecore/core-util.h>
|
|
#include <pulsecore/mcalign.h>
|
|
|
|
/* A simple program for testing pa_mcalign */
|
|
|
|
int main(int argc, char *argv[]) {
|
|
pa_mempool *p;
|
|
pa_mcalign *a;
|
|
pa_memchunk c;
|
|
|
|
p = pa_mempool_new(PA_MEM_TYPE_PRIVATE, 0, true);
|
|
|
|
a = pa_mcalign_new(11);
|
|
|
|
pa_memchunk_reset(&c);
|
|
|
|
srand((unsigned) time(NULL));
|
|
|
|
for (;;) {
|
|
ssize_t r;
|
|
size_t l;
|
|
|
|
if (!c.memblock) {
|
|
c.memblock = pa_memblock_new(p, 2048);
|
|
c.index = c.length = 0;
|
|
}
|
|
|
|
pa_assert(c.index < pa_memblock_get_length(c.memblock));
|
|
|
|
l = pa_memblock_get_length(c.memblock) - c.index;
|
|
|
|
l = l <= 1 ? l : (size_t) rand() % (l-1) +1;
|
|
|
|
p = pa_memblock_acquire(c.memblock);
|
|
|
|
if ((r = read(STDIN_FILENO, (uint8_t*) p + c.index, l)) <= 0) {
|
|
pa_memblock_release(c.memblock);
|
|
fprintf(stderr, "read() failed: %s\n", r < 0 ? strerror(errno) : "EOF");
|
|
break;
|
|
}
|
|
|
|
pa_memblock_release(c.memblock);
|
|
|
|
c.length = (size_t) r;
|
|
pa_mcalign_push(a, &c);
|
|
fprintf(stderr, "Read %zd bytes\n", r);
|
|
|
|
c.index += (size_t) r;
|
|
|
|
if (c.index >= pa_memblock_get_length(c.memblock)) {
|
|
pa_memblock_unref(c.memblock);
|
|
pa_memchunk_reset(&c);
|
|
}
|
|
|
|
for (;;) {
|
|
pa_memchunk t;
|
|
|
|
if (pa_mcalign_pop(a, &t) < 0)
|
|
break;
|
|
|
|
p = pa_memblock_acquire(t.memblock);
|
|
pa_loop_write(STDOUT_FILENO, (uint8_t*) p + t.index, t.length, NULL);
|
|
pa_memblock_release(t.memblock);
|
|
fprintf(stderr, "Wrote %lu bytes.\n", (unsigned long) t.length);
|
|
|
|
pa_memblock_unref(t.memblock);
|
|
}
|
|
}
|
|
|
|
pa_mcalign_free(a);
|
|
|
|
if (c.memblock)
|
|
pa_memblock_unref(c.memblock);
|
|
|
|
pa_mempool_unref(p);
|
|
|
|
return 0;
|
|
}
|