x11: Add X11 MetaSelectionSource implementation
This object represents the selection ownership from an X11 client. The list of supported targets is queried upfront, so its initialization is asynchronous. Requests to read contents from the selection will hand a MetaX11SelectionInputStream. https://gitlab.gnome.org/GNOME/mutter/merge_requests/320
This commit is contained in:
Carlos Garnacho
252
src/x11/meta-selection-source-x11.c
Normal file
252
src/x11/meta-selection-source-x11.c
Normal file
@ -0,0 +1,252 @@
|
||||
/*
|
||||
* Copyright (C) 2018 Red Hat
|
||||
*
|
||||
* 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, write to the Free Software
|
||||
* Foundation, Inc., 59 Temple Place - Suite 330, Boston, MA
|
||||
* 02111-1307, USA.
|
||||
*
|
||||
* Author: Carlos Garnacho <carlosg@gnome.org>
|
||||
*/
|
||||
|
||||
#include "config.h"
|
||||
|
||||
#include <gdk/gdkx.h>
|
||||
|
||||
#include "x11/meta-x11-selection-input-stream-private.h"
|
||||
#include "x11/meta-selection-source-x11-private.h"
|
||||
|
||||
#define MAX_MIMETYPE_SIZE 4096
|
||||
|
||||
struct _MetaSelectionSourceX11
|
||||
{
|
||||
MetaSelectionSource parent_instance;
|
||||
MetaX11Display *x11_display;
|
||||
GList *mimetypes;
|
||||
Window owner;
|
||||
Atom xselection;
|
||||
uint32_t timestamp;
|
||||
};
|
||||
|
||||
G_DEFINE_TYPE (MetaSelectionSourceX11, meta_selection_source_x11,
|
||||
META_TYPE_SELECTION_SOURCE)
|
||||
|
||||
static void
|
||||
stream_new_cb (GObject *source,
|
||||
GAsyncResult *res,
|
||||
GTask *task)
|
||||
{
|
||||
GInputStream *stream;
|
||||
GError *error = NULL;
|
||||
|
||||
stream = meta_x11_selection_input_stream_new_finish (res, NULL, NULL, &error);
|
||||
|
||||
if (stream)
|
||||
g_task_return_pointer (task, stream, g_object_unref);
|
||||
else
|
||||
g_task_return_error (task, error);
|
||||
|
||||
g_object_unref (task);
|
||||
}
|
||||
|
||||
static void
|
||||
meta_selection_source_x11_finalize (GObject *object)
|
||||
{
|
||||
MetaSelectionSourceX11 *source_x11 = META_SELECTION_SOURCE_X11 (object);
|
||||
|
||||
g_list_free_full (source_x11->mimetypes, g_free);
|
||||
|
||||
G_OBJECT_CLASS (meta_selection_source_x11_parent_class)->finalize (object);
|
||||
}
|
||||
|
||||
static void
|
||||
meta_selection_source_x11_read_async (MetaSelectionSource *source,
|
||||
const gchar *mimetype,
|
||||
GCancellable *cancellable,
|
||||
GAsyncReadyCallback callback,
|
||||
gpointer user_data)
|
||||
{
|
||||
MetaSelectionSourceX11 *source_x11 = META_SELECTION_SOURCE_X11 (source);
|
||||
GTask *task;
|
||||
|
||||
task = g_task_new (source, cancellable, callback, user_data);
|
||||
g_task_set_source_tag (task, meta_selection_source_x11_read_async);
|
||||
|
||||
meta_x11_selection_input_stream_new_async (source_x11->x11_display,
|
||||
source_x11->x11_display->selection.xwindow,
|
||||
gdk_x11_get_xatom_name (source_x11->xselection),
|
||||
mimetype,
|
||||
source_x11->timestamp,
|
||||
G_PRIORITY_DEFAULT,
|
||||
cancellable,
|
||||
(GAsyncReadyCallback) stream_new_cb,
|
||||
task);
|
||||
}
|
||||
|
||||
static GInputStream *
|
||||
meta_selection_source_x11_read_finish (MetaSelectionSource *source,
|
||||
GAsyncResult *result,
|
||||
GError **error)
|
||||
{
|
||||
g_return_val_if_fail (g_task_is_valid (result, source), NULL);
|
||||
g_return_val_if_fail (g_task_get_source_tag (G_TASK (result)) ==
|
||||
meta_selection_source_x11_read_async, NULL);
|
||||
|
||||
return g_task_propagate_pointer (G_TASK (result), error);
|
||||
}
|
||||
|
||||
static GList *
|
||||
meta_selection_source_x11_get_mimetypes (MetaSelectionSource *source)
|
||||
{
|
||||
MetaSelectionSourceX11 *source_x11 = META_SELECTION_SOURCE_X11 (source);
|
||||
|
||||
return g_list_copy_deep (source_x11->mimetypes, (GCopyFunc) g_strdup, NULL);
|
||||
}
|
||||
|
||||
static void
|
||||
meta_selection_source_x11_class_init (MetaSelectionSourceX11Class *klass)
|
||||
{
|
||||
GObjectClass *object_class = G_OBJECT_CLASS (klass);
|
||||
MetaSelectionSourceClass *source_class = META_SELECTION_SOURCE_CLASS (klass);
|
||||
|
||||
object_class->finalize = meta_selection_source_x11_finalize;
|
||||
|
||||
source_class->read_async = meta_selection_source_x11_read_async;
|
||||
source_class->read_finish = meta_selection_source_x11_read_finish;
|
||||
source_class->get_mimetypes = meta_selection_source_x11_get_mimetypes;
|
||||
}
|
||||
|
||||
static void
|
||||
meta_selection_source_x11_init (MetaSelectionSourceX11 *source)
|
||||
{
|
||||
}
|
||||
|
||||
static GList *
|
||||
atoms_to_mimetypes (MetaX11Display *display,
|
||||
GBytes *bytes)
|
||||
{
|
||||
GList *mimetypes = NULL;
|
||||
const Atom *atoms;
|
||||
gsize size;
|
||||
guint i, n_atoms;
|
||||
|
||||
atoms = g_bytes_get_data (bytes, &size);
|
||||
n_atoms = size / sizeof (Atom);
|
||||
|
||||
for (i = 0; i < n_atoms; i++)
|
||||
{
|
||||
const gchar *mimetype;
|
||||
|
||||
mimetype = gdk_x11_get_xatom_name (atoms[i]);
|
||||
mimetypes = g_list_prepend (mimetypes, g_strdup (mimetype));
|
||||
}
|
||||
|
||||
return mimetypes;
|
||||
}
|
||||
|
||||
static void
|
||||
read_mimetypes_cb (GInputStream *stream,
|
||||
GAsyncResult *res,
|
||||
GTask *task)
|
||||
{
|
||||
MetaSelectionSourceX11 *source_x11 = g_task_get_task_data (task);
|
||||
GError *error = NULL;
|
||||
GBytes *bytes;
|
||||
|
||||
bytes = g_input_stream_read_bytes_finish (stream, res, &error);
|
||||
if (error)
|
||||
{
|
||||
g_task_return_error (task, error);
|
||||
g_object_unref (task);
|
||||
return;
|
||||
}
|
||||
|
||||
source_x11->mimetypes = atoms_to_mimetypes (source_x11->x11_display, bytes);
|
||||
g_bytes_unref (bytes);
|
||||
|
||||
g_task_return_pointer (task,
|
||||
g_object_ref (g_task_get_task_data (task)),
|
||||
g_object_unref);
|
||||
g_object_unref (task);
|
||||
g_object_unref (stream);
|
||||
}
|
||||
|
||||
static void
|
||||
get_mimetypes_cb (GObject *source,
|
||||
GAsyncResult *res,
|
||||
GTask *task)
|
||||
{
|
||||
GInputStream *stream;
|
||||
GError *error = NULL;
|
||||
|
||||
stream = meta_x11_selection_input_stream_new_finish (res, NULL, NULL, &error);
|
||||
if (error)
|
||||
{
|
||||
g_task_return_error (task, error);
|
||||
g_object_unref (task);
|
||||
return;
|
||||
}
|
||||
|
||||
g_input_stream_read_bytes_async (stream,
|
||||
MAX_MIMETYPE_SIZE,
|
||||
G_PRIORITY_DEFAULT,
|
||||
g_task_get_cancellable (task),
|
||||
(GAsyncReadyCallback) read_mimetypes_cb,
|
||||
task);
|
||||
}
|
||||
|
||||
void
|
||||
meta_selection_source_x11_new_async (MetaX11Display *x11_display,
|
||||
Window owner,
|
||||
uint32_t timestamp,
|
||||
Atom xselection,
|
||||
GCancellable *cancellable,
|
||||
GAsyncReadyCallback callback,
|
||||
gpointer user_data)
|
||||
{
|
||||
MetaSelectionSourceX11 *source;
|
||||
GTask *task;
|
||||
|
||||
source = g_object_new (META_TYPE_SELECTION_SOURCE_X11, NULL);
|
||||
source->x11_display = x11_display;
|
||||
source->owner = owner;
|
||||
source->timestamp = timestamp;
|
||||
source->xselection = xselection;
|
||||
|
||||
task = g_task_new (NULL, cancellable, callback, user_data);
|
||||
g_task_set_source_tag (task, meta_selection_source_x11_new_async);
|
||||
g_task_set_task_data (task, source, g_object_unref);
|
||||
|
||||
meta_x11_selection_input_stream_new_async (x11_display,
|
||||
x11_display->selection.xwindow,
|
||||
gdk_x11_get_xatom_name (xselection),
|
||||
"TARGETS",
|
||||
timestamp,
|
||||
G_PRIORITY_DEFAULT,
|
||||
cancellable,
|
||||
(GAsyncReadyCallback) get_mimetypes_cb,
|
||||
task);
|
||||
}
|
||||
|
||||
MetaSelectionSource *
|
||||
meta_selection_source_x11_new_finish (GAsyncResult *result,
|
||||
GError **error)
|
||||
{
|
||||
GTask *task = G_TASK (result);
|
||||
|
||||
g_return_val_if_fail (g_task_is_valid (task, NULL), NULL);
|
||||
g_return_val_if_fail (g_task_get_source_tag (task) ==
|
||||
meta_selection_source_x11_new_async, NULL);
|
||||
|
||||
return g_task_propagate_pointer (task, error);
|
||||
}
|
||||
Reference in New Issue
Block a user