mirror of
https://gitlab.freedesktop.org/pipewire/pipewire.git
synced 2026-04-09 08:21:08 -04:00
d5e2cc94cd
Get the clock pointer using the io_changed stream event. and update the clock before triggering the process The clock needs to be updated in the data loop thread and before triggering the process so move the calls to `pw_stream_trigger_process` from gstreamer thread context into the data loop thread context by invoking a callback and update the clock inside the data loop callback before the trigger
64 lines
1.5 KiB
C
64 lines
1.5 KiB
C
/* GStreamer */
|
|
/* SPDX-FileCopyrightText: Copyright © 2018 Wim Taymans */
|
|
/* SPDX-FileCopyrightText: Copyright © 2024 Collabora Ltd. */
|
|
/* SPDX-License-Identifier: MIT */
|
|
|
|
#ifndef __GST_PIPEWIRE_STREAM_H__
|
|
#define __GST_PIPEWIRE_STREAM_H__
|
|
|
|
#include "config.h"
|
|
|
|
#include "gstpipewirecore.h"
|
|
|
|
#include <gst/gst.h>
|
|
#include <spa/utils/dll.h>
|
|
#include <pipewire/pipewire.h>
|
|
|
|
G_BEGIN_DECLS
|
|
|
|
typedef struct _GstPipeWirePool GstPipeWirePool;
|
|
|
|
#define GST_TYPE_PIPEWIRE_STREAM (gst_pipewire_stream_get_type())
|
|
G_DECLARE_FINAL_TYPE(GstPipeWireStream, gst_pipewire_stream, GST, PIPEWIRE_STREAM, GstObject)
|
|
|
|
struct _GstPipeWireStream {
|
|
GstObject parent;
|
|
|
|
/* relatives */
|
|
GstElement *element;
|
|
GstPipeWireCore *core;
|
|
GstPipeWirePool *pool;
|
|
GstClock *clock;
|
|
|
|
guint64 position;
|
|
guint64 buf_duration;
|
|
struct spa_dll dll;
|
|
double err_avg, err_var, err_wdw;
|
|
guint64 last_ts;
|
|
guint64 base_buffer_ts;
|
|
guint64 base_ts;
|
|
|
|
/* the actual pw stream */
|
|
struct pw_stream *pwstream;
|
|
struct spa_hook pwstream_listener;
|
|
|
|
struct spa_io_position *io_position;
|
|
|
|
/* common properties */
|
|
int fd;
|
|
gchar *path;
|
|
gchar *target_object;
|
|
gchar *client_name;
|
|
GstStructure *client_properties;
|
|
GstStructure *stream_properties;
|
|
};
|
|
|
|
GstPipeWireStream * gst_pipewire_stream_new (GstElement * element);
|
|
|
|
gboolean gst_pipewire_stream_open (GstPipeWireStream * self,
|
|
const struct pw_stream_events * pwstream_events);
|
|
void gst_pipewire_stream_close (GstPipeWireStream * self);
|
|
|
|
G_END_DECLS
|
|
|
|
#endif /* __GST_PIPEWIRE_STREAM_H__ */
|