mirror of
https://gitlab.freedesktop.org/pipewire/pipewire.git
synced 2025-11-02 09:01:50 -05:00
flags: change flag macros
SPA_FLAG_CHECK -> SPA_FLAG_IS_SET SPA_FLAG_UNSET -> SPA_FLAG_CLEAR Add SPA_FLAG_UPDATE
This commit is contained in:
parent
cc8e992cd1
commit
6e0ffb0c47
33 changed files with 91 additions and 92 deletions
|
|
@ -681,8 +681,8 @@ static int negotiate_buffers(struct impl *this)
|
|||
slave_flags = this->slave_flags;
|
||||
conv_flags = this->convert_flags;
|
||||
|
||||
slave_alloc = SPA_FLAG_CHECK(slave_flags, SPA_PORT_FLAG_CAN_ALLOC_BUFFERS);
|
||||
conv_alloc = SPA_FLAG_CHECK(conv_flags, SPA_PORT_FLAG_CAN_ALLOC_BUFFERS);
|
||||
slave_alloc = SPA_FLAG_IS_SET(slave_flags, SPA_PORT_FLAG_CAN_ALLOC_BUFFERS);
|
||||
conv_alloc = SPA_FLAG_IS_SET(conv_flags, SPA_PORT_FLAG_CAN_ALLOC_BUFFERS);
|
||||
|
||||
flags = 0;
|
||||
if (conv_alloc || slave_alloc) {
|
||||
|
|
|
|||
|
|
@ -322,9 +322,9 @@ static int negotiate_link_buffers(struct impl *this, struct link *link)
|
|||
|
||||
spa_pod_fixate(param);
|
||||
|
||||
in_alloc = SPA_FLAG_CHECK(link->in_flags,
|
||||
in_alloc = SPA_FLAG_IS_SET(link->in_flags,
|
||||
SPA_PORT_FLAG_CAN_ALLOC_BUFFERS);
|
||||
out_alloc = SPA_FLAG_CHECK(link->out_flags,
|
||||
out_alloc = SPA_FLAG_IS_SET(link->out_flags,
|
||||
SPA_PORT_FLAG_CAN_ALLOC_BUFFERS);
|
||||
|
||||
flags = 0;
|
||||
|
|
|
|||
|
|
@ -761,7 +761,7 @@ impl_node_port_use_buffers(void *object,
|
|||
}
|
||||
b->datas[j] = d[j].data;
|
||||
if (direction == SPA_DIRECTION_OUTPUT &&
|
||||
!SPA_FLAG_CHECK(d[j].flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
!SPA_FLAG_IS_SET(d[j].flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
this->is_passthrough = false;
|
||||
}
|
||||
if (direction == SPA_DIRECTION_OUTPUT)
|
||||
|
|
@ -803,9 +803,9 @@ static void recycle_buffer(struct impl *this, uint32_t id)
|
|||
struct port *port = GET_OUT_PORT(this, 0);
|
||||
struct buffer *b = &port->buffers[id];
|
||||
|
||||
if (SPA_FLAG_CHECK(b->flags, BUFFER_FLAG_OUT)) {
|
||||
if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_OUT)) {
|
||||
spa_list_append(&port->queue, &b->link);
|
||||
SPA_FLAG_UNSET(b->flags, BUFFER_FLAG_OUT);
|
||||
SPA_FLAG_CLEAR(b->flags, BUFFER_FLAG_OUT);
|
||||
spa_log_trace_fp(this->log, NAME " %p: recycle buffer %d", this, id);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -376,7 +376,7 @@ static int port_enum_formats(void *object,
|
|||
SPA_FORMAT_AUDIO_rate, SPA_POD_Int(info.info.raw.rate),
|
||||
SPA_FORMAT_AUDIO_channels, SPA_POD_Int(info.info.raw.channels),
|
||||
0);
|
||||
if (!SPA_FLAG_CHECK(info.info.raw.flags, SPA_AUDIO_FLAG_UNPOSITIONED)) {
|
||||
if (!SPA_FLAG_IS_SET(info.info.raw.flags, SPA_AUDIO_FLAG_UNPOSITIONED)) {
|
||||
qsort(info.info.raw.position, info.info.raw.channels,
|
||||
sizeof(uint32_t), int32_cmp);
|
||||
spa_pod_builder_prop(builder, SPA_FORMAT_AUDIO_position, 0);
|
||||
|
|
@ -703,7 +703,7 @@ impl_node_port_use_buffers(void *object,
|
|||
}
|
||||
b->datas[j] = d[j].data;
|
||||
if (direction == SPA_DIRECTION_OUTPUT &&
|
||||
!SPA_FLAG_CHECK(d[j].flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
!SPA_FLAG_IS_SET(d[j].flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
this->is_passthrough = false;
|
||||
}
|
||||
|
||||
|
|
@ -750,9 +750,9 @@ static void recycle_buffer(struct impl *this, struct port *port, uint32_t id)
|
|||
{
|
||||
struct buffer *b = &port->buffers[id];
|
||||
|
||||
if (SPA_FLAG_CHECK(b->flags, BUFFER_FLAG_OUT)) {
|
||||
if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_OUT)) {
|
||||
spa_list_append(&port->queue, &b->link);
|
||||
SPA_FLAG_UNSET(b->flags, BUFFER_FLAG_OUT);
|
||||
SPA_FLAG_CLEAR(b->flags, BUFFER_FLAG_OUT);
|
||||
spa_log_trace_fp(this->log, NAME " %p: recycle buffer %d", this, id);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -724,7 +724,7 @@ static void queue_buffer(struct impl *this, struct port *port, uint32_t id)
|
|||
|
||||
spa_log_trace_fp(this->log, NAME " %p: queue buffer %d on port %d %d",
|
||||
this, id, port->id, b->flags);
|
||||
if (SPA_FLAG_CHECK(b->flags, BUFFER_FLAG_QUEUED))
|
||||
if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_QUEUED))
|
||||
return;
|
||||
|
||||
spa_list_append(&port->queue, &b->link);
|
||||
|
|
@ -740,7 +740,7 @@ static struct buffer *dequeue_buffer(struct impl *this, struct port *port)
|
|||
|
||||
b = spa_list_first(&port->queue, struct buffer, link);
|
||||
spa_list_remove(&b->link);
|
||||
SPA_FLAG_UNSET(b->flags, BUFFER_FLAG_QUEUED);
|
||||
SPA_FLAG_CLEAR(b->flags, BUFFER_FLAG_QUEUED);
|
||||
spa_log_trace_fp(this->log, NAME " %p: dequeue buffer %d on port %d %u",
|
||||
this, b->id, port->id, b->flags);
|
||||
|
||||
|
|
@ -802,7 +802,7 @@ impl_node_port_use_buffers(void *object,
|
|||
}
|
||||
b->datas[j] = d[j].data;
|
||||
if (direction == SPA_DIRECTION_OUTPUT &&
|
||||
!SPA_FLAG_CHECK(d[j].flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
!SPA_FLAG_IS_SET(d[j].flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
this->is_passthrough = false;
|
||||
}
|
||||
|
||||
|
|
@ -915,7 +915,7 @@ static inline int handle_monitor(struct impl *this, const void *data, int n_samp
|
|||
|
||||
spa_log_trace(this->log, "%p: io %p %08x", this, outport->io, dd->flags);
|
||||
|
||||
if (SPA_FLAG_CHECK(dd->flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
if (SPA_FLAG_IS_SET(dd->flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
dd->data = (void*)data;
|
||||
else
|
||||
memcpy(dd->data, data, size);
|
||||
|
|
|
|||
|
|
@ -123,15 +123,15 @@ static void impl_native_update_rate(struct resample *r, double rate)
|
|||
|
||||
data->func = is_full ? do_resample_full_c : do_resample_inter_c;
|
||||
#if defined (HAVE_SSE)
|
||||
if (SPA_FLAG_CHECK(r->cpu_flags, SPA_CPU_FLAG_SSE))
|
||||
if (SPA_FLAG_IS_SET(r->cpu_flags, SPA_CPU_FLAG_SSE))
|
||||
data->func = is_full ? do_resample_full_sse : do_resample_inter_sse;
|
||||
#endif
|
||||
#if defined (HAVE_SSSE3)
|
||||
if (SPA_FLAG_CHECK(r->cpu_flags, SPA_CPU_FLAG_SSSE3 | SPA_CPU_FLAG_SLOW_UNALIGNED))
|
||||
if (SPA_FLAG_IS_SET(r->cpu_flags, SPA_CPU_FLAG_SSSE3 | SPA_CPU_FLAG_SLOW_UNALIGNED))
|
||||
data->func = is_full ? do_resample_full_ssse3 : do_resample_inter_ssse3;
|
||||
#endif
|
||||
#if defined(HAVE_AVX) && defined(HAVE_FMA)
|
||||
if (SPA_FLAG_CHECK(r->cpu_flags, SPA_CPU_FLAG_AVX | SPA_CPU_FLAG_FMA3))
|
||||
if (SPA_FLAG_IS_SET(r->cpu_flags, SPA_CPU_FLAG_AVX | SPA_CPU_FLAG_FMA3))
|
||||
data->func = is_full ? do_resample_full_avx : do_resample_inter_avx;
|
||||
#endif
|
||||
}
|
||||
|
|
|
|||
|
|
@ -658,9 +658,9 @@ static void recycle_buffer(struct impl *this, uint32_t id)
|
|||
struct port *port = GET_OUT_PORT(this, 0);
|
||||
struct buffer *b = &port->buffers[id];
|
||||
|
||||
if (SPA_FLAG_CHECK(b->flags, BUFFER_FLAG_OUT)) {
|
||||
if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_OUT)) {
|
||||
spa_list_append(&port->queue, &b->link);
|
||||
SPA_FLAG_UNSET(b->flags, BUFFER_FLAG_OUT);
|
||||
SPA_FLAG_CLEAR(b->flags, BUFFER_FLAG_OUT);
|
||||
spa_log_trace_fp(this->log, NAME " %p: recycle buffer %d", this, id);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
|
|
@ -688,7 +688,7 @@ static void queue_buffer(struct impl *this, struct port *port, uint32_t id)
|
|||
|
||||
spa_log_trace_fp(this->log, NAME " %p: queue buffer %d on port %d %d",
|
||||
this, id, port->id, b->flags);
|
||||
if (SPA_FLAG_CHECK(b->flags, BUFFER_FLAG_QUEUED))
|
||||
if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_QUEUED))
|
||||
return;
|
||||
|
||||
spa_list_append(&port->queue, &b->link);
|
||||
|
|
@ -704,7 +704,7 @@ static struct buffer *dequeue_buffer(struct impl *this, struct port *port)
|
|||
|
||||
b = spa_list_first(&port->queue, struct buffer, link);
|
||||
spa_list_remove(&b->link);
|
||||
SPA_FLAG_UNSET(b->flags, BUFFER_FLAG_QUEUED);
|
||||
SPA_FLAG_CLEAR(b->flags, BUFFER_FLAG_QUEUED);
|
||||
spa_log_trace_fp(this->log, NAME " %p: dequeue buffer %d on port %d %u",
|
||||
this, b->id, port->id, b->flags);
|
||||
|
||||
|
|
@ -758,7 +758,7 @@ impl_node_port_use_buffers(void *object,
|
|||
}
|
||||
b->datas[j] = d[j].data;
|
||||
if (direction == SPA_DIRECTION_OUTPUT &&
|
||||
!SPA_FLAG_CHECK(d[j].flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
!SPA_FLAG_IS_SET(d[j].flags, SPA_DATA_FLAG_DYNAMIC))
|
||||
this->is_passthrough = false;
|
||||
|
||||
spa_log_debug(this->log, NAME " %p: buffer %d data %d flags:%08x %p",
|
||||
|
|
|
|||
|
|
@ -618,9 +618,9 @@ impl_node_port_set_param(void *object,
|
|||
|
||||
static void recycle_buffer(struct impl *this, struct port *port, struct buffer *b)
|
||||
{
|
||||
if (SPA_FLAG_CHECK(b->flags, BUFFER_FLAG_OUT)) {
|
||||
if (SPA_FLAG_IS_SET(b->flags, BUFFER_FLAG_OUT)) {
|
||||
spa_list_append(&port->queue, &b->link);
|
||||
SPA_FLAG_UNSET(b->flags, BUFFER_FLAG_OUT);
|
||||
SPA_FLAG_CLEAR(b->flags, BUFFER_FLAG_OUT);
|
||||
spa_log_trace_fp(this->log, NAME " %p: recycle buffer %d", this, b->id);
|
||||
}
|
||||
}
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue