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

node: improve debug

Browse source
This commit is contained in:
Wim Taymans 2020-09-17 10:34:42 +02:00
parent 8b168935ee
commit e9fd38512e
2 changed files with 5 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/modules/module-client-node/client-node.c
View file

@ -1122,12 +1122,14 @@ static void node_on_data_fd_events(struct spa_source *source)
if (source->rmask & SPA_IO_IN) { if (source->rmask & SPA_IO_IN) {
uint64_t cmd; uint64_t cmd;
struct pw_impl_node *node = this->impl->this.node;
if (SPA_UNLIKELY(spa_system_eventfd_read(this->data_system, if (SPA_UNLIKELY(spa_system_eventfd_read(this->data_system,
this->data_source.fd, &cmd) < 0)) this->data_source.fd, &cmd) < 0))
pw_log_warn(NAME" %p: read failed %m", this); pw_log_warn(NAME" %p: read failed %m", this);
else if (SPA_UNLIKELY(cmd > 1)) else if (SPA_UNLIKELY(cmd > 1))
pw_log_warn(NAME" %p: missed %"PRIu64" wakeups", this, cmd - 1); pw_log_warn("(%s-%u) client missed %"PRIu64" wakeups",
node->name, node->info.id, cmd - 1);
spa_log_trace_fp(this->log, NAME" %p: got ready", this); spa_log_trace_fp(this->log, NAME" %p: got ready", this);
spa_node_call_ready(&this->callbacks, SPA_STATUS_HAVE_DATA); spa_node_call_ready(&this->callbacks, SPA_STATUS_HAVE_DATA);

3
src/pipewire/impl-node.c
View file

@ -1021,7 +1021,8 @@ static void node_on_fd_events(struct spa_source *source)
if (SPA_UNLIKELY(spa_system_eventfd_read(data_system, this->source.fd, &cmd) < 0)) if (SPA_UNLIKELY(spa_system_eventfd_read(data_system, this->source.fd, &cmd) < 0))
pw_log_warn(NAME" %p: read failed %m", this); pw_log_warn(NAME" %p: read failed %m", this);
else if (SPA_UNLIKELY(cmd > 1)) else if (SPA_UNLIKELY(cmd > 1))
pw_log_warn(NAME" %p: missed %"PRIu64" wakeups", this, cmd - 1); pw_log_warn("(%s-%u) client missed %"PRIu64" wakeups",
this->name, this->info.id, cmd - 1);
pw_log_trace_fp(NAME" %p: got process", this); pw_log_trace_fp(NAME" %p: got process", this);
this->rt.target.signal(this->rt.target.data); this->rt.target.signal(this->rt.target.data);