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

log: add stream and filter topics

Browse source
This commit is contained in:
Wim Taymans 2021-10-02 14:02:23 +02:00
parent 5522e9cb1c
commit 1ba805ac7e
3 changed files with 123 additions and 117 deletions
Download patch file Download diff file Expand all files Collapse all files

103
src/pipewire/filter.c
View file

@ -43,7 +43,8 @@
#include "pipewire/filter.h" #include "pipewire/filter.h"
#include "pipewire/private.h" #include "pipewire/private.h"
#define NAME "filter" PW_LOG_TOPIC_EXTERN(log_filter);
#define PW_LOG_TOPIC_DEFAULT log_filter
#define MAX_SAMPLES 8192 #define MAX_SAMPLES 8192
#define MAX_BUFFERS 64 #define MAX_BUFFERS 64
@ -220,11 +221,11 @@ static void fix_datatype(const struct spa_pod *param)
if (spa_pod_get_int(&vals[0], (int32_t*)&dataType) < 0) if (spa_pod_get_int(&vals[0], (int32_t*)&dataType) < 0)
return; return;
pw_log_debug(NAME" dataType: %u", dataType); pw_log_debug("dataType: %u", dataType);
if (dataType & (1u << SPA_DATA_MemPtr)) { if (dataType & (1u << SPA_DATA_MemPtr)) {
SPA_POD_VALUE(struct spa_pod_int, &vals[0]) = SPA_POD_VALUE(struct spa_pod_int, &vals[0]) =
dataType | mappable_dataTypes; dataType | mappable_dataTypes;
pw_log_debug(NAME" Change dataType: %u -> %u", dataType, pw_log_debug("Change dataType: %u -> %u", dataType,
SPA_POD_VALUE(struct spa_pod_int, &vals[0])); SPA_POD_VALUE(struct spa_pod_int, &vals[0]));
} }
} }
@ -260,7 +261,7 @@ static struct param *add_param(struct filter *impl, struct port *port,
memcpy(p->param, param, SPA_POD_SIZE(param)); memcpy(p->param, param, SPA_POD_SIZE(param));
SPA_POD_OBJECT_ID(p->param) = id; SPA_POD_OBJECT_ID(p->param) = id;
pw_log_debug(NAME" %p: port %p param id %d (%s)", impl, p, id, pw_log_debug("%p: port %p param id %d (%s)", impl, p, id,
spa_debug_type_find_name(spa_type_param, id)); spa_debug_type_find_name(spa_type_param, id));
if (port) { if (port) {
@ -392,12 +393,12 @@ static bool filter_set_state(struct pw_filter *filter, enum pw_filter_state stat
free(filter->error); free(filter->error);
filter->error = error ? strdup(error) : NULL; filter->error = error ? strdup(error) : NULL;
pw_log_debug(NAME" %p: update state from %s -> %s (%s)", filter, pw_log_debug("%p: update state from %s -> %s (%s)", filter,
pw_filter_state_as_string(old), pw_filter_state_as_string(old),
pw_filter_state_as_string(state), filter->error); pw_filter_state_as_string(state), filter->error);
if (state == PW_FILTER_STATE_ERROR) if (state == PW_FILTER_STATE_ERROR)
pw_log_error(NAME" %p: error %s", filter, error); pw_log_error("%p: error %s", filter, error);
filter->state = state; filter->state = state;
pw_filter_emit_state_changed(filter, old, state, error); pw_filter_emit_state_changed(filter, old, state, error);
@ -420,7 +421,7 @@ static int enum_params(struct filter *d, struct spa_list *param_list, int seq,
result.id = id; result.id = id;
result.next = 0; result.next = 0;
pw_log_debug(NAME" %p: %p param id %d (%s) start:%d num:%d", d, param_list, id, pw_log_debug("%p: %p param id %d (%s) start:%d num:%d", d, param_list, id,
spa_debug_type_find_name(spa_type_param, id), spa_debug_type_find_name(spa_type_param, id),
start, num); start, num);
@ -481,7 +482,7 @@ static int impl_set_io(void *object, uint32_t id, void *data, size_t size)
{ {
struct filter *impl = object; struct filter *impl = object;
pw_log_debug(NAME" %p: io %d %p/%zd", impl, id, data, size); pw_log_debug("%p: io %d %p/%zd", impl, id, data, size);
switch(id) { switch(id) {
case SPA_IO_Position: case SPA_IO_Position:
@ -509,18 +510,18 @@ static int impl_send_command(void *object, const struct spa_command *command)
pw_loop_invoke(impl->context->main_loop, pw_loop_invoke(impl->context->main_loop,
NULL, 0, NULL, 0, false, impl); NULL, 0, NULL, 0, false, impl);
if (filter->state == PW_FILTER_STATE_STREAMING) { if (filter->state == PW_FILTER_STATE_STREAMING) {
pw_log_debug(NAME" %p: pause", filter); pw_log_debug("%p: pause", filter);
filter_set_state(filter, PW_FILTER_STATE_PAUSED, NULL); filter_set_state(filter, PW_FILTER_STATE_PAUSED, NULL);
} }
break; break;
case SPA_NODE_COMMAND_Start: case SPA_NODE_COMMAND_Start:
if (filter->state == PW_FILTER_STATE_PAUSED) { if (filter->state == PW_FILTER_STATE_PAUSED) {
pw_log_debug(NAME" %p: start", filter); pw_log_debug("%p: start", filter);
filter_set_state(filter, PW_FILTER_STATE_STREAMING, NULL); filter_set_state(filter, PW_FILTER_STATE_STREAMING, NULL);
} }
break; break;
default: default:
pw_log_warn(NAME" %p: unhandled node command %d", filter, pw_log_warn("%p: unhandled node command %d", filter,
SPA_NODE_COMMAND_ID(command)); SPA_NODE_COMMAND_ID(command));
break; break;
} }
@ -604,7 +605,7 @@ static int impl_port_set_io(void *object, enum spa_direction direction, uint32_t
struct filter *impl = object; struct filter *impl = object;
struct port *port; struct port *port;
pw_log_debug(NAME" %p: set io %s %p %zd", impl, pw_log_debug("%p: set io %s %p %zd", impl,
spa_debug_type_find_name(spa_type_io, id), data, size); spa_debug_type_find_name(spa_type_io, id), data, size);
if ((port = get_port(impl, direction, port_id)) == NULL) if ((port = get_port(impl, direction, port_id)) == NULL)
@ -700,17 +701,17 @@ static int map_data(struct filter *impl, struct spa_data *data, int prot)
ptr = mmap(NULL, range.size, prot, MAP_SHARED, data->fd, range.offset); ptr = mmap(NULL, range.size, prot, MAP_SHARED, data->fd, range.offset);
if (ptr == MAP_FAILED) { if (ptr == MAP_FAILED) {
pw_log_error(NAME" %p: failed to mmap buffer mem: %m", impl); pw_log_error("%p: failed to mmap buffer mem: %m", impl);
return -errno; return -errno;
} }
data->data = SPA_PTROFF(ptr, range.start, void); data->data = SPA_PTROFF(ptr, range.start, void);
pw_log_debug(NAME" %p: fd %"PRIi64" mapped %d %d %p", impl, data->fd, pw_log_debug("%p: fd %"PRIi64" mapped %d %d %p", impl, data->fd,
range.offset, range.size, data->data); range.offset, range.size, data->data);
if (impl->allow_mlock && mlock(data->data, data->maxsize) < 0) { if (impl->allow_mlock && mlock(data->data, data->maxsize) < 0) {
if (errno != ENOMEM || !mlock_warned) { if (errno != ENOMEM || !mlock_warned) {
pw_log(impl->warn_mlock ? SPA_LOG_LEVEL_WARN : SPA_LOG_LEVEL_DEBUG, pw_log(impl->warn_mlock ? SPA_LOG_LEVEL_WARN : SPA_LOG_LEVEL_DEBUG,
NAME" %p: Failed to mlock memory %p %u: %s", impl, "%p: Failed to mlock memory %p %u: %s", impl,
data->data, data->maxsize, data->data, data->maxsize,
errno == ENOMEM ? errno == ENOMEM ?
"This is not a problem but for best performance, " "This is not a problem but for best performance, "
@ -728,9 +729,9 @@ static int unmap_data(struct filter *impl, struct spa_data *data)
pw_map_range_init(&range, data->mapoffset, data->maxsize, impl->context->sc_pagesize); pw_map_range_init(&range, data->mapoffset, data->maxsize, impl->context->sc_pagesize);
if (munmap(SPA_PTROFF(data->data, -range.start, void), range.size) < 0) if (munmap(SPA_PTROFF(data->data, -range.start, void), range.size) < 0)
pw_log_warn(NAME" %p: failed to unmap: %m", impl); pw_log_warn("%p: failed to unmap: %m", impl);
pw_log_debug(NAME" %p: fd %"PRIi64" unmapped", impl, data->fd); pw_log_debug("%p: fd %"PRIi64" unmapped", impl, data->fd);
return 0; return 0;
} }
@ -739,7 +740,7 @@ static void clear_buffers(struct port *port)
uint32_t i, j; uint32_t i, j;
struct filter *impl = port->filter; struct filter *impl = port->filter;
pw_log_debug(NAME" %p: clear buffers %d", impl, port->n_buffers); pw_log_debug("%p: clear buffers %d", impl, port->n_buffers);
for (i = 0; i < port->n_buffers; i++) { for (i = 0; i < port->n_buffers; i++) {
struct buffer *b = &port->buffers[i]; struct buffer *b = &port->buffers[i];
@ -750,7 +751,7 @@ static void clear_buffers(struct port *port)
if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_MAPPED)) { if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_MAPPED)) {
for (j = 0; j < b->this.buffer->n_datas; j++) { for (j = 0; j < b->this.buffer->n_datas; j++) {
struct spa_data *d = &b->this.buffer->datas[j]; struct spa_data *d = &b->this.buffer->datas[j];
pw_log_debug(NAME" %p: clear buffer %d mem", pw_log_debug("%p: clear buffer %d mem",
impl, b->id); impl, b->id);
unmap_data(impl, d); unmap_data(impl, d);
} }
@ -839,7 +840,7 @@ static int impl_port_set_param(void *object,
if (impl->disconnecting && param != NULL) if (impl->disconnecting && param != NULL)
return -EIO; return -EIO;
pw_log_debug(NAME" %p: param changed: %p %d", impl, param, impl->disconnecting); pw_log_debug("%p: param changed: %p %d", impl, param, impl->disconnecting);
if ((port = get_port(impl, direction, port_id)) == NULL) if ((port = get_port(impl, direction, port_id)) == NULL)
return -EINVAL; return -EINVAL;
@ -913,19 +914,19 @@ static int impl_port_use_buffers(void *object,
SPA_FLAG_SET(b->flags, BUFFER_FLAG_MAPPED); SPA_FLAG_SET(b->flags, BUFFER_FLAG_MAPPED);
} }
else if (d->type == SPA_DATA_MemPtr && d->data == NULL) { else if (d->type == SPA_DATA_MemPtr && d->data == NULL) {
pw_log_error(NAME" %p: invalid buffer mem", filter); pw_log_error("%p: invalid buffer mem", filter);
return -EINVAL; return -EINVAL;
} }
buf_size += d->maxsize; buf_size += d->maxsize;
} }
if (size > 0 && buf_size != size) { if (size > 0 && buf_size != size) {
pw_log_error(NAME" %p: invalid buffer size %d", filter, buf_size); pw_log_error("%p: invalid buffer size %d", filter, buf_size);
return -EINVAL; return -EINVAL;
} else } else
size = buf_size; size = buf_size;
} }
pw_log_debug(NAME" %p: got buffer %d %d datas, mapped size %d", filter, i, pw_log_debug("%p: got buffer %d %d datas, mapped size %d", filter, i,
buffers[i]->n_datas, size); buffers[i]->n_datas, size);
} }
@ -935,7 +936,7 @@ static int impl_port_use_buffers(void *object,
b->this.buffer = buffers[i]; b->this.buffer = buffers[i];
if (port->direction == SPA_DIRECTION_OUTPUT) { if (port->direction == SPA_DIRECTION_OUTPUT) {
pw_log_trace(NAME" %p: recycle buffer %d", filter, b->id); pw_log_trace("%p: recycle buffer %d", filter, b->id);
push_queue(port, &port->dequeued, b); push_queue(port, &port->dequeued, b);
} }
@ -956,7 +957,7 @@ static int impl_port_reuse_buffer(void *object, uint32_t port_id, uint32_t buffe
if ((port = get_port(impl, SPA_DIRECTION_OUTPUT, port_id)) == NULL) if ((port = get_port(impl, SPA_DIRECTION_OUTPUT, port_id)) == NULL)
return -EINVAL; return -EINVAL;
pw_log_trace(NAME" %p: recycle buffer %d", impl, buffer_id); pw_log_trace("%p: recycle buffer %d", impl, buffer_id);
if (buffer_id < port->n_buffers) if (buffer_id < port->n_buffers)
push_queue(port, &port->queued, &port->buffers[buffer_id]); push_queue(port, &port->queued, &port->buffers[buffer_id]);
@ -986,14 +987,14 @@ do_call_process(struct spa_loop *loop,
{ {
struct filter *impl = user_data; struct filter *impl = user_data;
struct pw_filter *filter = &impl->this; struct pw_filter *filter = &impl->this;
pw_log_trace(NAME" %p: do process", filter); pw_log_trace("%p: do process", filter);
pw_filter_emit_process(filter, impl->position); pw_filter_emit_process(filter, impl->position);
return 0; return 0;
} }
static void call_process(struct filter *impl) static void call_process(struct filter *impl)
{ {
pw_log_trace(NAME" %p: call process", impl); pw_log_trace("%p: call process", impl);
if (SPA_FLAG_IS_SET(impl->flags, PW_FILTER_FLAG_RT_PROCESS)) { if (SPA_FLAG_IS_SET(impl->flags, PW_FILTER_FLAG_RT_PROCESS)) {
spa_callbacks_call(&impl->rt_callbacks, struct pw_filter_events, spa_callbacks_call(&impl->rt_callbacks, struct pw_filter_events,
process, 0, impl->rt.position); process, 0, impl->rt.position);
@ -1010,7 +1011,7 @@ do_call_drained(struct spa_loop *loop,
{ {
struct filter *impl = user_data; struct filter *impl = user_data;
struct pw_filter *filter = &impl->this; struct pw_filter *filter = &impl->this;
pw_log_trace(NAME" %p: drained", filter); pw_log_trace("%p: drained", filter);
pw_filter_emit_drained(filter); pw_filter_emit_drained(filter);
impl->draining = false; impl->draining = false;
return 0; return 0;
@ -1029,7 +1030,7 @@ static int impl_node_process(void *object)
struct buffer *b; struct buffer *b;
bool drained = true; bool drained = true;
pw_log_trace(NAME" %p: do process %p", impl, impl->rt.position); pw_log_trace("%p: do process %p", impl, impl->rt.position);
/** first dequeue and recycle buffers */ /** first dequeue and recycle buffers */
spa_list_for_each(p, &impl->port_list, link) { spa_list_for_each(p, &impl->port_list, link) {
@ -1045,7 +1046,7 @@ static int impl_node_process(void *object)
/* push new buffer */ /* push new buffer */
b = &p->buffers[io->buffer_id]; b = &p->buffers[io->buffer_id];
pw_log_trace(NAME" %p: dequeue buffer %d", impl, b->id); pw_log_trace("%p: dequeue buffer %d", impl, b->id);
push_queue(p, &p->dequeued, b); push_queue(p, &p->dequeued, b);
drained = false; drained = false;
} else { } else {
@ -1054,7 +1055,7 @@ static int impl_node_process(void *object)
/* recycle old buffer */ /* recycle old buffer */
b = &p->buffers[io->buffer_id]; b = &p->buffers[io->buffer_id];
pw_log_trace(NAME" %p: recycle buffer %d", impl, b->id); pw_log_trace("%p: recycle buffer %d", impl, b->id);
push_queue(p, &p->dequeued, b); push_queue(p, &p->dequeued, b);
} }
} }
@ -1075,7 +1076,7 @@ static int impl_node_process(void *object)
/* pop buffer to recycle */ /* pop buffer to recycle */
if ((b = pop_queue(p, &p->queued)) != NULL) { if ((b = pop_queue(p, &p->queued)) != NULL) {
pw_log_trace(NAME" %p: recycle buffer %d", impl, b->id); pw_log_trace("%p: recycle buffer %d", impl, b->id);
io->buffer_id = b->id; io->buffer_id = b->id;
} else { } else {
io->buffer_id = SPA_ID_INVALID; io->buffer_id = SPA_ID_INVALID;
@ -1086,7 +1087,7 @@ static int impl_node_process(void *object)
continue; continue;
if ((b = pop_queue(p, &p->queued)) != NULL) { if ((b = pop_queue(p, &p->queued)) != NULL) {
pw_log_trace(NAME" %p: pop %d %p", impl, b->id, io); pw_log_trace("%p: pop %d %p", impl, b->id, io);
io->buffer_id = b->id; io->buffer_id = b->id;
io->status = SPA_STATUS_HAVE_DATA; io->status = SPA_STATUS_HAVE_DATA;
drained = false; drained = false;
@ -1121,7 +1122,7 @@ static const struct spa_node_methods impl_node = {
static void proxy_removed(void *_data) static void proxy_removed(void *_data)
{ {
struct pw_filter *filter = _data; struct pw_filter *filter = _data;
pw_log_debug(NAME" %p: removed", filter); pw_log_debug("%p: removed", filter);
spa_hook_remove(&filter->proxy_listener); spa_hook_remove(&filter->proxy_listener);
filter->node_id = SPA_ID_INVALID; filter->node_id = SPA_ID_INVALID;
filter_set_state(filter, PW_FILTER_STATE_UNCONNECTED, NULL); filter_set_state(filter, PW_FILTER_STATE_UNCONNECTED, NULL);
@ -1130,7 +1131,7 @@ static void proxy_removed(void *_data)
static void proxy_destroy(void *_data) static void proxy_destroy(void *_data)
{ {
struct pw_filter *filter = _data; struct pw_filter *filter = _data;
pw_log_debug(NAME" %p: destroy", filter); pw_log_debug("%p: destroy", filter);
proxy_removed(_data); proxy_removed(_data);
} }
@ -1159,7 +1160,7 @@ static void on_core_error(void *_data, uint32_t id, int seq, int res, const char
{ {
struct pw_filter *filter = _data; struct pw_filter *filter = _data;
pw_log_debug(NAME" %p: error id:%u seq:%d res:%d (%s): %s", filter, pw_log_debug("%p: error id:%u seq:%d res:%d (%s): %s", filter,
id, seq, res, spa_strerror(res), message); id, seq, res, spa_strerror(res), message);
if (id == PW_ID_CORE && res == -EPIPE) { if (id == PW_ID_CORE && res == -EPIPE) {
@ -1188,7 +1189,7 @@ filter_new(struct pw_context *context, const char *name,
} }
this = &impl->this; this = &impl->this;
pw_log_debug(NAME" %p: new", impl); pw_log_debug("%p: new", impl);
if (props == NULL) { if (props == NULL) {
props = pw_properties_new(PW_KEY_MEDIA_NAME, name, NULL); props = pw_properties_new(PW_KEY_MEDIA_NAME, name, NULL);
@ -1332,7 +1333,7 @@ void pw_filter_destroy(struct pw_filter *filter)
struct filter *impl = SPA_CONTAINER_OF(filter, struct filter, this); struct filter *impl = SPA_CONTAINER_OF(filter, struct filter, this);
struct port *p; struct port *p;
pw_log_debug(NAME" %p: destroy", filter); pw_log_debug("%p: destroy", filter);
pw_filter_emit_destroy(filter); pw_filter_emit_destroy(filter);
@ -1349,7 +1350,7 @@ void pw_filter_destroy(struct pw_filter *filter)
clear_params(impl, NULL, SPA_ID_INVALID); clear_params(impl, NULL, SPA_ID_INVALID);
pw_log_debug(NAME" %p: free", filter); pw_log_debug("%p: free", filter);
free(filter->error); free(filter->error);
pw_properties_free(filter->properties); pw_properties_free(filter->properties);
@ -1459,7 +1460,7 @@ pw_filter_connect(struct pw_filter *filter,
uint32_t i; uint32_t i;
struct spa_dict_item items[1]; struct spa_dict_item items[1];
pw_log_debug(NAME" %p: connect", filter); pw_log_debug("%p: connect", filter);
impl->flags = flags; impl->flags = flags;
impl->process_rt = SPA_FLAG_IS_SET(flags, PW_FILTER_FLAG_RT_PROCESS); impl->process_rt = SPA_FLAG_IS_SET(flags, PW_FILTER_FLAG_RT_PROCESS);
@ -1509,7 +1510,7 @@ pw_filter_connect(struct pw_filter *filter,
impl->disconnect_core = true; impl->disconnect_core = true;
} }
pw_log_debug(NAME" %p: export node %p", filter, &impl->impl_node); pw_log_debug("%p: export node %p", filter, &impl->impl_node);
items[0] = SPA_DICT_ITEM_INIT(PW_KEY_OBJECT_REGISTER, "false"); items[0] = SPA_DICT_ITEM_INIT(PW_KEY_OBJECT_REGISTER, "false");
filter->proxy = pw_core_export(filter->core, filter->proxy = pw_core_export(filter->core,
@ -1525,10 +1526,10 @@ pw_filter_connect(struct pw_filter *filter,
return 0; return 0;
error_connect: error_connect:
pw_log_error(NAME" %p: can't connect: %s", filter, spa_strerror(res)); pw_log_error("%p: can't connect: %s", filter, spa_strerror(res));
return res; return res;
error_proxy: error_proxy:
pw_log_error(NAME" %p: can't make proxy: %s", filter, spa_strerror(res)); pw_log_error("%p: can't make proxy: %s", filter, spa_strerror(res));
return res; return res;
} }
@ -1543,7 +1544,7 @@ int pw_filter_disconnect(struct pw_filter *filter)
{ {
struct filter *impl = SPA_CONTAINER_OF(filter, struct filter, this); struct filter *impl = SPA_CONTAINER_OF(filter, struct filter, this);
pw_log_debug(NAME" %p: disconnect", filter); pw_log_debug("%p: disconnect", filter);
impl->disconnecting = true; impl->disconnecting = true;
if (filter->proxy) { if (filter->proxy) {
@ -1749,7 +1750,7 @@ int pw_filter_update_params(struct pw_filter *filter,
struct port *port; struct port *port;
int res; int res;
pw_log_debug(NAME" %p: update params", filter); pw_log_debug("%p: update params", filter);
port = port_data ? SPA_CONTAINER_OF(port_data, struct port, user_data) : NULL; port = port_data ? SPA_CONTAINER_OF(port_data, struct port, user_data) : NULL;
@ -1768,7 +1769,7 @@ int pw_filter_update_params(struct pw_filter *filter,
SPA_EXPORT SPA_EXPORT
int pw_filter_set_active(struct pw_filter *filter, bool active) int pw_filter_set_active(struct pw_filter *filter, bool active)
{ {
pw_log_debug(NAME" %p: active:%d", filter, active); pw_log_debug("%p: active:%d", filter, active);
return 0; return 0;
} }
@ -1784,7 +1785,7 @@ int pw_filter_get_time(struct pw_filter *filter, struct pw_time *time)
seq2 = SEQ_READ(impl->seq); seq2 = SEQ_READ(impl->seq);
} while (!SEQ_READ_SUCCESS(seq1, seq2)); } while (!SEQ_READ_SUCCESS(seq1, seq2));
pw_log_trace(NAME" %p: %"PRIi64" %"PRIi64" %"PRIu64" %d/%d ", filter, pw_log_trace("%p: %"PRIi64" %"PRIi64" %"PRIu64" %d/%d ", filter,
time->now, time->delay, time->ticks, time->now, time->delay, time->ticks,
time->rate.num, time->rate.denom); time->rate.num, time->rate.denom);
@ -1820,11 +1821,11 @@ struct pw_buffer *pw_filter_dequeue_buffer(void *port_data)
if ((b = pop_queue(p, &p->dequeued)) == NULL) { if ((b = pop_queue(p, &p->dequeued)) == NULL) {
res = -errno; res = -errno;
pw_log_trace(NAME" %p: no more buffers: %m", impl); pw_log_trace("%p: no more buffers: %m", impl);
errno = -res; errno = -res;
return NULL; return NULL;
} }
pw_log_trace(NAME" %p: dequeue buffer %d", impl, b->id); pw_log_trace("%p: dequeue buffer %d", impl, b->id);
return &b->this; return &b->this;
} }
@ -1837,7 +1838,7 @@ int pw_filter_queue_buffer(void *port_data, struct pw_buffer *buffer)
struct buffer *b = SPA_CONTAINER_OF(buffer, struct buffer, this); struct buffer *b = SPA_CONTAINER_OF(buffer, struct buffer, this);
int res; int res;
pw_log_trace(NAME" %p: queue buffer %d", impl, b->id); pw_log_trace("%p: queue buffer %d", impl, b->id);
if ((res = push_queue(p, &p->queued, b)) < 0) if ((res = push_queue(p, &p->queued, b)) < 0)
return res; return res;
@ -1876,7 +1877,7 @@ do_flush(struct spa_loop *loop,
struct filter *impl = user_data; struct filter *impl = user_data;
struct buffer *b; struct buffer *b;
pw_log_trace(NAME" %p: flush", impl); pw_log_trace("%p: flush", impl);
do { do {
b = pop_queue(impl, &impl->queued); b = pop_queue(impl, &impl->queued);
if (b != NULL) if (b != NULL)

4
src/pipewire/log.c
View file

@ -52,6 +52,7 @@ PW_LOG_TOPIC(log_buffers, "pw.buffers");
PW_LOG_TOPIC(log_conf, "pw.conf"); PW_LOG_TOPIC(log_conf, "pw.conf");
PW_LOG_TOPIC(log_context, "pw.context"); PW_LOG_TOPIC(log_context, "pw.context");
PW_LOG_TOPIC(log_data_loop, "pw.data-loop"); PW_LOG_TOPIC(log_data_loop, "pw.data-loop");
PW_LOG_TOPIC(log_filter, "pw.filter");
PW_LOG_TOPIC(log_metadata, "pw.metadata"); PW_LOG_TOPIC(log_metadata, "pw.metadata");
PW_LOG_TOPIC(log_node, "pw.node"); PW_LOG_TOPIC(log_node, "pw.node");
PW_LOG_TOPIC(log_port, "pw.port"); PW_LOG_TOPIC(log_port, "pw.port");
@ -67,6 +68,7 @@ PW_LOG_TOPIC(log_factory, "pw.factory");
PW_LOG_TOPIC(log_module, "pw.module"); PW_LOG_TOPIC(log_module, "pw.module");
PW_LOG_TOPIC(log_device, "pw.device"); PW_LOG_TOPIC(log_device, "pw.device");
PW_LOG_TOPIC(log_resource, "pw.resource"); PW_LOG_TOPIC(log_resource, "pw.resource");
PW_LOG_TOPIC(log_stream, "pw.stream");
PW_LOG_TOPIC(log_thread_loop, "pw.thread-loop"); PW_LOG_TOPIC(log_thread_loop, "pw.thread-loop");
PW_LOG_TOPIC(PW_LOG_TOPIC_DEFAULT, "default"); PW_LOG_TOPIC(PW_LOG_TOPIC_DEFAULT, "default");
@ -426,6 +428,7 @@ pw_log_init(void)
PW_LOG_TOPIC_INIT(log_buffers); PW_LOG_TOPIC_INIT(log_buffers);
PW_LOG_TOPIC_INIT(log_conf); PW_LOG_TOPIC_INIT(log_conf);
PW_LOG_TOPIC_INIT(log_data_loop); PW_LOG_TOPIC_INIT(log_data_loop);
PW_LOG_TOPIC_INIT(log_filter);
PW_LOG_TOPIC_INIT(log_topic); PW_LOG_TOPIC_INIT(log_topic);
PW_LOG_TOPIC_INIT(log_context); PW_LOG_TOPIC_INIT(log_context);
PW_LOG_TOPIC_INIT(log_metadata); PW_LOG_TOPIC_INIT(log_metadata);
@ -443,5 +446,6 @@ pw_log_init(void)
PW_LOG_TOPIC_INIT(log_module); PW_LOG_TOPIC_INIT(log_module);
PW_LOG_TOPIC_INIT(log_device); PW_LOG_TOPIC_INIT(log_device);
PW_LOG_TOPIC_INIT(log_resource); PW_LOG_TOPIC_INIT(log_resource);
PW_LOG_TOPIC_INIT(log_stream);
PW_LOG_TOPIC_INIT(log_thread_loop); PW_LOG_TOPIC_INIT(log_thread_loop);
} }

133
src/pipewire/stream.c
View file

@ -42,7 +42,8 @@
#include "pipewire/stream.h" #include "pipewire/stream.h"
#include "pipewire/private.h" #include "pipewire/private.h"
#define NAME "stream" PW_LOG_TOPIC_EXTERN(log_stream);
#define PW_LOG_TOPIC_DEFAULT log_stream
#define MAX_BUFFERS 64 #define MAX_BUFFERS 64
@ -216,11 +217,11 @@ static void fix_datatype(const struct spa_pod *param)
if (spa_pod_get_int(&vals[0], (int32_t*)&dataType) < 0) if (spa_pod_get_int(&vals[0], (int32_t*)&dataType) < 0)
return; return;
pw_log_debug(NAME" dataType: %u", dataType); pw_log_debug("dataType: %u", dataType);
if (dataType & (1u << SPA_DATA_MemPtr)) { if (dataType & (1u << SPA_DATA_MemPtr)) {
SPA_POD_VALUE(struct spa_pod_int, &vals[0]) = SPA_POD_VALUE(struct spa_pod_int, &vals[0]) =
dataType | mappable_dataTypes; dataType | mappable_dataTypes;
pw_log_debug(NAME" Change dataType: %u -> %u", dataType, pw_log_debug("Change dataType: %u -> %u", dataType,
SPA_POD_VALUE(struct spa_pod_int, &vals[0])); SPA_POD_VALUE(struct spa_pod_int, &vals[0]));
} }
} }
@ -357,12 +358,12 @@ static bool stream_set_state(struct pw_stream *stream, enum pw_stream_state stat
free(stream->error); free(stream->error);
stream->error = error ? strdup(error) : NULL; stream->error = error ? strdup(error) : NULL;
pw_log_debug(NAME" %p: update state from %s -> %s (%s)", stream, pw_log_debug("%p: update state from %s -> %s (%s)", stream,
pw_stream_state_as_string(old), pw_stream_state_as_string(old),
pw_stream_state_as_string(state), stream->error); pw_stream_state_as_string(state), stream->error);
if (state == PW_STREAM_STATE_ERROR) if (state == PW_STREAM_STATE_ERROR)
pw_log_error(NAME" %p: error %s", stream, error); pw_log_error("%p: error %s", stream, error);
stream->state = state; stream->state = state;
pw_stream_emit_state_changed(stream, old, state, error); pw_stream_emit_state_changed(stream, old, state, error);
@ -386,14 +387,14 @@ do_call_process(struct spa_loop *loop,
{ {
struct stream *impl = user_data; struct stream *impl = user_data;
struct pw_stream *stream = &impl->this; struct pw_stream *stream = &impl->this;
pw_log_trace(NAME" %p: do process", stream); pw_log_trace("%p: do process", stream);
pw_stream_emit_process(stream); pw_stream_emit_process(stream);
return 0; return 0;
} }
static void call_process(struct stream *impl) static void call_process(struct stream *impl)
{ {
pw_log_trace(NAME" %p: call process rt:%u", impl, impl->process_rt); pw_log_trace("%p: call process rt:%u", impl, impl->process_rt);
if (impl->process_rt) if (impl->process_rt)
spa_callbacks_call(&impl->rt_callbacks, struct pw_stream_events, process, 0); spa_callbacks_call(&impl->rt_callbacks, struct pw_stream_events, process, 0);
else else
@ -407,7 +408,7 @@ do_call_drained(struct spa_loop *loop,
{ {
struct stream *impl = user_data; struct stream *impl = user_data;
struct pw_stream *stream = &impl->this; struct pw_stream *stream = &impl->this;
pw_log_trace(NAME" %p: drained", stream); pw_log_trace("%p: drained", stream);
pw_stream_emit_drained(stream); pw_stream_emit_drained(stream);
return 0; return 0;
} }
@ -432,7 +433,7 @@ static int impl_set_io(void *object, uint32_t id, void *data, size_t size)
struct stream *impl = object; struct stream *impl = object;
struct pw_stream *stream = &impl->this; struct pw_stream *stream = &impl->this;
pw_log_debug(NAME" %p: set io id %d (%s) %p %zd", impl, id, pw_log_debug("%p: set io id %d (%s) %p %zd", impl, id,
spa_debug_type_find_name(spa_type_io, id), data, size); spa_debug_type_find_name(spa_type_io, id), data, size);
switch(id) { switch(id) {
@ -476,7 +477,7 @@ static int enum_params(void *object, bool is_port, int seq, uint32_t id, uint32_
result.id = id; result.id = id;
result.next = 0; result.next = 0;
pw_log_debug(NAME" %p: param id %d (%s) start:%d num:%d", d, id, pw_log_debug("%p: param id %d (%s) start:%d num:%d", d, id,
spa_debug_type_find_name(spa_type_param, id), spa_debug_type_find_name(spa_type_param, id),
start, num); start, num);
@ -536,13 +537,13 @@ static int impl_send_command(void *object, const struct spa_command *command)
NULL, 0, NULL, 0, false, impl); NULL, 0, NULL, 0, false, impl);
if (stream->state == PW_STREAM_STATE_STREAMING) { if (stream->state == PW_STREAM_STATE_STREAMING) {
pw_log_debug(NAME" %p: pause", stream); pw_log_debug("%p: pause", stream);
stream_set_state(stream, PW_STREAM_STATE_PAUSED, NULL); stream_set_state(stream, PW_STREAM_STATE_PAUSED, NULL);
} }
break; break;
case SPA_NODE_COMMAND_Start: case SPA_NODE_COMMAND_Start:
if (stream->state == PW_STREAM_STATE_PAUSED) { if (stream->state == PW_STREAM_STATE_PAUSED) {
pw_log_debug(NAME" %p: start %d", stream, impl->direction); pw_log_debug("%p: start %d", stream, impl->direction);
if (impl->direction == SPA_DIRECTION_INPUT) if (impl->direction == SPA_DIRECTION_INPUT)
impl->io->status = SPA_STATUS_NEED_DATA; impl->io->status = SPA_STATUS_NEED_DATA;
@ -556,7 +557,7 @@ static int impl_send_command(void *object, const struct spa_command *command)
case SPA_NODE_COMMAND_ParamEnd: case SPA_NODE_COMMAND_ParamEnd:
break; break;
default: default:
pw_log_warn(NAME" %p: unhandled node command %d", stream, pw_log_warn("%p: unhandled node command %d", stream,
SPA_NODE_COMMAND_ID(command)); SPA_NODE_COMMAND_ID(command));
break; break;
} }
@ -617,7 +618,7 @@ static int impl_port_set_io(void *object, enum spa_direction direction, uint32_t
struct stream *impl = object; struct stream *impl = object;
struct pw_stream *stream = &impl->this; struct pw_stream *stream = &impl->this;
pw_log_debug(NAME" %p: set io id %d (%s) %p %zd", impl, id, pw_log_debug("%p: set io id %d (%s) %p %zd", impl, id,
spa_debug_type_find_name(spa_type_io, id), data, size); spa_debug_type_find_name(spa_type_io, id), data, size);
switch (id) { switch (id) {
@ -650,18 +651,18 @@ static int map_data(struct stream *impl, struct spa_data *data, int prot)
ptr = mmap(NULL, range.size, prot, MAP_SHARED, data->fd, range.offset); ptr = mmap(NULL, range.size, prot, MAP_SHARED, data->fd, range.offset);
if (ptr == MAP_FAILED) { if (ptr == MAP_FAILED) {
pw_log_error(NAME" %p: failed to mmap buffer mem: %m", impl); pw_log_error("%p: failed to mmap buffer mem: %m", impl);
return -errno; return -errno;
} }
data->data = SPA_PTROFF(ptr, range.start, void); data->data = SPA_PTROFF(ptr, range.start, void);
pw_log_debug(NAME" %p: fd %"PRIi64" mapped %d %d %p", impl, data->fd, pw_log_debug("%p: fd %"PRIi64" mapped %d %d %p", impl, data->fd,
range.offset, range.size, data->data); range.offset, range.size, data->data);
if (impl->allow_mlock && mlock(data->data, data->maxsize) < 0) { if (impl->allow_mlock && mlock(data->data, data->maxsize) < 0) {
if (errno != ENOMEM || !mlock_warned) { if (errno != ENOMEM || !mlock_warned) {
pw_log(impl->warn_mlock ? SPA_LOG_LEVEL_WARN : SPA_LOG_LEVEL_DEBUG, pw_log(impl->warn_mlock ? SPA_LOG_LEVEL_WARN : SPA_LOG_LEVEL_DEBUG,
NAME" %p: Failed to mlock memory %p %u: %s", impl, "%p: Failed to mlock memory %p %u: %s", impl,
data->data, data->maxsize, data->data, data->maxsize,
errno == ENOMEM ? errno == ENOMEM ?
"This is not a problem but for best performance, " "This is not a problem but for best performance, "
@ -679,9 +680,9 @@ static int unmap_data(struct stream *impl, struct spa_data *data)
pw_map_range_init(&range, data->mapoffset, data->maxsize, impl->context->sc_pagesize); pw_map_range_init(&range, data->mapoffset, data->maxsize, impl->context->sc_pagesize);
if (munmap(SPA_PTROFF(data->data, -range.start, void), range.size) < 0) if (munmap(SPA_PTROFF(data->data, -range.start, void), range.size) < 0)
pw_log_warn(NAME" %p: failed to unmap: %m", impl); pw_log_warn("%p: failed to unmap: %m", impl);
pw_log_debug(NAME" %p: fd %"PRIi64" unmapped", impl, data->fd); pw_log_debug("%p: fd %"PRIi64" unmapped", impl, data->fd);
return 0; return 0;
} }
@ -690,7 +691,7 @@ static void clear_buffers(struct pw_stream *stream)
struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this); struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this);
uint32_t i, j; uint32_t i, j;
pw_log_debug(NAME" %p: clear buffers %d", stream, impl->n_buffers); pw_log_debug("%p: clear buffers %d", stream, impl->n_buffers);
for (i = 0; i < impl->n_buffers; i++) { for (i = 0; i < impl->n_buffers; i++) {
struct buffer *b = &impl->buffers[i]; struct buffer *b = &impl->buffers[i];
@ -701,7 +702,7 @@ static void clear_buffers(struct pw_stream *stream)
if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_MAPPED)) { if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_MAPPED)) {
for (j = 0; j < b->this.buffer->n_datas; j++) { for (j = 0; j < b->this.buffer->n_datas; j++) {
struct spa_data *d = &b->this.buffer->datas[j]; struct spa_data *d = &b->this.buffer->datas[j];
pw_log_debug(NAME" %p: clear buffer %d mem", pw_log_debug("%p: clear buffer %d mem",
stream, b->id); stream, b->id);
unmap_data(impl, d); unmap_data(impl, d);
} }
@ -749,7 +750,7 @@ static int impl_port_set_param(void *object,
if (impl->disconnecting && param != NULL) if (impl->disconnecting && param != NULL)
return -EIO; return -EIO;
pw_log_debug(NAME" %p: param id %d (%s) changed: %p", impl, id, pw_log_debug("%p: param id %d (%s) changed: %p", impl, id,
spa_debug_type_find_name(spa_type_param, id), param); spa_debug_type_find_name(spa_type_param, id), param);
if (param) if (param)
@ -813,19 +814,19 @@ static int impl_port_use_buffers(void *object,
SPA_FLAG_SET(b->flags, BUFFER_FLAG_MAPPED); SPA_FLAG_SET(b->flags, BUFFER_FLAG_MAPPED);
} }
else if (d->type == SPA_DATA_MemPtr && d->data == NULL) { else if (d->type == SPA_DATA_MemPtr && d->data == NULL) {
pw_log_error(NAME" %p: invalid buffer mem", stream); pw_log_error("%p: invalid buffer mem", stream);
return -EINVAL; return -EINVAL;
} }
buf_size += d->maxsize; buf_size += d->maxsize;
} }
if (size > 0 && buf_size != size) { if (size > 0 && buf_size != size) {
pw_log_error(NAME" %p: invalid buffer size %d", stream, buf_size); pw_log_error("%p: invalid buffer size %d", stream, buf_size);
return -EINVAL; return -EINVAL;
} else } else
size = buf_size; size = buf_size;
} }
pw_log_debug(NAME" %p: got buffer id:%d datas:%d, mapped size %d", stream, i, pw_log_debug("%p: got buffer id:%d datas:%d, mapped size %d", stream, i,
buffers[i]->n_datas, size); buffers[i]->n_datas, size);
} }
@ -836,7 +837,7 @@ static int impl_port_use_buffers(void *object,
b->busy = spa_buffer_find_meta_data(buffers[i], SPA_META_Busy, sizeof(*b->busy)); b->busy = spa_buffer_find_meta_data(buffers[i], SPA_META_Busy, sizeof(*b->busy));
if (impl->direction == SPA_DIRECTION_OUTPUT) { if (impl->direction == SPA_DIRECTION_OUTPUT) {
pw_log_trace(NAME" %p: recycle buffer %d", stream, b->id); pw_log_trace("%p: recycle buffer %d", stream, b->id);
push_queue(impl, &impl->dequeued, b); push_queue(impl, &impl->dequeued, b);
} }
@ -853,7 +854,7 @@ static int impl_port_use_buffers(void *object,
static int impl_port_reuse_buffer(void *object, uint32_t port_id, uint32_t buffer_id) static int impl_port_reuse_buffer(void *object, uint32_t port_id, uint32_t buffer_id)
{ {
struct stream *d = object; struct stream *d = object;
pw_log_trace(NAME" %p: recycle buffer %d", d, buffer_id); pw_log_trace("%p: recycle buffer %d", d, buffer_id);
if (buffer_id < d->n_buffers) if (buffer_id < d->n_buffers)
push_queue(d, &d->queued, &d->buffers[buffer_id]); push_queue(d, &d->queued, &d->buffers[buffer_id]);
return 0; return 0;
@ -885,7 +886,7 @@ static int impl_node_process_input(void *object)
struct spa_io_buffers *io = impl->io; struct spa_io_buffers *io = impl->io;
struct buffer *b; struct buffer *b;
pw_log_trace(NAME" %p: process in status:%d id:%d ticks:%"PRIu64" delay:%"PRIi64, pw_log_trace("%p: process in status:%d id:%d ticks:%"PRIu64" delay:%"PRIi64,
stream, io->status, io->buffer_id, impl->time.ticks, impl->time.delay); stream, io->status, io->buffer_id, impl->time.ticks, impl->time.delay);
if (io->status == SPA_STATUS_HAVE_DATA && if (io->status == SPA_STATUS_HAVE_DATA &&
@ -901,7 +902,7 @@ static int impl_node_process_input(void *object)
if (io->status != SPA_STATUS_NEED_DATA) { if (io->status != SPA_STATUS_NEED_DATA) {
/* pop buffer to recycle */ /* pop buffer to recycle */
if ((b = pop_queue(impl, &impl->queued))) { if ((b = pop_queue(impl, &impl->queued))) {
pw_log_trace(NAME" %p: recycle buffer %d", stream, b->id); pw_log_trace("%p: recycle buffer %d", stream, b->id);
} else if (io->status == -EPIPE) } else if (io->status == -EPIPE)
return io->status; return io->status;
io->buffer_id = b ? b->id : SPA_ID_INVALID; io->buffer_id = b ? b->id : SPA_ID_INVALID;
@ -920,13 +921,13 @@ static int impl_node_process_output(void *object)
uint32_t index; uint32_t index;
again: again:
pw_log_trace(NAME" %p: process out status:%d id:%d", stream, pw_log_trace("%p: process out status:%d id:%d", stream,
io->status, io->buffer_id); io->status, io->buffer_id);
if ((res = io->status) != SPA_STATUS_HAVE_DATA) { if ((res = io->status) != SPA_STATUS_HAVE_DATA) {
/* recycle old buffer */ /* recycle old buffer */
if ((b = get_buffer(stream, io->buffer_id)) != NULL) { if ((b = get_buffer(stream, io->buffer_id)) != NULL) {
pw_log_trace(NAME" %p: recycle buffer %d", stream, b->id); pw_log_trace("%p: recycle buffer %d", stream, b->id);
push_queue(impl, &impl->dequeued, b); push_queue(impl, &impl->dequeued, b);
} }
@ -935,17 +936,17 @@ again:
impl->drained = false; impl->drained = false;
io->buffer_id = b->id; io->buffer_id = b->id;
res = io->status = SPA_STATUS_HAVE_DATA; res = io->status = SPA_STATUS_HAVE_DATA;
pw_log_trace(NAME" %p: pop %d %p", stream, b->id, io); pw_log_trace("%p: pop %d %p", stream, b->id, io);
} else if (impl->draining || impl->drained) { } else if (impl->draining || impl->drained) {
impl->draining = true; impl->draining = true;
impl->drained = true; impl->drained = true;
io->buffer_id = SPA_ID_INVALID; io->buffer_id = SPA_ID_INVALID;
res = io->status = SPA_STATUS_DRAINED; res = io->status = SPA_STATUS_DRAINED;
pw_log_trace(NAME" %p: draining", stream); pw_log_trace("%p: draining", stream);
} else { } else {
io->buffer_id = SPA_ID_INVALID; io->buffer_id = SPA_ID_INVALID;
res = io->status = SPA_STATUS_NEED_DATA; res = io->status = SPA_STATUS_NEED_DATA;
pw_log_trace(NAME" %p: no more buffers %p", stream, io); pw_log_trace("%p: no more buffers %p", stream, io);
} }
} }
@ -969,7 +970,7 @@ again:
} }
} }
pw_log_trace(NAME" %p: res %d", stream, res); pw_log_trace("%p: res %d", stream, res);
return res; return res;
} }
@ -992,7 +993,7 @@ static const struct spa_node_methods impl_node = {
static void proxy_removed(void *_data) static void proxy_removed(void *_data)
{ {
struct pw_stream *stream = _data; struct pw_stream *stream = _data;
pw_log_debug(NAME" %p: removed", stream); pw_log_debug("%p: removed", stream);
spa_hook_remove(&stream->proxy_listener); spa_hook_remove(&stream->proxy_listener);
stream->node_id = SPA_ID_INVALID; stream->node_id = SPA_ID_INVALID;
stream_set_state(stream, PW_STREAM_STATE_UNCONNECTED, NULL); stream_set_state(stream, PW_STREAM_STATE_UNCONNECTED, NULL);
@ -1001,7 +1002,7 @@ static void proxy_removed(void *_data)
static void proxy_destroy(void *_data) static void proxy_destroy(void *_data)
{ {
struct pw_stream *stream = _data; struct pw_stream *stream = _data;
pw_log_debug(NAME" %p: destroy", stream); pw_log_debug("%p: destroy", stream);
proxy_removed(_data); proxy_removed(_data);
} }
@ -1116,7 +1117,7 @@ static int node_event_param(void *object, int seq,
} }
c->id = iid; c->id = iid;
pw_log_debug(NAME" %p: add control %d (%s) container:%d (def:%f min:%f max:%f)", pw_log_debug("%p: add control %d (%s) container:%d (def:%f min:%f max:%f)",
stream, c->id, c->control.name, c->container, stream, c->id, c->control.name, c->container,
c->control.def, c->control.min, c->control.max); c->control.def, c->control.min, c->control.max);
break; break;
@ -1170,10 +1171,10 @@ static int node_event_param(void *object, int seq,
c->control.n_values = n_values; c->control.n_values = n_values;
c->emitted = true; c->emitted = true;
pw_log_debug(NAME" %p: control %d (%s) changed %d:", stream, pw_log_debug("%p: control %d (%s) changed %d:", stream,
prop->key, c->control.name, n_values); prop->key, c->control.name, n_values);
for (i = 0; i < n_values; i++) for (i = 0; i < n_values; i++)
pw_log_debug(NAME" %p: value %d %f", stream, i, values[i]); pw_log_debug("%p: value %d %f", stream, i, values[i]);
pw_stream_emit_control_info(stream, prop->key, &c->control); pw_stream_emit_control_info(stream, prop->key, &c->control);
} }
@ -1219,7 +1220,7 @@ static void on_core_error(void *object, uint32_t id, int seq, int res, const cha
{ {
struct pw_stream *stream = object; struct pw_stream *stream = object;
pw_log_debug(NAME" %p: error id:%u seq:%d res:%d (%s): %s", stream, pw_log_debug("%p: error id:%u seq:%d res:%d (%s): %s", stream,
id, seq, res, spa_strerror(res), message); id, seq, res, spa_strerror(res), message);
if (id == PW_ID_CORE && res == -EPIPE) { if (id == PW_ID_CORE && res == -EPIPE) {
@ -1270,7 +1271,7 @@ stream_new(struct pw_context *context, const char *name,
} }
this = &impl->this; this = &impl->this;
pw_log_debug(NAME" %p: new \"%s\"", impl, name); pw_log_debug("%p: new \"%s\"", impl, name);
if (props == NULL) { if (props == NULL) {
props = pw_properties_new(PW_KEY_MEDIA_NAME, name, NULL); props = pw_properties_new(PW_KEY_MEDIA_NAME, name, NULL);
@ -1421,7 +1422,7 @@ void pw_stream_destroy(struct pw_stream *stream)
struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this); struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this);
struct control *c; struct control *c;
pw_log_debug(NAME" %p: destroy", stream); pw_log_debug("%p: destroy", stream);
pw_stream_emit_destroy(stream); pw_stream_emit_destroy(stream);
@ -1436,7 +1437,7 @@ void pw_stream_destroy(struct pw_stream *stream)
clear_params(impl, SPA_ID_INVALID); clear_params(impl, SPA_ID_INVALID);
pw_log_debug(NAME" %p: free", stream); pw_log_debug("%p: free", stream);
free(stream->error); free(stream->error);
pw_properties_free(stream->properties); pw_properties_free(stream->properties);
@ -1561,14 +1562,14 @@ static int find_format(struct stream *impl, enum pw_direction direction,
impl->direction, 0, impl->direction, 0,
SPA_PARAM_EnumFormat, &state, SPA_PARAM_EnumFormat, &state,
NULL, &format, &b) != 1) { NULL, &format, &b) != 1) {
pw_log_warn(NAME" %p: no format given", impl); pw_log_warn("%p: no format given", impl);
return 0; return 0;
} }
if ((res = spa_format_parse(format, media_type, media_subtype)) < 0) if ((res = spa_format_parse(format, media_type, media_subtype)) < 0)
return res; return res;
pw_log_debug(NAME " %p: %s/%s", impl, pw_log_debug("%p: %s/%s", impl,
spa_debug_type_find_name(spa_type_media_type, *media_type), spa_debug_type_find_name(spa_type_media_type, *media_type),
spa_debug_type_find_name(spa_type_media_subtype, *media_subtype)); spa_debug_type_find_name(spa_type_media_subtype, *media_subtype));
return 0; return 0;
@ -1615,7 +1616,7 @@ pw_stream_connect(struct pw_stream *stream,
uint32_t i; uint32_t i;
int res; int res;
pw_log_debug(NAME" %p: connect target:%d", stream, target_id); pw_log_debug("%p: connect target:%d", stream, target_id);
impl->direction = impl->direction =
direction == PW_DIRECTION_INPUT ? SPA_DIRECTION_INPUT : SPA_DIRECTION_OUTPUT; direction == PW_DIRECTION_INPUT ? SPA_DIRECTION_INPUT : SPA_DIRECTION_OUTPUT;
impl->flags = flags; impl->flags = flags;
@ -1737,7 +1738,7 @@ pw_stream_connect(struct pw_stream *stream,
impl->disconnect_core = true; impl->disconnect_core = true;
} }
pw_log_debug(NAME" %p: creating node", stream); pw_log_debug("%p: creating node", stream);
props = pw_properties_copy(stream->properties); props = pw_properties_copy(stream->properties);
if (props == NULL) { if (props == NULL) {
res = -errno; res = -errno;
@ -1761,7 +1762,7 @@ pw_stream_connect(struct pw_stream *stream,
if (impl->media_type == SPA_MEDIA_TYPE_audio) { if (impl->media_type == SPA_MEDIA_TYPE_audio) {
factory = pw_context_find_factory(impl->context, "adapter"); factory = pw_context_find_factory(impl->context, "adapter");
if (factory == NULL) { if (factory == NULL) {
pw_log_error(NAME" %p: no adapter factory found", stream); pw_log_error("%p: no adapter factory found", stream);
res = -ENOENT; res = -ENOENT;
goto error_node; goto error_node;
} }
@ -1786,7 +1787,7 @@ pw_stream_connect(struct pw_stream *stream,
pw_impl_node_set_active(impl->node, pw_impl_node_set_active(impl->node,
!SPA_FLAG_IS_SET(impl->flags, PW_STREAM_FLAG_INACTIVE)); !SPA_FLAG_IS_SET(impl->flags, PW_STREAM_FLAG_INACTIVE));
pw_log_debug(NAME" %p: export node %p", stream, impl->node); pw_log_debug("%p: export node %p", stream, impl->node);
stream->proxy = pw_core_export(stream->core, stream->proxy = pw_core_export(stream->core,
PW_TYPE_INTERFACE_Node, NULL, impl->node, 0); PW_TYPE_INTERFACE_Node, NULL, impl->node, 0);
if (stream->proxy == NULL) { if (stream->proxy == NULL) {
@ -1801,13 +1802,13 @@ pw_stream_connect(struct pw_stream *stream,
return 0; return 0;
error_connect: error_connect:
pw_log_error(NAME" %p: can't connect: %s", stream, spa_strerror(res)); pw_log_error("%p: can't connect: %s", stream, spa_strerror(res));
goto exit_cleanup; goto exit_cleanup;
error_node: error_node:
pw_log_error(NAME" %p: can't make node: %s", stream, spa_strerror(res)); pw_log_error("%p: can't make node: %s", stream, spa_strerror(res));
goto exit_cleanup; goto exit_cleanup;
error_proxy: error_proxy:
pw_log_error(NAME" %p: can't make proxy: %s", stream, spa_strerror(res)); pw_log_error("%p: can't make proxy: %s", stream, spa_strerror(res));
goto exit_cleanup; goto exit_cleanup;
exit_cleanup: exit_cleanup:
@ -1826,7 +1827,7 @@ int pw_stream_disconnect(struct pw_stream *stream)
{ {
struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this); struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this);
pw_log_debug(NAME" %p: disconnect", stream); pw_log_debug("%p: disconnect", stream);
if (impl->disconnecting) if (impl->disconnecting)
return 0; return 0;
@ -1887,7 +1888,7 @@ int pw_stream_update_params(struct pw_stream *stream,
struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this); struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this);
int res; int res;
pw_log_debug(NAME" %p: update params", stream); pw_log_debug("%p: update params", stream);
if ((res = update_params(impl, SPA_ID_INVALID, params, n_params)) < 0) if ((res = update_params(impl, SPA_ID_INVALID, params, n_params)) < 0)
return res; return res;
@ -1912,7 +1913,7 @@ int pw_stream_set_control(struct pw_stream *stream, uint32_t id, uint32_t n_valu
spa_pod_builder_push_object(&b, &f[0], SPA_TYPE_OBJECT_Props, SPA_PARAM_Props); spa_pod_builder_push_object(&b, &f[0], SPA_TYPE_OBJECT_Props, SPA_PARAM_Props);
while (1) { while (1) {
pw_log_debug(NAME" %p: set control %d %d %f", stream, id, n_values, values[0]); pw_log_debug("%p: set control %d %d %f", stream, id, n_values, values[0]);
if ((c = find_control(stream, id))) { if ((c = find_control(stream, id))) {
spa_pod_builder_prop(&b, id, 0); spa_pod_builder_prop(&b, id, 0);
@ -1933,7 +1934,7 @@ int pw_stream_set_control(struct pw_stream *stream, uint32_t id, uint32_t n_valu
break; break;
} }
} else { } else {
pw_log_warn(NAME" %p: unknown control with id %d", stream, id); pw_log_warn("%p: unknown control with id %d", stream, id);
} }
if ((id = va_arg(varargs, uint32_t)) == 0) if ((id = va_arg(varargs, uint32_t)) == 0)
break; break;
@ -1967,7 +1968,7 @@ SPA_EXPORT
int pw_stream_set_active(struct pw_stream *stream, bool active) int pw_stream_set_active(struct pw_stream *stream, bool active)
{ {
struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this); struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this);
pw_log_debug(NAME" %p: active:%d", stream, active); pw_log_debug("%p: active:%d", stream, active);
if (impl->node) if (impl->node)
pw_impl_node_set_active(impl->node, active); pw_impl_node_set_active(impl->node, active);
@ -1997,7 +1998,7 @@ int pw_stream_get_time(struct pw_stream *stream, struct pw_time *time)
time->delay += (impl->latency.min_rate + impl->latency.max_rate) / 2; time->delay += (impl->latency.min_rate + impl->latency.max_rate) / 2;
time->delay += ((impl->latency.min_ns + impl->latency.max_ns) / 2) * time->rate.denom / SPA_NSEC_PER_SEC; time->delay += ((impl->latency.min_ns + impl->latency.max_ns) / 2) * time->rate.denom / SPA_NSEC_PER_SEC;
pw_log_trace(NAME" %p: %"PRIi64" %"PRIi64" %"PRIu64" %d/%d %"PRIu64" %" pw_log_trace("%p: %"PRIi64" %"PRIi64" %"PRIu64" %d/%d %"PRIu64" %"
PRIu64" %"PRIu64" %"PRIu64" %"PRIu64, stream, PRIu64" %"PRIu64" %"PRIu64" %"PRIu64, stream,
time->now, time->delay, time->ticks, time->now, time->delay, time->ticks,
time->rate.num, time->rate.denom, time->queued, time->rate.num, time->rate.denom, time->queued,
@ -2025,17 +2026,17 @@ struct pw_buffer *pw_stream_dequeue_buffer(struct pw_stream *stream)
if ((b = pop_queue(impl, &impl->dequeued)) == NULL) { if ((b = pop_queue(impl, &impl->dequeued)) == NULL) {
res = -errno; res = -errno;
pw_log_trace(NAME" %p: no more buffers: %m", stream); pw_log_trace("%p: no more buffers: %m", stream);
errno = -res; errno = -res;
return NULL; return NULL;
} }
pw_log_trace(NAME" %p: dequeue buffer %d", stream, b->id); pw_log_trace("%p: dequeue buffer %d", stream, b->id);
if (b->busy && impl->direction == SPA_DIRECTION_OUTPUT) { if (b->busy && impl->direction == SPA_DIRECTION_OUTPUT) {
if (ATOMIC_INC(b->busy->count) > 1) { if (ATOMIC_INC(b->busy->count) > 1) {
ATOMIC_DEC(b->busy->count); ATOMIC_DEC(b->busy->count);
push_queue(impl, &impl->dequeued, b); push_queue(impl, &impl->dequeued, b);
pw_log_trace(NAME" %p: buffer busy", stream); pw_log_trace("%p: buffer busy", stream);
errno = EBUSY; errno = EBUSY;
return NULL; return NULL;
} }
@ -2053,7 +2054,7 @@ int pw_stream_queue_buffer(struct pw_stream *stream, struct pw_buffer *buffer)
if (b->busy) if (b->busy)
ATOMIC_DEC(b->busy->count); ATOMIC_DEC(b->busy->count);
pw_log_trace(NAME" %p: queue buffer %d", stream, b->id); pw_log_trace("%p: queue buffer %d", stream, b->id);
if ((res = push_queue(impl, &impl->queued, b)) < 0) if ((res = push_queue(impl, &impl->queued, b)) < 0)
return res; return res;
@ -2073,7 +2074,7 @@ do_flush(struct spa_loop *loop,
struct stream *impl = user_data; struct stream *impl = user_data;
struct buffer *b; struct buffer *b;
pw_log_trace(NAME" %p: flush", impl); pw_log_trace("%p: flush", impl);
do { do {
b = pop_queue(impl, &impl->queued); b = pop_queue(impl, &impl->queued);
if (b != NULL) if (b != NULL)
@ -2091,7 +2092,7 @@ do_drain(struct spa_loop *loop,
bool async, uint32_t seq, const void *data, size_t size, void *user_data) bool async, uint32_t seq, const void *data, size_t size, void *user_data)
{ {
struct stream *impl = user_data; struct stream *impl = user_data;
pw_log_trace(NAME" %p", impl); pw_log_trace("%p", impl);
impl->draining = true; impl->draining = true;
impl->drained = false; impl->drained = false;
return 0; return 0;
@ -2138,7 +2139,7 @@ int pw_stream_trigger_process(struct pw_stream *stream)
struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this); struct stream *impl = SPA_CONTAINER_OF(stream, struct stream, this);
int res = 0; int res = 0;
pw_log_trace(NAME" %p", impl); pw_log_trace("%p", impl);
/* flag to check for old or new behaviour */ /* flag to check for old or new behaviour */
impl->using_trigger = true; impl->using_trigger = true;