a2a4067e07
When a stream is destroyed by a consumer, mutter won't be able to recognize that. For mutter, the stream just paused, but did not disconnect, because the connection state of a PipeWire stream only represents, whether the respective PipeWire context is connected to PipeWire. In addition to that, it may be the case, that the stream consumer just recreates the stream. So even if mutter would be able to know, when the stream consumer destroyed a stream, but not the whole screencast or remote-desktop session, then mutter would not know, whether the stream will be resumed eventually or not. So, add an explicit API call to the screencast interface to stop a stream. For virtual streams, this also means, that the respective virtual monitor is destroyed. Closes: https://gitlab.gnome.org/GNOME/mutter/-/issues/2889 Part-of: <https://gitlab.gnome.org/GNOME/mutter/-/merge_requests/3307>
537 lines
17 KiB
C
537 lines
17 KiB
C
/* -*- mode: C; c-file-style: "gnu"; indent-tabs-mode: nil; -*- */
|
|
|
|
/*
|
|
* Copyright (C) 2017 Red Hat Inc.
|
|
*
|
|
* This program is free software; you can redistribute it and/or
|
|
* modify it under the terms of the GNU General Public License as
|
|
* published by the Free Software Foundation; either version 2 of the
|
|
* License, or (at your option) any later version.
|
|
*
|
|
* This program is distributed in the hope that it will be useful, but
|
|
* WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
* MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
|
|
* General Public License for more details.
|
|
*
|
|
* You should have received a copy of the GNU General Public License
|
|
* along with this program; if not, see <http://www.gnu.org/licenses/>.
|
|
*
|
|
*/
|
|
|
|
#include "config.h"
|
|
|
|
#include "backends/meta-screen-cast-stream.h"
|
|
|
|
#include "backends/meta-remote-desktop-session.h"
|
|
#include "backends/meta-screen-cast-session.h"
|
|
|
|
#include "meta-private-enum-types.h"
|
|
|
|
#define META_SCREEN_CAST_STREAM_DBUS_IFACE "org.gnome.Mutter.ScreenCast.Stream"
|
|
#define META_SCREEN_CAST_STREAM_DBUS_PATH "/org/gnome/Mutter/ScreenCast/Stream"
|
|
|
|
enum
|
|
{
|
|
PROP_0,
|
|
|
|
PROP_SESSION,
|
|
PROP_CONNECTION,
|
|
PROP_CURSOR_MODE,
|
|
PROP_FLAGS,
|
|
PROP_IS_CONFIGURED,
|
|
|
|
N_PROPS
|
|
};
|
|
|
|
static GParamSpec *obj_props[N_PROPS];
|
|
|
|
enum
|
|
{
|
|
CLOSED,
|
|
|
|
N_SIGNALS
|
|
};
|
|
|
|
static guint signals[N_SIGNALS];
|
|
|
|
typedef struct _MetaScreenCastStreamPrivate
|
|
{
|
|
MetaScreenCastSession *session;
|
|
|
|
GDBusConnection *connection;
|
|
char *object_path;
|
|
|
|
MetaScreenCastCursorMode cursor_mode;
|
|
MetaScreenCastFlag flags;
|
|
gboolean is_configured;
|
|
|
|
MetaScreenCastStreamSrc *src;
|
|
|
|
char *mapping_id;
|
|
} MetaScreenCastStreamPrivate;
|
|
|
|
static void
|
|
meta_screen_cast_stream_init_iface (MetaDBusScreenCastStreamIface *iface);
|
|
|
|
static void
|
|
meta_screen_cast_stream_init_initable_iface (GInitableIface *iface);
|
|
|
|
G_DEFINE_TYPE_WITH_CODE (MetaScreenCastStream,
|
|
meta_screen_cast_stream,
|
|
META_DBUS_TYPE_SCREEN_CAST_STREAM_SKELETON,
|
|
G_IMPLEMENT_INTERFACE (META_DBUS_TYPE_SCREEN_CAST_STREAM,
|
|
meta_screen_cast_stream_init_iface)
|
|
G_IMPLEMENT_INTERFACE (G_TYPE_INITABLE,
|
|
meta_screen_cast_stream_init_initable_iface)
|
|
G_ADD_PRIVATE (MetaScreenCastStream))
|
|
|
|
static MetaScreenCastStreamSrc *
|
|
meta_screen_cast_stream_create_src (MetaScreenCastStream *stream,
|
|
GError **error)
|
|
{
|
|
return META_SCREEN_CAST_STREAM_GET_CLASS (stream)->create_src (stream,
|
|
error);
|
|
}
|
|
|
|
static void
|
|
meta_screen_cast_stream_set_parameters (MetaScreenCastStream *stream,
|
|
GVariantBuilder *parameters_builder)
|
|
{
|
|
META_SCREEN_CAST_STREAM_GET_CLASS (stream)->set_parameters (stream,
|
|
parameters_builder);
|
|
}
|
|
|
|
static void
|
|
on_stream_src_closed (MetaScreenCastStreamSrc *src,
|
|
MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
if (priv->src)
|
|
meta_screen_cast_stream_close (stream);
|
|
}
|
|
|
|
static void
|
|
on_stream_src_ready (MetaScreenCastStreamSrc *src,
|
|
uint32_t node_id,
|
|
MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
GDBusConnection *connection = priv->connection;
|
|
char *peer_name;
|
|
|
|
peer_name = meta_screen_cast_session_get_peer_name (priv->session);
|
|
g_dbus_connection_emit_signal (connection,
|
|
peer_name,
|
|
priv->object_path,
|
|
META_SCREEN_CAST_STREAM_DBUS_IFACE,
|
|
"PipeWireStreamAdded",
|
|
g_variant_new ("(u)", node_id),
|
|
NULL);
|
|
}
|
|
|
|
MetaScreenCastSession *
|
|
meta_screen_cast_stream_get_session (MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
return priv->session;
|
|
}
|
|
|
|
gboolean
|
|
meta_screen_cast_stream_start (MetaScreenCastStream *stream,
|
|
GError **error)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
MetaScreenCastStreamSrc *src;
|
|
|
|
if (priv->src)
|
|
{
|
|
g_set_error (error, G_IO_ERROR, G_IO_ERROR_FAILED,
|
|
"Stream already started");
|
|
return FALSE;
|
|
}
|
|
|
|
src = meta_screen_cast_stream_create_src (stream, error);
|
|
if (!src)
|
|
return FALSE;
|
|
|
|
priv->src = src;
|
|
g_signal_connect (src, "ready", G_CALLBACK (on_stream_src_ready), stream);
|
|
g_signal_connect (src, "closed", G_CALLBACK (on_stream_src_closed), stream);
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
void
|
|
meta_screen_cast_stream_close (MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
g_clear_object (&priv->src);
|
|
|
|
g_signal_emit (stream, signals[CLOSED], 0);
|
|
}
|
|
|
|
char *
|
|
meta_screen_cast_stream_get_object_path (MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
return priv->object_path;
|
|
}
|
|
|
|
MetaScreenCastStreamSrc *
|
|
meta_screen_cast_stream_get_src (MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
return priv->src;
|
|
}
|
|
|
|
gboolean
|
|
meta_screen_cast_stream_transform_position (MetaScreenCastStream *stream,
|
|
double stream_x,
|
|
double stream_y,
|
|
double *x,
|
|
double *y)
|
|
{
|
|
MetaScreenCastStreamClass *klass = META_SCREEN_CAST_STREAM_GET_CLASS (stream);
|
|
|
|
return klass->transform_position (stream, stream_x, stream_y, x, y);
|
|
}
|
|
|
|
MetaScreenCastCursorMode
|
|
meta_screen_cast_stream_get_cursor_mode (MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
return priv->cursor_mode;
|
|
}
|
|
|
|
MetaScreenCastFlag
|
|
meta_screen_cast_stream_get_flags (MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
return priv->flags;
|
|
}
|
|
|
|
const char *
|
|
meta_screen_cast_stream_get_mapping_id (MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
return priv->mapping_id;
|
|
}
|
|
|
|
gboolean
|
|
meta_screen_cast_stream_is_configured (MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
return priv->is_configured;
|
|
}
|
|
|
|
void
|
|
meta_screen_cast_stream_notify_is_configured (MetaScreenCastStream *stream)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
priv->is_configured = TRUE;
|
|
g_object_notify_by_pspec (G_OBJECT (stream), obj_props[PROP_IS_CONFIGURED]);
|
|
}
|
|
|
|
static void
|
|
meta_screen_cast_stream_set_property (GObject *object,
|
|
guint prop_id,
|
|
const GValue *value,
|
|
GParamSpec *pspec)
|
|
{
|
|
MetaScreenCastStream *stream = META_SCREEN_CAST_STREAM (object);
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
switch (prop_id)
|
|
{
|
|
case PROP_SESSION:
|
|
priv->session = g_value_get_object (value);
|
|
break;
|
|
case PROP_CONNECTION:
|
|
priv->connection = g_value_get_object (value);
|
|
break;
|
|
case PROP_CURSOR_MODE:
|
|
priv->cursor_mode = g_value_get_uint (value);
|
|
break;
|
|
case PROP_FLAGS:
|
|
priv->flags = g_value_get_flags (value);
|
|
break;
|
|
case PROP_IS_CONFIGURED:
|
|
priv->is_configured = g_value_get_boolean (value);
|
|
break;
|
|
default:
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
|
}
|
|
}
|
|
|
|
static void
|
|
meta_screen_cast_stream_get_property (GObject *object,
|
|
guint prop_id,
|
|
GValue *value,
|
|
GParamSpec *pspec)
|
|
{
|
|
MetaScreenCastStream *stream = META_SCREEN_CAST_STREAM (object);
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
switch (prop_id)
|
|
{
|
|
case PROP_SESSION:
|
|
g_value_set_object (value, priv->session);
|
|
break;
|
|
case PROP_CONNECTION:
|
|
g_value_set_object (value, priv->connection);
|
|
break;
|
|
case PROP_CURSOR_MODE:
|
|
g_value_set_uint (value, priv->cursor_mode);
|
|
break;
|
|
case PROP_FLAGS:
|
|
g_value_set_flags (value, priv->flags);
|
|
break;
|
|
case PROP_IS_CONFIGURED:
|
|
g_value_set_boolean (value, priv->is_configured);
|
|
break;
|
|
default:
|
|
G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
|
|
}
|
|
}
|
|
|
|
static void
|
|
meta_screen_cast_stream_finalize (GObject *object)
|
|
{
|
|
MetaScreenCastStream *stream = META_SCREEN_CAST_STREAM (object);
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
MetaRemoteDesktopSession *remote_desktop_session;
|
|
|
|
if (priv->src)
|
|
meta_screen_cast_stream_close (stream);
|
|
|
|
remote_desktop_session =
|
|
meta_screen_cast_session_get_remote_desktop_session (priv->session);
|
|
if (remote_desktop_session && priv->mapping_id)
|
|
{
|
|
meta_remote_desktop_session_release_mapping_id (remote_desktop_session,
|
|
priv->mapping_id);
|
|
}
|
|
|
|
g_clear_pointer (&priv->object_path, g_free);
|
|
g_clear_pointer (&priv->mapping_id, g_free);
|
|
|
|
G_OBJECT_CLASS (meta_screen_cast_stream_parent_class)->finalize (object);
|
|
}
|
|
|
|
static gboolean
|
|
check_permission (MetaScreenCastStream *stream,
|
|
GDBusMethodInvocation *invocation)
|
|
{
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
char *peer_name;
|
|
|
|
peer_name = meta_screen_cast_session_get_peer_name (priv->session);
|
|
return g_strcmp0 (peer_name,
|
|
g_dbus_method_invocation_get_sender (invocation)) == 0;
|
|
}
|
|
|
|
static gboolean
|
|
handle_start (MetaDBusScreenCastStream *skeleton,
|
|
GDBusMethodInvocation *invocation)
|
|
{
|
|
MetaScreenCastStream *stream = META_SCREEN_CAST_STREAM (skeleton);
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
g_autoptr (GError) error = NULL;
|
|
|
|
if (!check_permission (stream, invocation))
|
|
{
|
|
g_dbus_method_invocation_return_error (invocation, G_DBUS_ERROR,
|
|
G_DBUS_ERROR_ACCESS_DENIED,
|
|
"Permission denied");
|
|
return TRUE;
|
|
}
|
|
|
|
if (!meta_screen_cast_session_is_active (priv->session))
|
|
{
|
|
g_dbus_method_invocation_return_error (invocation, G_DBUS_ERROR,
|
|
G_DBUS_ERROR_FAILED,
|
|
"Failed to start stream: "
|
|
"session not started");
|
|
return TRUE;
|
|
}
|
|
|
|
if (!meta_screen_cast_stream_start (stream, &error))
|
|
{
|
|
g_dbus_method_invocation_return_error (invocation, G_DBUS_ERROR,
|
|
G_DBUS_ERROR_FAILED,
|
|
"Failed to start stream: %s",
|
|
error->message);
|
|
return TRUE;
|
|
}
|
|
|
|
meta_dbus_screen_cast_stream_complete_start (skeleton, invocation);
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
static gboolean
|
|
handle_stop (MetaDBusScreenCastStream *skeleton,
|
|
GDBusMethodInvocation *invocation)
|
|
{
|
|
MetaScreenCastStream *stream = META_SCREEN_CAST_STREAM (skeleton);
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
|
|
if (!check_permission (stream, invocation))
|
|
{
|
|
g_dbus_method_invocation_return_error (invocation, G_DBUS_ERROR,
|
|
G_DBUS_ERROR_ACCESS_DENIED,
|
|
"Permission denied");
|
|
return G_DBUS_METHOD_INVOCATION_HANDLED;
|
|
}
|
|
|
|
if (priv->src)
|
|
meta_screen_cast_stream_close (stream);
|
|
|
|
meta_dbus_screen_cast_stream_complete_stop (skeleton, invocation);
|
|
|
|
return G_DBUS_METHOD_INVOCATION_HANDLED;
|
|
}
|
|
|
|
static void
|
|
meta_screen_cast_stream_init_iface (MetaDBusScreenCastStreamIface *iface)
|
|
{
|
|
iface->handle_start = handle_start;
|
|
iface->handle_stop = handle_stop;
|
|
}
|
|
|
|
static gboolean
|
|
meta_screen_cast_stream_initable_init (GInitable *initable,
|
|
GCancellable *cancellable,
|
|
GError **error)
|
|
{
|
|
MetaScreenCastStream *stream = META_SCREEN_CAST_STREAM (initable);
|
|
MetaDBusScreenCastStream *skeleton = META_DBUS_SCREEN_CAST_STREAM (stream);
|
|
MetaScreenCastStreamPrivate *priv =
|
|
meta_screen_cast_stream_get_instance_private (stream);
|
|
MetaRemoteDesktopSession *remote_desktop_session;
|
|
GVariantBuilder parameters_builder;
|
|
GVariant *parameters_variant;
|
|
static unsigned int global_stream_number = 0;
|
|
|
|
g_variant_builder_init (¶meters_builder, G_VARIANT_TYPE_VARDICT);
|
|
meta_screen_cast_stream_set_parameters (stream, ¶meters_builder);
|
|
|
|
remote_desktop_session =
|
|
meta_screen_cast_session_get_remote_desktop_session (priv->session);
|
|
if (remote_desktop_session)
|
|
{
|
|
const char *mapping_id;
|
|
|
|
mapping_id =
|
|
meta_remote_desktop_session_acquire_mapping_id (remote_desktop_session);
|
|
priv->mapping_id = g_strdup (mapping_id);
|
|
g_variant_builder_add (¶meters_builder, "{sv}",
|
|
"mapping-id",
|
|
g_variant_new ("s", priv->mapping_id));
|
|
}
|
|
|
|
parameters_variant = g_variant_builder_end (¶meters_builder);
|
|
meta_dbus_screen_cast_stream_set_parameters (skeleton, parameters_variant);
|
|
|
|
priv->object_path =
|
|
g_strdup_printf (META_SCREEN_CAST_STREAM_DBUS_PATH "/u%u",
|
|
++global_stream_number);
|
|
if (!g_dbus_interface_skeleton_export (G_DBUS_INTERFACE_SKELETON (stream),
|
|
priv->connection,
|
|
priv->object_path,
|
|
error))
|
|
return FALSE;
|
|
|
|
return TRUE;
|
|
}
|
|
|
|
static void
|
|
meta_screen_cast_stream_init_initable_iface (GInitableIface *iface)
|
|
{
|
|
iface->init = meta_screen_cast_stream_initable_init;
|
|
}
|
|
|
|
static void
|
|
meta_screen_cast_stream_init (MetaScreenCastStream *stream)
|
|
{
|
|
}
|
|
|
|
static void
|
|
meta_screen_cast_stream_class_init (MetaScreenCastStreamClass *klass)
|
|
{
|
|
GObjectClass *object_class = G_OBJECT_CLASS (klass);
|
|
|
|
object_class->finalize = meta_screen_cast_stream_finalize;
|
|
object_class->set_property = meta_screen_cast_stream_set_property;
|
|
object_class->get_property = meta_screen_cast_stream_get_property;
|
|
|
|
obj_props[PROP_SESSION] =
|
|
g_param_spec_object ("session", NULL, NULL,
|
|
META_TYPE_SCREEN_CAST_SESSION,
|
|
G_PARAM_READWRITE |
|
|
G_PARAM_CONSTRUCT_ONLY |
|
|
G_PARAM_STATIC_STRINGS);
|
|
obj_props[PROP_CONNECTION] =
|
|
g_param_spec_object ("connection", NULL, NULL,
|
|
G_TYPE_DBUS_CONNECTION,
|
|
G_PARAM_READWRITE |
|
|
G_PARAM_CONSTRUCT_ONLY |
|
|
G_PARAM_STATIC_STRINGS);
|
|
obj_props[PROP_CURSOR_MODE] =
|
|
g_param_spec_uint ("cursor-mode", NULL, NULL,
|
|
META_SCREEN_CAST_CURSOR_MODE_HIDDEN,
|
|
META_SCREEN_CAST_CURSOR_MODE_METADATA,
|
|
META_SCREEN_CAST_CURSOR_MODE_HIDDEN,
|
|
G_PARAM_READWRITE |
|
|
G_PARAM_CONSTRUCT_ONLY |
|
|
G_PARAM_STATIC_STRINGS);
|
|
obj_props[PROP_FLAGS] =
|
|
g_param_spec_flags ("flags", NULL, NULL,
|
|
META_TYPE_SCREEN_CAST_FLAG,
|
|
META_SCREEN_CAST_FLAG_NONE,
|
|
G_PARAM_READWRITE |
|
|
G_PARAM_CONSTRUCT_ONLY |
|
|
G_PARAM_STATIC_STRINGS);
|
|
obj_props[PROP_IS_CONFIGURED] =
|
|
g_param_spec_boolean ("is-configured", NULL, NULL,
|
|
FALSE,
|
|
G_PARAM_READWRITE |
|
|
G_PARAM_CONSTRUCT |
|
|
G_PARAM_STATIC_STRINGS);
|
|
g_object_class_install_properties (object_class, N_PROPS, obj_props);
|
|
|
|
signals[CLOSED] = g_signal_new ("closed",
|
|
G_TYPE_FROM_CLASS (klass),
|
|
G_SIGNAL_RUN_LAST,
|
|
0,
|
|
NULL, NULL, NULL,
|
|
G_TYPE_NONE, 0);
|
|
}
|