mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-06 13:30:01 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions

video-src: let stream map buffers

Browse source
This commit is contained in:
Wim Taymans 2018-07-12 11:10:59 +02:00
parent 18bfa9ae6e
commit 8b919e89bd
1 changed files with 6 additions and 20 deletions
Download patch file Download diff file Expand all files Collapse all files

26
src/examples/video-src.c
View file

@ -72,7 +72,7 @@ static void on_timeout(void *userdata, uint64_t expirations)
{ {
struct data *data = userdata; struct data *data = userdata;
int i, j; int i, j;
uint8_t *p, *map; uint8_t *p;
struct spa_meta_header *h; struct spa_meta_header *h;
struct pw_buffer *buf; struct pw_buffer *buf;
struct spa_buffer *b; struct spa_buffer *b;
@ -83,21 +83,8 @@ static void on_timeout(void *userdata, uint64_t expirations)
b = buf->buffer; b = buf->buffer;
if (b->datas[0].type == data->t->data.MemFd || if ((p = b->datas[0].data) == NULL)
b->datas[0].type == data->t->data.DmaBuf) { goto done;
map =
mmap(NULL, b->datas[0].maxsize + b->datas[0].mapoffset,
PROT_READ | PROT_WRITE, MAP_SHARED, b->datas[0].fd, 0);
if (map == MAP_FAILED) {
printf("failed to mmap: %s\n", strerror(errno));
return;
}
p = SPA_MEMBER(map, b->datas[0].mapoffset, uint8_t);
} else if (b->datas[0].type == data->t->data.MemPtr) {
map = NULL;
p = b->datas[0].data;
} else
return;
if ((h = spa_buffer_find_meta(b, data->t->meta.Header))) { if ((h = spa_buffer_find_meta(b, data->t->meta.Header))) {
#if 0 #if 0
@ -120,11 +107,9 @@ static void on_timeout(void *userdata, uint64_t expirations)
data->counter += 13; data->counter += 13;
} }
if (map)
munmap(map, b->datas[0].maxsize + b->datas[0].mapoffset);
b->datas[0].chunk->size = b->datas[0].maxsize; b->datas[0].chunk->size = b->datas[0].maxsize;
done:
pw_stream_queue_buffer(data->stream, buf); pw_stream_queue_buffer(data->stream, buf);
} }
@ -243,7 +228,8 @@ static void on_state_changed(void *_data, enum pw_remote_state old, enum pw_remo
pw_stream_connect(data->stream, pw_stream_connect(data->stream,
PW_DIRECTION_OUTPUT, PW_DIRECTION_OUTPUT,
NULL, NULL,
PW_STREAM_FLAG_DRIVER, PW_STREAM_FLAG_DRIVER |
PW_STREAM_FLAG_MAP_BUFFERS,
params, 1); params, 1);
break; break;
} }