mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-01 22:58:50 -04:00
Code Issues Projects Releases Packages Wiki Activity Actions

v4l2: we set clock and position on the node now

Browse source
This commit is contained in:
Wim Taymans 2018-10-27 10:11:27 +01:00
parent a4ff7296b2
commit 9a969ac756
2 changed files with 24 additions and 9 deletions
Download patch file Download diff file Expand all files Collapse all files

25
spa/plugins/v4l2/v4l2-source.c
View file

@ -108,7 +108,6 @@ struct port {
struct spa_port_info info;
struct spa_io_buffers *io;
struct spa_io_clock *clock;
struct spa_io_sequence *control;
};
@ -128,6 +127,9 @@ struct impl {
void *callbacks_data;
struct port out_ports[1];
struct spa_io_position *position;
struct spa_io_clock *clock;
};
#define CHECK_PORT(this,direction,port_id) ((direction) == SPA_DIRECTION_OUTPUT && (port_id) == 0)
@ -267,7 +269,23 @@ static int impl_node_set_param(struct spa_node *node,
static int impl_node_set_io(struct spa_node *node, uint32_t id, void *data, size_t size)
{
return -ENOTSUP;
struct impl *this;
spa_return_val_if_fail(node != NULL, -EINVAL);
this = SPA_CONTAINER_OF(node, struct impl, node);
switch (id) {
case SPA_IO_Clock:
this->clock = data;
break;
case SPA_IO_Position:
this->position = data;
break;
default:
return -ENOENT;
}
return 0;
}
static int impl_node_send_command(struct spa_node *node, const struct spa_command *command)
@ -747,9 +765,6 @@ static int impl_node_port_set_io(struct spa_node *node,
case SPA_IO_Buffers:
port->io = data;
break;
case SPA_IO_Clock:
port->clock = data;
break;
case SPA_IO_Control:
port->control = data;
break;

8
spa/plugins/v4l2/v4l2-utils.c
View file

@ -1154,10 +1154,10 @@ static int mmap_read(struct impl *this)
pts = SPA_TIMEVAL_TO_TIME(&buf.timestamp);
if (port->clock) {
port->clock->nsec = pts;
port->clock->rate = port->rate;
port->clock->position = buf.sequence;
if (this->clock) {
this->clock->nsec = pts;
this->clock->rate = port->rate;
this->clock->position = buf.sequence;
}
b = &port->buffers[buf.index];