mirrors/pipewire
1
0
Fork 0
mirror of https://gitlab.freedesktop.org/pipewire/pipewire.git synced 2025-11-15 07:00:05 -05:00
Code Issues Projects Releases Packages Wiki Activity Actions
pipewire/src/gst/gstpipewiresrc.h

104 lines
2.2 KiB
C
Raw Normal View History

treewide: use SPDX tags to specify copyright information SPDX tags make the licensing information easy to understand and clear, and they are machine parseable. See https://spdx.dev for more information.
2023-02-08 18:12:00 +01:00
/* GStreamer */
/* SPDX-FileCopyrightText: Copyright © 2018 Wim Taymans */
/* SPDX-License-Identifier: MIT */
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
pinos -> pipewire
2017-05-23 19:15:33 +02:00
#ifndef __GST_PIPEWIRE_SRC_H__
#define __GST_PIPEWIRE_SRC_H__
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
gst: Add support for DMA_DRM / explicit modifiers Gstreamer 1.24 added and largely switched to a new, modifier aware DMABuf API. Unfortunately that breaks the existing DMABuf support in the PW Gst element. Add support for the new API.
2024-02-02 02:20:29 +01:00
#include "config.h"
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
#include <gst/gst.h>
#include <gst/base/gstpushsrc.h>
gst: add buffer video meta support Fixes video buffer strides handling. This enables passing of image datas with right line padding.
2023-02-03 13:02:49 +08:00
#include <gst/video/video.h>
move things around
2017-07-11 15:57:20 +02:00
#include <pipewire/pipewire.h>
stream: improve stream API Simplify the stream API. make just 2 methods to queue and dequeue buffers. Make just one callback when new buffers can be dequeued. Add support for driver nodes such as the video-src. Pass a pw_buffer structure to add/remove_buffer and make it possible to attach metadata to it. This makes it a lot easier to implement the gstreamer pipewire pool. Call the stream process function from the main loop and use a lockfree ringbuffer to pass buffers between the threads. Make it possible to also call process from the RT thread. unmap the buffer data when needed.
2018-03-22 16:40:27 +01:00
#include <gst/gstpipewirepool.h>
gst: share the core between connections Make all sources in the same process with the same fd share the connection to the server. This makes it possible to set the same fd on multiple sources/sinks and have them all use the same connection, like when capturing multiple monitors from screencast with the portal. Fixes #241
2020-07-13 17:42:09 +02:00
#include <gst/gstpipewirecore.h>
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
G_BEGIN_DECLS
pinos -> pipewire
2017-05-23 19:15:33 +02:00
#define GST_TYPE_PIPEWIRE_SRC \
(gst_pipewire_src_get_type())
#define GST_PIPEWIRE_SRC(obj) \
(G_TYPE_CHECK_INSTANCE_CAST((obj),GST_TYPE_PIPEWIRE_SRC,GstPipeWireSrc))
#define GST_PIPEWIRE_SRC_CLASS(klass) \
(G_TYPE_CHECK_CLASS_CAST((klass),GST_TYPE_PIPEWIRE_SRC,GstPipeWireSrcClass))
#define GST_IS_PIPEWIRE_SRC(obj) \
(G_TYPE_CHECK_INSTANCE_TYPE((obj),GST_TYPE_PIPEWIRE_SRC))
#define GST_IS_PIPEWIRE_SRC_CLASS(klass) \
(G_TYPE_CHECK_CLASS_TYPE((klass),GST_TYPE_PIPEWIRE_SRC))
#define GST_PIPEWIRE_SRC_CAST(obj) \
((GstPipeWireSrc *) (obj))
typedef struct _GstPipeWireSrc GstPipeWireSrc;
typedef struct _GstPipeWireSrcClass GstPipeWireSrcClass;
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
/**
pinos -> pipewire
2017-05-23 19:15:33 +02:00
* GstPipeWireSrc:
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
*
* Opaque data structure.
*/
pinos -> pipewire
2017-05-23 19:15:33 +02:00
struct _GstPipeWireSrc {
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
GstPushSrc element;
/*< private >*/
Try to use source_path consistently
2015-07-09 17:58:54 +02:00
gchar *path;
gst: use target.object instead of node.target, soft-deprecate ids Use target-object=<serial/name> instead of path=<id> for specifying sink/src targets. Deprecate path= argument. Change device provider to preferably expose serials instead of ids.
2022-03-06 14:10:55 +02:00
gchar *target_object;
Improve introspection Add instrospection of client and source-output. Add properties to source-output and to CreateSourceOutput/Input Add helper to fill properties of context. Add client-name to pinossrc and pinossink Improve test-subscribe to show all new introspection details.
2015-07-28 17:05:03 +02:00
gchar *client_name;
pinossrc: add always-copy property
2017-05-17 11:49:57 +02:00
gboolean always_copy;
gst: add properties for limits of negotiated buffers By default, the pipewiresrc tries to negotiate 16 buffers. This value is hard coded in the pipewiresrc. If the buffers are large, this could lead to an undesirably high memory usage. Applications that know about the buffer size and that fewer buffers are sufficient should be able to configure the limits for the number of buffers that are negotiated. Therefore, add the min-buffers and max-buffers properties to the pipewiresrc to enable applications to configure limits for the number of negotiated buffers.
2020-03-20 17:00:36 +01:00
gint min_buffers;
gint max_buffers;
gstpipewiresrc: Add fd parameter Will be passed to a pw_remote_connect_fd() instead of plain a pw_remote_connect() call.
2018-01-22 17:05:13 +08:00
int fd;
pipewiresrc: add option to resend last buffer on EOS Add an option to resend the last buffer on EOS with an updated timestamp. This can be used to make sure encoders fill up the gap between last buffer and EOS, like with sparse streams from screen capture.
2020-07-13 12:11:34 +02:00
gboolean resend_last;
gst: add keepalive-time property Add a property to periodically send the last buffer to keep the stream alive. Useful for sparse streams that need to keep the encoder busy every once and a while.
2020-07-14 13:54:21 +02:00
gint keepalive_time;
Add autoconnect parameter to pipewiresrc element
2023-02-19 15:38:52 +00:00
gboolean autoconnect;
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
gst: don't do set_caps from the pipewire callback Don't do any GStreamer data transport from the PipeWire callback because it might block in preroll and block our communication with PipeWire. Instead, take the caps and wake up the caller to continue with negotiation.
2020-08-06 13:03:40 +02:00
GstCaps *caps;
gst: src: Improve DMA_DRM caps selection The translation between Pipewire parameters and Gstreamer caps is, for compatibility reasons, ambiguous. Formats with linear modifier are translated both in the legacy way as `format`, as well as `drm-format`. When finishing negotiation and setting caps, ensure that we: 1. set caps that the peer actually supports in order to prevent negotiation errors. 2. fixate caps to DMA_DRM if both options are supported, using the newly introduced helper, in order to prevent hangs. While on it, add some small clean-ups that hopefully make the code easier to follow, notably that `pwsrc->caps` and `pwsrc->possible_caps` are only used during negotiation.
2024-05-28 16:59:01 +02:00
GstCaps *possible_caps;
gst: don't do set_caps from the pipewire callback Don't do any GStreamer data transport from the PipeWire callback because it might block in preroll and block our communication with PipeWire. Instead, take the caps and wake up the caller to continue with negotiation.
2020-08-06 13:03:40 +02:00
gst: add buffer video meta support Fixes video buffer strides handling. This enables passing of image datas with right line padding.
2023-02-03 13:02:49 +08:00
gboolean is_video;
GstVideoInfo video_info;
gst: Add support for DMA_DRM / explicit modifiers Gstreamer 1.24 added and largely switched to a new, modifier aware DMABuf API. Unfortunately that breaks the existing DMABuf support in the PW Gst element. Add support for the new API.
2024-02-02 02:20:29 +01:00
#ifdef HAVE_GSTREAMER_DMA_DRM
GstVideoInfoDmaDrm drm_info;
#endif
gst: add buffer video meta support Fixes video buffer strides handling. This enables passing of image datas with right line padding.
2023-02-03 13:02:49 +08:00
Implement negotiation Use generic byte blobs for formats. We currently use them to store gstreamer caps but we could also use them to exchange serialized GVariants if we want. Make properties a variant dictionary
2015-05-14 17:46:12 +02:00
gboolean negotiated;
pinossrc: implement unlock/unlock_stop Implement unlock and unlock_stop to unblock the create method.
2016-01-07 15:07:15 +01:00
gboolean flushing;
pinossrc: fix timestamp and clock handling Send the base-time to the client so that it can calibrarte the clock. Wait until we are completely negotiated before completing the state change to paused. This makes it possible to provide a clock and decide if we are live or not.
2016-04-28 16:42:25 +02:00
gboolean started;
pipewiresrc: add option to resend last buffer on EOS Add an option to resend the last buffer on EOS with an updated timestamp. This can be used to make sure encoders fill up the gap between last buffer and EOS, like with sparse streams from screen capture.
2020-07-13 12:11:34 +02:00
gboolean eos;
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
source: send latency to client Send the latency to the client and use this to configure the pinossrc element latency correctly.
2016-04-28 11:18:10 +02:00
gboolean is_live;
gst: handle latency in the pipewiresrc Get the delay in the graph and subtract this from the cycle start time to get the timestamp of the buffer. Report this latency as well. Fixes #30
2024-03-15 17:31:43 +01:00
int64_t delay;
source: send latency to client Send the latency to the client and use this to configure the pinossrc element latency correctly.
2016-04-28 11:18:10 +02:00
GstClockTime min_latency;
GstClockTime max_latency;
gst: add client-properties To update the client properties of the connection. Fixes #1573
2022-06-03 13:00:52 +02:00
GstStructure *client_properties;
gst: share the core between connections Make all sources in the same process with the same fd share the connection to the server. This makes it possible to set the same fd on multiple sources/sinks and have them all use the same connection, like when capturing multiple monitors from screencast with the portal. Fixes #241
2020-07-13 17:42:09 +02:00
GstPipeWireCore *core;
gst: do a sync before disconnect This makes sure we first nicely remove the stream from the server and then close the socket. If we don't do this, the disconnect might not have flushed out our disconnect and the server is left with a non-responsive node, especially if the disconnect on the core was done with a socket from the portal that is still open.
2020-05-21 12:22:48 +02:00
struct spa_hook core_listener;
int last_seq;
int pending_seq;
Make native protocol Remove DBus and work towards something like wayland. Remove more glib stuff from the client code
2016-11-24 17:00:42 +01:00
pinos -> pipewire
2017-05-23 19:15:33 +02:00
struct pw_stream *stream;
Move listeners to spa and rename to hooks The listeners are generally useful in spa, move it there and rename to hooks. Implement loop hooks with it. Fix some cleanup issues in stream and remote
2017-08-08 16:56:29 +02:00
struct spa_hook stream_listener;
Make native protocol Remove DBus and work towards something like wayland. Remove more glib stuff from the client code
2016-11-24 17:00:42 +01:00
pipewiresrc: add option to resend last buffer on EOS Add an option to resend the last buffer on EOS with an updated timestamp. This can be used to make sure encoders fill up the gap between last buffer and EOS, like with sparse streams from screen capture.
2020-07-13 12:11:34 +02:00
GstBuffer *last_buffer;
gst: add client-properties To update the client properties of the connection. Fixes #1573
2022-06-03 13:00:52 +02:00
GstStructure *stream_properties;
Rework the wire protocol Send a command stream over the socket. Implement a new buffer object that holds the data and commands. Make iterator and builders to parse and construct buffers. Rework gstreamer elements to use new API for creating and parsing buffers. Add _release_buffer to notify a stream when we are done processing the buffer. This will eventually go all the way to the server and will allow us to do more complicated buffer management.
2015-08-24 16:41:04 +02:00
stream: improve stream API Simplify the stream API. make just 2 methods to queue and dequeue buffers. Make just one callback when new buffers can be dequeued. Add support for driver nodes such as the video-src. Pass a pw_buffer structure to add/remove_buffer and make it possible to attach metadata to it. This makes it a lot easier to implement the gstreamer pipewire pool. Call the stream process function from the main loop and use a lockfree ringbuffer to pass buffers between the threads. Make it possible to also call process from the RT thread. unmap the buffer data when needed.
2018-03-22 16:40:27 +01:00
GstPipeWirePool *pool;
pinossrc: slave a clock to the server clock Slave our clock to the server clock and provide it as the pipeline clock.
2015-12-02 20:43:37 +01:00
GstClock *clock;
gst: keep track of clock time Invalidate the clock when the stream is destroyed and let the new clock take the time of previous clock when no timing info is available.
2018-08-13 15:19:20 +02:00
GstClockTime last_time;
gst: Implement SPA_META_VideoTransform support Many Gstreamer elements support transforming buffers via the `image-orientation` tag. Use it to implement support for the new VideoTransform meta. In order for Gstreamer pipelines to enable support for these tags usually the rotate method has to be set to `auto` or `automatic`, e.g. `videoflip method=automatic`, `glimagesink rotate-method=automatic` or `waylandsink rotate-method=auto`.
2022-12-03 23:20:52 +01:00
enum spa_meta_videotransform_value transform_value;
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
};
pinos -> pipewire
2017-05-23 19:15:33 +02:00
struct _GstPipeWireSrcClass {
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
GstPushSrcClass parent_class;
};
pinos -> pipewire
2017-05-23 19:15:33 +02:00
GType gst_pipewire_src_get_type (void);
Add gstreamer source element Add a source gstreamer element Expose error in context Make it possible to set the source in the error state Add properties to a stream and use those to get a source-output Fix signal for new-buffer Attach the socket source to the thread default mainloop Make subscribe cancellable. Propagate state and error in context. Add bus handler for v4l2 source Use negotiated properties to set capsfilter in v4l2 Fix subscribe in test-client
2015-04-28 17:36:44 +02:00
G_END_DECLS
pinos -> pipewire
2017-05-23 19:15:33 +02:00
#endif /* __GST_PIPEWIRE_SRC_H__ */
Reference in a new issue Copy permalink