mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-10-29 05:40:27 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

pulse-server: clear timer when stream is created

Browse source 
Make a function when the stream is created so that we can clear the
create_tag and the timer.
This commit is contained in:
Wim Taymans 2025-09-18 14:22:00 +02:00
parent ca713c08ee
commit 06efc8ffb6
3 changed files with 12 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/modules/module-protocol-pulse/pulse-server.c
View file

@ -621,7 +621,7 @@ static int reply_create_playback_stream(struct stream *stream, struct pw_manager
TAG_INVALID);
}
stream->create_tag = SPA_ID_INVALID;
stream_created(stream);
return client_queue_message(client, reply);
}
@ -783,7 +783,7 @@ static int reply_create_record_stream(struct stream *stream, struct pw_manager_o
TAG_INVALID);
}
stream->create_tag = SPA_ID_INVALID;
stream_created(stream);
return client_queue_message(client, reply);
}

9
src/modules/module-protocol-pulse/stream.c
View file

@ -119,6 +119,15 @@ error_errno:
return NULL;
}
void stream_created(struct stream *stream)
{
struct client *client = stream->client;
pw_log_debug("client %p: stream %p channel:%d", client, stream, stream->channel);
stream->create_tag = SPA_ID_INVALID;
pw_timer_queue_cancel(&stream->timer);
}
void stream_free(struct stream *stream)
{
struct client *client = stream->client;

1
src/modules/module-protocol-pulse/stream.h
View file

@ -106,6 +106,7 @@ struct stream {
struct stream *stream_new(struct client *client, enum stream_type type, uint32_t create_tag,
const struct sample_spec *ss, const struct channel_map *map,
const struct buffer_attr *attr);
void stream_created(struct stream *stream);
void stream_free(struct stream *stream);
void stream_flush(struct stream *stream);
uint32_t stream_pop_missing(struct stream *stream);