mirrors/gstreamer
mirrors/gstreamer
1
1
Fork 0
mirror of https://gitlab.freedesktop.org/gstreamer/gstreamer.git synced 2025-06-05 06:58:56 +00:00
Code Issues 1 Projects Releases Wiki Activity

shmpipe: Ref client shmarea when a buffer is received in it

Browse source
This commit is contained in:
Olivier Crête 2010-01-28 11:31:11 +02:00
parent 68c9ed6e5c
commit 007a26ac08
1 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

3
gst/shm/shmpipe.c
View file

@ -597,6 +597,7 @@ sp_client_recv (ShmPipe * self, char **buf)
for (area = self->shm_area; area; area = area->next) { for (area = self->shm_area; area; area = area->next) {
if (area->id == cb.area_id) { if (area->id == cb.area_id) {
*buf = area->shm_area + cb.payload.buffer.offset; *buf = area->shm_area + cb.payload.buffer.offset;
sp_shm_area_inc (area);
return cb.payload.buffer.size; return cb.payload.buffer.size;
} }
} }
@ -658,6 +659,8 @@ sp_client_recv_finish (ShmPipe * self, char *buf)
offset = buf - shm_area->shm_area; offset = buf - shm_area->shm_area;
sp_shm_area_dec (self, shm_area);
cb.payload.ack_buffer.offset = offset; cb.payload.ack_buffer.offset = offset;
return send_command (self->main_socket, &cb, COMMAND_ACK_BUFFER, return send_command (self->main_socket, &cb, COMMAND_ACK_BUFFER,
self->shm_area->id); self->shm_area->id);