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

small debug improvements

Browse source
This commit is contained in:
Wim Taymans 2018-08-01 21:43:31 +02:00
parent a63523650d
commit f087a088a5
2 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/pipewire/remote.c
View file

@ -544,8 +544,8 @@ on_rtsocket_condition(void *user_data, int fd, enum spa_io mask)
if (mask & SPA_IO_IN) {
uint64_t cmd;
if (read(fd, &cmd, sizeof(uint64_t)) != sizeof(uint64_t))
pw_log_warn("proxy %p: read failed %m", proxy);
if (read(fd, &cmd, sizeof(uint64_t)) != sizeof(uint64_t) || cmd != 1)
pw_log_warn("proxy %p: read %"PRIu64" failed %m", proxy, cmd);
pw_log_trace("remote %p: process", data->remote);
spa_graph_run(node->graph->parent->graph);

4
src/pipewire/stream.c
View file

@ -627,7 +627,7 @@ static int impl_port_use_buffers(struct spa_node *node, enum spa_direction direc
static int impl_port_reuse_buffer(struct spa_node *node, uint32_t port_id, uint32_t buffer_id)
{
struct stream *d = SPA_CONTAINER_OF(node, struct stream, impl_node);
pw_log_trace("export-source %p: recycle buffer %d", d, buffer_id);
pw_log_trace("stream %p: recycle buffer %d", d, buffer_id);
if (buffer_id < d->n_buffers)
push_queue(d, &d->queued, &d->buffers[buffer_id]);
return 0;
@ -750,7 +750,7 @@ static int handle_connect(struct pw_stream *stream)
struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this);
pw_log_debug("stream %p: creating node", stream);
impl->node = pw_node_new(impl->core, "export-source",
impl->node = pw_node_new(impl->core, "PipeWire-stream",
pw_properties_copy(stream->properties), 0);
impl->impl_node = impl_node;