Sign Up
Log In
Log In
or
Sign Up
Places
All Projects
Status Monitor
Collapse sidebar
home:AZhou:branches:GNOME:STABLE:3.34
tracker
tracker-add-dbus-connection-endpoint-sparql.patch
Overview
Repositories
Revisions
Requests
Users
Attributes
Meta
File tracker-add-dbus-connection-endpoint-sparql.patch of Package tracker
diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql/libtracker-sparql-intermediate-c.vapi tracker-2.3.4.new/src/libtracker-sparql/libtracker-sparql-intermediate-c.vapi --- tracker-2.3.4.old/src/libtracker-sparql/libtracker-sparql-intermediate-c.vapi 2020-03-10 07:27:20.370601200 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql/libtracker-sparql-intermediate-c.vapi 2023-12-08 18:21:10.619690274 +0800 @@ -100,4 +100,14 @@ public string get_location (); } } + + [CCode (cheader_filename = "libtracker-sparql/tracker-endpoint.h")] + public class Endpoint : GLib.Object { + Sparql.Connection get_sparql_connection (); + } + + [CCode (cheader_filename = "libtracker-sparql/tracker-endpoint-dbus.h")] + public class EndpointDBus : GLib.Object, GLib.Initable { + public EndpointDBus (Sparql.Connection sparql_conn, GLib.DBusConnection? dbus_conn, string object_path, GLib.Cancellable? cancellable) throws GLib.Error; + } } diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql/meson.build tracker-2.3.4.new/src/libtracker-sparql/meson.build --- tracker-2.3.4.old/src/libtracker-sparql/meson.build 2020-03-10 07:27:20.370601200 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql/meson.build 2023-12-08 18:21:10.626357173 +0800 @@ -55,6 +55,8 @@ # Now build the C parts ... libtracker_sparql_c_sources = files( + 'tracker-endpoint.c', + 'tracker-endpoint-dbus.c', 'tracker-namespace-manager.c', 'tracker-notifier.c', 'tracker-resource.c', @@ -63,6 +65,8 @@ ) libtracker_sparql_c_public_headers = files( + 'tracker-endpoint.h', + 'tracker-endpoint-dbus.h', 'tracker-namespace-manager.h', 'tracker-notifier.h', 'tracker-resource.h', @@ -70,7 +74,7 @@ ) libtracker_sparql_intermediate_c = static_library('tracker-sparql-intermediate-c', - enums_c, enums_h, + enums_c, enums_h, tracker_sparql_generated_header[0], libtracker_sparql_c_sources, dependencies: [tracker_common_dep, json_glib], link_with: libtracker_sparql_intermediate_vala, diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql/tracker-connection.vala tracker-2.3.4.new/src/libtracker-sparql/tracker-connection.vala --- tracker-2.3.4.old/src/libtracker-sparql/tracker-connection.vala 2020-03-10 07:27:20.371601000 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql/tracker-connection.vala 2023-12-08 20:01:01.015097597 +0800 @@ -237,6 +237,8 @@ */ public extern async static new Connection local_new_async (Tracker.Sparql.ConnectionFlags flags, File store, File? journal, File? ontology, Cancellable? cancellable = null) throws Sparql.Error, IOError; + public extern static new Connection bus_new (string service_name, DBusConnection? dbus_connection = null) throws Sparql.Error, IOError, DBusError, GLib.Error; + /** * tracker_sparql_connection_query: * @self: a #TrackerSparqlConnection diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql/tracker-endpoint.c tracker-2.3.4.new/src/libtracker-sparql/tracker-endpoint.c --- tracker-2.3.4.old/src/libtracker-sparql/tracker-endpoint.c 1970-01-01 08:00:00.000000000 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql/tracker-endpoint.c 2023-12-08 18:21:10.626357173 +0800 @@ -0,0 +1,118 @@ +/* + * Copyright (C) 2019, Red Hat, Inc + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library 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 + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the + * Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + * Boston, MA 02110-1301, USA. + * + * Author: Carlos Garnacho <carlosg@gnome.org> + */ + +#include "config.h" + +#include "tracker-endpoint.h" + +enum { + PROP_0, + PROP_SPARQL_CONNECTION, + N_PROPS +}; + +static GParamSpec *props[N_PROPS] = { 0 }; + +typedef struct { + TrackerSparqlConnection *sparql_connection; +} TrackerEndpointPrivate; + +G_DEFINE_ABSTRACT_TYPE_WITH_PRIVATE (TrackerEndpoint, tracker_endpoint, G_TYPE_OBJECT) + +static void +tracker_endpoint_finalize (GObject *object) +{ + TrackerEndpoint *endpoint = TRACKER_ENDPOINT (object); + TrackerEndpointPrivate *priv = tracker_endpoint_get_instance_private (endpoint); + + g_clear_object (&priv->sparql_connection); + + G_OBJECT_CLASS (tracker_endpoint_parent_class)->finalize (object); +} + +static void +tracker_endpoint_set_property (GObject *object, + guint prop_id, + const GValue *value, + GParamSpec *pspec) +{ + TrackerEndpoint *endpoint = TRACKER_ENDPOINT (object); + TrackerEndpointPrivate *priv = tracker_endpoint_get_instance_private (endpoint); + + switch (prop_id) { + case PROP_SPARQL_CONNECTION: + priv->sparql_connection = g_value_dup_object (value); + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); + break; + } +} + +static void +tracker_endpoint_get_property (GObject *object, + guint prop_id, + GValue *value, + GParamSpec *pspec) +{ + TrackerEndpoint *endpoint = TRACKER_ENDPOINT (object); + TrackerEndpointPrivate *priv = tracker_endpoint_get_instance_private (endpoint); + + switch (prop_id) { + case PROP_SPARQL_CONNECTION: + g_value_set_object (value, priv->sparql_connection); + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); + break; + } +} + +static void +tracker_endpoint_class_init (TrackerEndpointClass *klass) +{ + GObjectClass *object_class = G_OBJECT_CLASS (klass); + + object_class->finalize = tracker_endpoint_finalize; + object_class->set_property = tracker_endpoint_set_property; + object_class->get_property = tracker_endpoint_get_property; + + props[PROP_SPARQL_CONNECTION] = + g_param_spec_object ("sparql-connection", + "Sparql connection", + "Sparql connection", + TRACKER_SPARQL_TYPE_CONNECTION, + G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY); + g_object_class_install_properties (object_class, N_PROPS, props); +} + +static void +tracker_endpoint_init (TrackerEndpoint *endpoint) +{ +} + +TrackerSparqlConnection * +tracker_endpoint_get_sparql_connection (TrackerEndpoint *endpoint) +{ + TrackerEndpointPrivate *priv = tracker_endpoint_get_instance_private (endpoint); + + return priv->sparql_connection; +} diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql/tracker-endpoint-dbus.c tracker-2.3.4.new/src/libtracker-sparql/tracker-endpoint-dbus.c --- tracker-2.3.4.old/src/libtracker-sparql/tracker-endpoint-dbus.c 1970-01-01 08:00:00.000000000 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql/tracker-endpoint-dbus.c 2023-12-08 18:21:10.626357173 +0800 @@ -0,0 +1,610 @@ +/* + * Copyright (C) 2019, Red Hat, Inc + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library 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 + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the + * Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + * Boston, MA 02110-1301, USA. + * + * Author: Carlos Garnacho <carlosg@gnome.org> + */ + +#include "config.h" + +#include "tracker-endpoint-dbus.h" + +#include <gio/gio.h> +#include <gio/gunixinputstream.h> +#include <gio/gunixoutputstream.h> +#include <gio/gunixfdlist.h> + +static const gchar introspection_xml[] = + "<node>" + " <interface name='org.freedesktop.Tracker1.Endpoint'>" + " <method name='Query'>" + " <arg type='as' name='anon_graphs' direction='in' />" + " <arg type='as' name='named_graphs' direction='in' />" + " <arg type='s' name='query' direction='in' />" + " <arg type='h' name='output_stream' direction='in' />" + " <arg type='as' name='result' direction='out' />" + " </method>" + " <method name='Update'>" + " <arg type='as' name='anon_graphs' direction='in' />" + " <arg type='as' name='named_graphs' direction='in' />" + " <arg type='h' name='input_stream' direction='in' />" + " </method>" + " <method name='UpdateArray'>" + " <arg type='as' name='anon_graphs' direction='in' />" + " <arg type='as' name='named_graphs' direction='in' />" + " <arg type='h' name='input_stream' direction='in' />" + " </method>" + " <method name='UpdateBlank'>" + " <arg type='as' name='anon_graphs' direction='in' />" + " <arg type='as' name='named_graphs' direction='in' />" + " <arg type='h' name='input_stream' direction='in' />" + " <arg type='aaa{ss}' name='result' direction='out' />" + " </method>" + " <signal name='GraphUpdate'>" + " <arg type='a(ii)' name='updates' />" + " </signal>" + " </interface>" + "</node>"; + +enum { + PROP_0, + PROP_DBUS_CONNECTION, + PROP_OBJECT_PATH, + N_PROPS +}; + +struct _TrackerEndpointDBus { + TrackerEndpoint parent_instance; + GDBusConnection *dbus_connection; + gchar *object_path; + guint register_id; + GDBusNodeInfo *node_info; + GCancellable *cancellable; +}; + +typedef struct { + TrackerEndpointDBus *endpoint; + GDBusMethodInvocation *invocation; + GDataOutputStream *data_stream; +} QueryRequest; + +typedef struct { + TrackerEndpointDBus *endpoint; + GDBusMethodInvocation *invocation; + GDataInputStream *input_stream; + GPtrArray *queries; + gboolean array_update; + gint num_queries; + gint cur_query; +} UpdateRequest; + +GParamSpec *props[N_PROPS] = { 0 }; + +static void tracker_endpoint_dbus_initable_iface_init (GInitableIface *iface); + +static void read_update_cb (GObject *object, + GAsyncResult *res, + gpointer user_data); +static void read_update_blank_cb (GObject *object, + GAsyncResult *res, + gpointer user_data); + +G_DEFINE_TYPE_WITH_CODE (TrackerEndpointDBus, tracker_endpoint_dbus, TRACKER_TYPE_ENDPOINT, + G_IMPLEMENT_INTERFACE (G_TYPE_INITABLE, tracker_endpoint_dbus_initable_iface_init)) + +static QueryRequest * +query_request_new (TrackerEndpointDBus *endpoint, + GDBusMethodInvocation *invocation, + int fd) +{ + GOutputStream *stream, *buffered_stream; + QueryRequest *request; + + request = g_new0 (QueryRequest, 1); + request->invocation = g_object_ref (invocation); + request->endpoint = endpoint; + + stream = g_unix_output_stream_new (fd, TRUE); + buffered_stream = g_buffered_output_stream_new_sized (stream, + getpagesize ()); + + request->data_stream = g_data_output_stream_new (buffered_stream); + g_data_output_stream_set_byte_order (request->data_stream, + G_DATA_STREAM_BYTE_ORDER_HOST_ENDIAN); + + g_object_unref (buffered_stream); + g_object_unref (stream); + + return request; +} + +static void +query_request_free (QueryRequest *request) +{ + g_output_stream_close (G_OUTPUT_STREAM (request->data_stream), + NULL, NULL); + + g_object_unref (request->invocation); + g_object_unref (request->data_stream); + g_free (request); +} + +static UpdateRequest * +update_request_new (TrackerEndpointDBus *endpoint, + GDBusMethodInvocation *invocation, + gboolean array_update, + int input) +{ + UpdateRequest *request; + GInputStream *stream; + + request = g_new0 (UpdateRequest, 1); + request->invocation = g_object_ref (invocation); + request->endpoint = endpoint; + request->cur_query = 0; + request->array_update = array_update; + request->queries = g_ptr_array_new_with_free_func (g_free); + + stream = g_unix_input_stream_new (input, TRUE); + request->input_stream = g_data_input_stream_new (stream); + g_buffered_input_stream_set_buffer_size (G_BUFFERED_INPUT_STREAM (request->input_stream), + getpagesize ()); + g_data_input_stream_set_byte_order (request->input_stream, + G_DATA_STREAM_BYTE_ORDER_HOST_ENDIAN); + g_object_unref (stream); + + if (array_update) + request->num_queries = g_data_input_stream_read_int32 (request->input_stream, NULL, NULL); + else + request->num_queries = 1; + + return request; +} + +static gboolean +update_request_read_next (UpdateRequest *request, + GAsyncReadyCallback cb) +{ + gchar *buffer; + gint buffer_size; + + if (request->cur_query >= request->num_queries) + return FALSE; + + request->cur_query++; + buffer_size = g_data_input_stream_read_int32 (request->input_stream, NULL, NULL); + buffer = g_new0 (char, buffer_size + 1); + g_ptr_array_add (request->queries, buffer); + + g_input_stream_read_all_async (G_INPUT_STREAM (request->input_stream), + buffer, + buffer_size, + G_PRIORITY_DEFAULT, + request->endpoint->cancellable, + cb, request); + return TRUE; +} + +static void +update_request_free (UpdateRequest *request) +{ + g_input_stream_close (G_INPUT_STREAM (request->input_stream), + NULL, NULL); + + g_ptr_array_unref (request->queries); + g_object_unref (request->invocation); + g_object_unref (request->input_stream); + g_free (request); +} + +static void +query_cb (GObject *object, + GAsyncResult *res, + gpointer user_data) +{ + QueryRequest *request = user_data; + TrackerSparqlCursor *cursor; + GError *error = NULL; + const gchar **values = NULL; + const gchar **variable_names = NULL; + glong *offsets = NULL; + gint i, n_columns = 0; + + cursor = tracker_sparql_connection_query_finish (TRACKER_SPARQL_CONNECTION (object), + res, &error); + if (!cursor) + goto error; + + n_columns = tracker_sparql_cursor_get_n_columns (cursor); + variable_names = g_new0 (const gchar *, n_columns + 1); + values = g_new0 (const char *, n_columns); + offsets = g_new0 (glong, n_columns); + + for (i = 0; i < n_columns; i++) + variable_names[i] = tracker_sparql_cursor_get_variable_name (cursor, i); + + while (tracker_sparql_cursor_next (cursor, NULL, &error)) { + glong cur_offset = -1; + + g_data_output_stream_put_int32 (request->data_stream, n_columns, NULL, NULL); + + for (i = 0; i < n_columns; i++) { + glong len; + + g_data_output_stream_put_int32 (request->data_stream, + tracker_sparql_cursor_get_value_type (cursor, i), + NULL, NULL); + values[i] = tracker_sparql_cursor_get_string (cursor, i, &len); + len++; + cur_offset += len; + offsets[i] = cur_offset; + } + + for (i = 0; i < n_columns; i++) { + g_data_output_stream_put_int32 (request->data_stream, + offsets[i], NULL, NULL); + } + + for (i = 0; i < n_columns; i++) { + g_data_output_stream_put_string (request->data_stream, + values[i] ? values[i] : "", + NULL, NULL); + g_data_output_stream_put_byte (request->data_stream, 0, NULL, NULL); + } + } + +error: + if (error) + g_dbus_method_invocation_return_gerror (request->invocation, error); + else + g_dbus_method_invocation_return_value (request->invocation, g_variant_new ("(^as)", variable_names)); + + g_free (variable_names); + g_free (values); + g_free (offsets); + g_clear_object (&cursor); + + query_request_free (request); +} + +static void +update_cb (GObject *object, + GAsyncResult *res, + gpointer user_data) +{ + UpdateRequest *request = user_data; + GError *error = NULL; + + tracker_sparql_connection_update_array_finish (TRACKER_SPARQL_CONNECTION (object), + res, &error); + if (error) { + g_dbus_method_invocation_return_gerror (request->invocation, error); + } else { + g_dbus_method_invocation_return_value (request->invocation, NULL); + } + + update_request_free (request); +} + +static void +read_update_cb (GObject *object, + GAsyncResult *res, + gpointer user_data) +{ + TrackerSparqlConnection *conn; + UpdateRequest *request = user_data; + GError *error = NULL; + + if (!g_input_stream_read_all_finish (G_INPUT_STREAM (object), + res, NULL, &error)) { + g_dbus_method_invocation_return_gerror (request->invocation, error); + update_request_free (request); + return; + } + + if (!update_request_read_next (request, read_update_cb)) { + conn = tracker_endpoint_get_sparql_connection (TRACKER_ENDPOINT (request->endpoint)); + tracker_sparql_connection_update_array_async (conn, + (gchar **) request->queries->pdata, + request->queries->len, + G_PRIORITY_DEFAULT, + request->endpoint->cancellable, + update_cb, + request); + } +} + +static void +update_blank_cb (GObject *object, + GAsyncResult *res, + gpointer user_data) +{ + UpdateRequest *request = user_data; + GError *error = NULL; + GVariant *results; + + results = tracker_sparql_connection_update_blank_finish (TRACKER_SPARQL_CONNECTION (object), + res, &error); + if (results) + g_dbus_method_invocation_return_value (request->invocation, results); + else + g_dbus_method_invocation_return_gerror (request->invocation, error); + + update_request_free (request); +} + +static void +read_update_blank_cb (GObject *object, + GAsyncResult *res, + gpointer user_data) +{ + TrackerSparqlConnection *conn; + UpdateRequest *request = user_data; + GError *error = NULL; + + if (!g_input_stream_read_all_finish (G_INPUT_STREAM (object), + res, NULL, &error)) { + g_dbus_method_invocation_return_gerror (request->invocation, error); + update_request_free (request); + return; + } + + conn = tracker_endpoint_get_sparql_connection (TRACKER_ENDPOINT (request->endpoint)); + tracker_sparql_connection_update_blank_async (conn, + g_ptr_array_index (request->queries, 0), + G_PRIORITY_DEFAULT, + request->endpoint->cancellable, + update_blank_cb, + request); +} + +static void +endpoint_dbus_iface_method_call (GDBusConnection *connection, + const gchar *sender, + const gchar *object_path, + const gchar *interface_name, + const gchar *method_name, + GVariant *parameters, + GDBusMethodInvocation *invocation, + gpointer user_data) +{ + TrackerEndpointDBus *endpoint_dbus = user_data; + TrackerSparqlConnection *conn; + GUnixFDList *fd_list; + GError *error = NULL; + gchar *query; + gint handle, fd = -1; + + conn = tracker_endpoint_get_sparql_connection (TRACKER_ENDPOINT (endpoint_dbus)); + fd_list = g_dbus_message_get_unix_fd_list (g_dbus_method_invocation_get_message (invocation)); + + if (g_strcmp0 (method_name, "Query") == 0) { + /* FIXME: Anon/named graphs are ignored ATM */ + g_variant_get (parameters, "(asassh)", NULL, NULL, &query, &handle); + + if (fd_list) + fd = g_unix_fd_list_get (fd_list, handle, &error); + + if (fd < 0) { + g_dbus_method_invocation_return_error (invocation, + G_DBUS_ERROR, + G_DBUS_ERROR_INVALID_ARGS, + "Did not get a file descriptor"); + } else { + QueryRequest *request; + + request = query_request_new (endpoint_dbus, invocation, fd); + tracker_sparql_connection_query_async (conn, + query, + endpoint_dbus->cancellable, + query_cb, + request); + } + + g_free (query); + } else if (g_strcmp0 (method_name, "Update") == 0 || + g_strcmp0 (method_name, "UpdateArray") == 0) { + /* FIXME: Anon/named graphs are ignored ATM */ + g_variant_get (parameters, "(asash)", NULL, NULL, &handle); + + if (fd_list) + fd = g_unix_fd_list_get (fd_list, handle, &error); + + if (fd < 0) { + g_dbus_method_invocation_return_error (invocation, + G_DBUS_ERROR, + G_DBUS_ERROR_INVALID_ARGS, + "Did not get a file descriptor"); + } else { + UpdateRequest *request; + + request = update_request_new (endpoint_dbus, invocation, + g_strcmp0 (method_name, "UpdateArray") == 0, + fd); + update_request_read_next (request, read_update_cb); + } + } else if (g_strcmp0 (method_name, "UpdateBlank") == 0) { + /* FIXME: Anon/named graphs are ignored ATM */ + g_variant_get (parameters, "(asash)", NULL, NULL, &handle); + + if (fd_list) + fd = g_unix_fd_list_get (fd_list, handle, &error); + + if (fd < 0) { + g_dbus_method_invocation_return_error (invocation, + G_DBUS_ERROR, + G_DBUS_ERROR_INVALID_ARGS, + "Did not get a file descriptor"); + } else { + UpdateRequest *request; + + request = update_request_new (endpoint_dbus, invocation, FALSE, fd); + update_request_read_next (request, read_update_blank_cb); + } + } else { + g_dbus_method_invocation_return_error (invocation, + G_DBUS_ERROR, + G_DBUS_ERROR_UNKNOWN_METHOD, + "Unknown method '%s'", method_name); + } +} + +static gboolean +tracker_endpoint_dbus_initable_init (GInitable *initable, + GCancellable *cancellable, + GError **error) +{ + TrackerEndpointDBus *endpoint_dbus = TRACKER_ENDPOINT_DBUS (initable); + + endpoint_dbus->node_info = g_dbus_node_info_new_for_xml (introspection_xml, + error); + if (!endpoint_dbus->node_info) + return FALSE; + + endpoint_dbus->register_id = + g_dbus_connection_register_object (endpoint_dbus->dbus_connection, + endpoint_dbus->object_path, + endpoint_dbus->node_info->interfaces[0], + &(GDBusInterfaceVTable) { + endpoint_dbus_iface_method_call, + NULL, + NULL + }, + endpoint_dbus, + NULL, + error); + return TRUE; +} + +static void +tracker_endpoint_dbus_initable_iface_init (GInitableIface *iface) +{ + iface->init = tracker_endpoint_dbus_initable_init; +} + +static void +tracker_endpoint_dbus_finalize (GObject *object) +{ + TrackerEndpointDBus *endpoint_dbus = TRACKER_ENDPOINT_DBUS (object); + + g_cancellable_cancel (endpoint_dbus->cancellable); + + if (endpoint_dbus->register_id != 0) { + g_dbus_connection_unregister_object (endpoint_dbus->dbus_connection, + endpoint_dbus->register_id); + endpoint_dbus->register_id = 0; + } + + g_clear_object (&endpoint_dbus->cancellable); + g_clear_object (&endpoint_dbus->dbus_connection); + g_clear_pointer (&endpoint_dbus->object_path, g_free); + g_clear_pointer (&endpoint_dbus->node_info, + g_dbus_node_info_unref); + + G_OBJECT_CLASS (tracker_endpoint_dbus_parent_class)->finalize (object); +} + +static void +tracker_endpoint_dbus_set_property (GObject *object, + guint prop_id, + const GValue *value, + GParamSpec *pspec) +{ + TrackerEndpointDBus *endpoint_dbus = TRACKER_ENDPOINT_DBUS (object); + + switch (prop_id) { + case PROP_DBUS_CONNECTION: + endpoint_dbus->dbus_connection = g_value_dup_object (value); + break; + case PROP_OBJECT_PATH: + endpoint_dbus->object_path = g_value_dup_string (value); + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); + break; + } +} + +static void +tracker_endpoint_dbus_get_property (GObject *object, + guint prop_id, + GValue *value, + GParamSpec *pspec) +{ + TrackerEndpointDBus *endpoint_dbus = TRACKER_ENDPOINT_DBUS (object); + + switch (prop_id) { + case PROP_DBUS_CONNECTION: + g_value_set_object (value, endpoint_dbus->dbus_connection); + break; + case PROP_OBJECT_PATH: + g_value_set_string (value, endpoint_dbus->object_path); + break; + default: + G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec); + break; + } +} + +static void +tracker_endpoint_dbus_class_init (TrackerEndpointDBusClass *klass) +{ + GObjectClass *object_class = G_OBJECT_CLASS (klass); + + object_class->finalize = tracker_endpoint_dbus_finalize; + object_class->set_property = tracker_endpoint_dbus_set_property; + object_class->get_property = tracker_endpoint_dbus_get_property; + + props[PROP_DBUS_CONNECTION] = + g_param_spec_object ("dbus-connection", + "DBus connection", + "DBus connection", + G_TYPE_DBUS_CONNECTION, + G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY); + props[PROP_OBJECT_PATH] = + g_param_spec_string ("object-path", + "DBus object path", + "DBus object path", + NULL, + G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY); + + g_object_class_install_properties (object_class, N_PROPS, props); +} + +static void +tracker_endpoint_dbus_init (TrackerEndpointDBus *endpoint) +{ +} + +TrackerEndpointDBus * +tracker_endpoint_dbus_new (TrackerSparqlConnection *sparql_connection, + GDBusConnection *dbus_connection, + const gchar *object_path, + GCancellable *cancellable, + GError **error) +{ + g_return_val_if_fail (TRACKER_SPARQL_IS_CONNECTION (sparql_connection), NULL); + g_return_val_if_fail (G_IS_DBUS_CONNECTION (dbus_connection), NULL); + g_return_val_if_fail (!cancellable || G_IS_CANCELLABLE (cancellable), NULL); + g_return_val_if_fail (!error || !*error, NULL); + + return g_initable_new (TRACKER_TYPE_ENDPOINT_DBUS, cancellable, error, + "dbus-connection", dbus_connection, + "sparql-connection", sparql_connection, + "object-path", object_path, + NULL); +} diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql/tracker-endpoint-dbus.h tracker-2.3.4.new/src/libtracker-sparql/tracker-endpoint-dbus.h --- tracker-2.3.4.old/src/libtracker-sparql/tracker-endpoint-dbus.h 1970-01-01 08:00:00.000000000 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql/tracker-endpoint-dbus.h 2023-12-08 18:21:10.626357173 +0800 @@ -0,0 +1,41 @@ +/* + * Copyright (C) 2019, Red Hat, Inc + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library 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 + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the + * Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + * Boston, MA 02110-1301, USA. + * + * Author: Carlos Garnacho <carlosg@gnome.org> + */ + +#ifndef __TRACKER_ENDPOINT_DBUS_H__ +#define __TRACKER_ENDPOINT_DBUS_H__ + +#if !defined (__LIBTRACKER_SPARQL_INSIDE__) && !defined (TRACKER_COMPILATION) +#error "only <libtracker-sparql/tracker-sparql.h> must be included directly." +#endif + +#include <libtracker-sparql/tracker-endpoint.h> + +#define TRACKER_TYPE_ENDPOINT_DBUS tracker_endpoint_dbus_get_type() +G_DECLARE_FINAL_TYPE (TrackerEndpointDBus, tracker_endpoint_dbus, TRACKER, ENDPOINT_DBUS, TrackerEndpoint) + +TrackerEndpointDBus * +tracker_endpoint_dbus_new (TrackerSparqlConnection *sparql_connection, + GDBusConnection *dbus_connection, + const gchar *object_path, + GCancellable *cancellable, + GError **error); + +#endif /* __TRACKER_ENDPOINT_DBUS_H__ */ diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql/tracker-endpoint.h tracker-2.3.4.new/src/libtracker-sparql/tracker-endpoint.h --- tracker-2.3.4.old/src/libtracker-sparql/tracker-endpoint.h 1970-01-01 08:00:00.000000000 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql/tracker-endpoint.h 2023-12-08 18:21:10.626357173 +0800 @@ -0,0 +1,41 @@ +/* + * Copyright (C) 2019, Red Hat, Inc + * + * This library is free software; you can redistribute it and/or + * modify it under the terms of the GNU Lesser General Public + * License as published by the Free Software Foundation; either + * version 2.1 of the License, or (at your option) any later version. + * + * This library 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 + * Lesser General Public License for more details. + * + * You should have received a copy of the GNU Lesser General Public + * License along with this library; if not, write to the + * Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, + * Boston, MA 02110-1301, USA. + * + * Author: Carlos Garnacho <carlosg@gnome.org> + */ + +#ifndef __TRACKER_ENDPOINT_H__ +#define __TRACKER_ENDPOINT_H__ + +#if !defined (__LIBTRACKER_SPARQL_INSIDE__) && !defined (TRACKER_COMPILATION) +#error "only <libtracker-sparql/tracker-sparql.h> must be included directly." +#endif + +#include <glib-object.h> +#include <libtracker-sparql/tracker-generated.h> + +#define TRACKER_TYPE_ENDPOINT tracker_endpoint_get_type() +G_DECLARE_DERIVABLE_TYPE (TrackerEndpoint, tracker_endpoint, TRACKER, ENDPOINT, GObject) + +struct _TrackerEndpointClass { + GObjectClass parent_class; +}; + +TrackerSparqlConnection * tracker_endpoint_get_sparql_connection (TrackerEndpoint *endpoint); + +#endif /* __TRACKER_ENDPOINT_H__ */ diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql/tracker-sparql.h tracker-2.3.4.new/src/libtracker-sparql/tracker-sparql.h --- tracker-2.3.4.old/src/libtracker-sparql/tracker-sparql.h 2020-03-10 07:27:20.373601200 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql/tracker-sparql.h 2023-12-08 18:21:10.626357173 +0800 @@ -22,6 +22,8 @@ #define __LIBTRACKER_SPARQL_INSIDE__ +#include <libtracker-sparql/tracker-endpoint.h> +#include <libtracker-sparql/tracker-endpoint-dbus.h> #include <libtracker-sparql/tracker-version.h> #include <libtracker-sparql/tracker-ontologies.h> #include <libtracker-sparql/tracker-resource.h> diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql-backend/tracker-backend.vala tracker-2.3.4.new/src/libtracker-sparql-backend/tracker-backend.vala --- tracker-2.3.4.old/src/libtracker-sparql-backend/tracker-backend.vala 2020-03-10 07:27:20.370601200 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql-backend/tracker-backend.vala 2023-12-08 20:01:01.015097597 +0800 @@ -358,6 +358,10 @@ return new Tracker.Remote.Connection (url_base); } +public static Tracker.Sparql.Connection tracker_sparql_connection_bus_new (string service, DBusConnection? conn) throws Tracker.Sparql.Error, IOError, DBusError, GLib.Error { + return new Tracker.Bus.Connection (service, conn, true); +} + public static Tracker.Sparql.Connection tracker_sparql_connection_local_new (Tracker.Sparql.ConnectionFlags flags, File store, File? journal, File? ontology, Cancellable? cancellable = null) throws GLib.Error, Tracker.Sparql.Error, IOError { var conn = new Tracker.Direct.Connection (flags, store, journal, ontology); conn.init (cancellable); diff --unified --recursive --text --new-file --color tracker-2.3.4.old/src/libtracker-sparql-backend/tracker-sparql-2.map tracker-2.3.4.new/src/libtracker-sparql-backend/tracker-sparql-2.map --- tracker-2.3.4.old/src/libtracker-sparql-backend/tracker-sparql-2.map 2020-03-10 07:27:20.370601200 +0800 +++ tracker-2.3.4.new/src/libtracker-sparql-backend/tracker-sparql-2.map 2023-12-08 18:21:10.619690274 +0800 @@ -11,6 +11,7 @@ tracker_namespace_manager_*; tracker_resource_*; tracker_notifier_*; + tracker_endpoint_*; local: *; };
Locations
Projects
Search
Status Monitor
Help
OpenBuildService.org
Documentation
API Documentation
Code of Conduct
Contact
Support
@OBShq
Terms
openSUSE Build Service is sponsored by
The Open Build Service is an
openSUSE project
.
Sign Up
Log In
Places
Places
All Projects
Status Monitor
