X-Git-Url: https://www.fi.muni.cz/~kas/git//home/kas/public_html/git/?a=blobdiff_plain;f=shell%2Fev-daemon.c;h=6ecd48c1f8af1b470ebe1b70d62c14ee03110214;hb=b78ca7547945cef51c8224672d4a46cb2e74b2dc;hp=c44f8a8b1c8eff48c0be571b5059da3a1cc91465;hpb=f9e5408ac68703a89c556a1bcb394a8c67498cca;p=evince.git
diff --git a/shell/ev-daemon.c b/shell/ev-daemon.c
index c44f8a8b..6ecd48c1 100644
--- a/shell/ev-daemon.c
+++ b/shell/ev-daemon.c
@@ -41,11 +41,12 @@
static GList *ev_daemon_docs = NULL;
static guint kill_timer_id;
+static GHashTable *pending_invocations = NULL;
typedef struct {
gchar *dbus_name;
gchar *uri;
- guint watch_id;
+ guint watch_id;
} EvDoc;
static void
@@ -205,6 +206,29 @@ ev_migrate_metadata (void)
g_free (metadata);
}
+static gboolean
+spawn_evince (const gchar *uri)
+{
+ gchar *argv[3];
+ gboolean retval;
+ GError *error = NULL;
+
+ /* TODO Check that the uri exists */
+ argv[0] = g_build_filename (BINDIR, "evince", NULL);
+ argv[1] = (gchar *) uri;
+ argv[2] = NULL;
+
+ retval = g_spawn_async (NULL /* wd */, argv, NULL /* env */,
+ 0, NULL, NULL, NULL, &error);
+ if (!retval) {
+ g_printerr ("Error spawning evince for uri %s: %s\n", uri, error->message);
+ g_error_free (error);
+ }
+ g_free (argv[0]);
+
+ return retval;
+}
+
static void
name_appeared_cb (GDBusConnection *connection,
const gchar *name,
@@ -239,6 +263,28 @@ name_vanished_cb (GDBusConnection *connection,
}
}
+static void
+process_pending_invocations (const gchar *uri,
+ const gchar *dbus_name)
+{
+ GList *l;
+ GList *uri_invocations;
+
+ LOG ("RegisterDocument process pending invocations for URI %s\n", uri);
+ uri_invocations = g_hash_table_lookup (pending_invocations, uri);
+
+ for (l = uri_invocations; l != NULL; l = l->next) {
+ GDBusMethodInvocation *invocation;
+
+ invocation = (GDBusMethodInvocation *)l->data;
+ g_dbus_method_invocation_return_value (invocation,
+ g_variant_new ("(s)", dbus_name));
+ }
+
+ g_list_free (uri_invocations);
+ g_hash_table_remove (pending_invocations, uri);
+}
+
static void
method_call_cb (GDBusConnection *connection,
const gchar *sender,
@@ -265,26 +311,25 @@ method_call_cb (GDBusConnection *connection,
g_variant_new ("(s)", doc->dbus_name));
return;
}
-
+
ev_daemon_stop_killtimer ();
doc = g_new (EvDoc, 1);
doc->dbus_name = g_strdup (sender);
doc->uri = g_strdup (uri);
+ process_pending_invocations (doc->uri, doc->dbus_name);
- doc->watch_id = g_bus_watch_name (G_BUS_TYPE_STARTER,
- sender,
- G_BUS_NAME_WATCHER_FLAGS_NONE,
- name_appeared_cb,
- name_vanished_cb,
- user_data, NULL);
+ doc->watch_id = g_bus_watch_name_on_connection (connection,
+ sender,
+ G_BUS_NAME_WATCHER_FLAGS_NONE,
+ name_appeared_cb,
+ name_vanished_cb,
+ user_data, NULL);
LOG ("RegisterDocument registered owner '%s' for URI '%s'\n", doc->dbus_name, uri);
ev_daemon_docs = g_list_prepend (ev_daemon_docs, doc);
g_dbus_method_invocation_return_value (invocation, g_variant_new ("(s)", ""));
- return;
-
} else if (g_strcmp0 (method_name, "UnregisterDocument") == 0) {
EvDoc *doc;
const gchar *uri;
@@ -319,30 +364,47 @@ method_call_cb (GDBusConnection *connection,
ev_daemon_maybe_start_killtimer (user_data);
g_dbus_method_invocation_return_value (invocation, g_variant_new ("()"));
- return;
- }
-}
+ } else if (g_strcmp0 (method_name, "FindDocument") == 0) {
+ EvDoc *doc;
+ const gchar *uri;
+ gboolean spawn;
-static void
-name_acquired_cb (GDBusConnection *connection,
- const gchar *name,
- gpointer user_data)
-{
- ev_migrate_metadata ();
+ g_variant_get (parameters, "(&sb)", &uri, &spawn);
- ev_daemon_maybe_start_killtimer (user_data);
-}
+ LOG ("FindDocument URI '%s' \n", uri);
-static void
-name_lost_cb (GDBusConnection *connection,
- const gchar *name,
- gpointer user_data)
-{
- GMainLoop *loop = (GMainLoop *) user_data;
+ doc = ev_daemon_find_doc (uri);
+ if (doc != NULL) {
+ g_dbus_method_invocation_return_value (invocation,
+ g_variant_new ("(s)", doc->dbus_name));
+ return;
+ }
- /* Failed to acquire the name; exit daemon */
- if (g_main_loop_is_running (loop))
- g_main_loop_quit (loop);
+ if (spawn) {
+ GList *uri_invocations;
+ gboolean ret_val = TRUE;
+
+ uri_invocations = g_hash_table_lookup (pending_invocations, uri);
+
+ if (uri_invocations == NULL) {
+ /* Only spawn once. */
+ ret_val = spawn_evince (uri);
+ }
+
+ if (ret_val) {
+ /* Only defer DBUS answer if evince was succesfully spawned */
+ uri_invocations = g_list_prepend (uri_invocations, invocation);
+ g_hash_table_insert (pending_invocations,
+ g_strdup (uri),
+ uri_invocations);
+ return;
+ }
+ }
+
+ LOG ("FindDocument URI '%s' was not registered!\n", uri);
+ g_dbus_method_invocation_return_value (invocation,
+ g_variant_new ("(s)",""));
+ }
}
static const char introspection_xml[] =
@@ -355,6 +417,11 @@ static const char introspection_xml[] =
""
""
""
+ ""
+ ""
+ ""
+ ""
+ ""
""
"";
@@ -364,63 +431,94 @@ static const GDBusInterfaceVTable interface_vtable = {
NULL
};
+static GDBusNodeInfo *introspection_data;
+
+static void
+bus_acquired_cb (GDBusConnection *connection,
+ const gchar *name,
+ gpointer user_data)
+{
+ GMainLoop *loop = (GMainLoop *) user_data;
+ guint registration_id;
+ GError *error = NULL;
+
+ if (!introspection_data)
+ introspection_data = g_dbus_node_info_new_for_xml (introspection_xml, NULL);
+
+ registration_id = g_dbus_connection_register_object (connection,
+ EV_DBUS_DAEMON_OBJECT_PATH,
+ introspection_data->interfaces[0],
+ &interface_vtable,
+ g_main_loop_ref (loop),
+ (GDestroyNotify) g_main_loop_unref,
+ &error);
+ if (registration_id == 0) {
+ g_printerr ("Failed to register object: %s\n", error->message);
+ g_error_free (error);
+
+ if (g_main_loop_is_running (loop))
+ g_main_loop_quit (loop);
+ }
+}
+
+static void
+name_acquired_cb (GDBusConnection *connection,
+ const gchar *name,
+ gpointer user_data)
+{
+ ev_migrate_metadata ();
+
+ ev_daemon_maybe_start_killtimer (user_data);
+}
+
+static void
+name_lost_cb (GDBusConnection *connection,
+ const gchar *name,
+ gpointer user_data)
+{
+ GMainLoop *loop = (GMainLoop *) user_data;
+
+ /* Failed to acquire the name; exit daemon */
+ if (g_main_loop_is_running (loop))
+ g_main_loop_quit (loop);
+}
+
gint
main (gint argc, gchar **argv)
{
- GDBusConnection *connection;
GMainLoop *loop;
- GError *error = NULL;
- guint registration_id, owner_id;
- GDBusNodeInfo *introspection_data;
+ guint owner_id;
g_set_prgname ("evince-daemon");
g_type_init ();
- connection = g_bus_get_sync (G_BUS_TYPE_STARTER, NULL, &error);
- if (connection == NULL) {
- g_printerr ("Failed to get bus connection: %s\n", error->message);
- g_error_free (error);
- return 1;
- }
-
- introspection_data = g_dbus_node_info_new_for_xml (introspection_xml, NULL);
- g_assert (introspection_data != NULL);
-
loop = g_main_loop_new (NULL, FALSE);
- registration_id = g_dbus_connection_register_object (connection,
- EV_DBUS_DAEMON_OBJECT_PATH,
- EV_DBUS_DAEMON_NAME,
- introspection_data->interfaces[0],
- &interface_vtable,
- g_main_loop_ref (loop),
- (GDestroyNotify) g_main_loop_unref,
- &error);
- if (registration_id == 0) {
- g_printerr ("Failed to register object: %s\n", error->message);
- g_error_free (error);
- g_object_unref (connection);
- return 1;
- }
+ pending_invocations = g_hash_table_new_full (g_str_hash,
+ g_str_equal,
+ (GDestroyNotify)g_free,
+ NULL);
- owner_id = g_bus_own_name_on_connection (connection,
- EV_DBUS_DAEMON_NAME,
- G_BUS_NAME_OWNER_FLAGS_NONE,
- name_acquired_cb,
- name_lost_cb,
- g_main_loop_ref (loop),
- (GDestroyNotify) g_main_loop_unref);
+ owner_id = g_bus_own_name (G_BUS_TYPE_SESSION,
+ EV_DBUS_DAEMON_NAME,
+ G_BUS_NAME_OWNER_FLAGS_NONE,
+ bus_acquired_cb,
+ name_acquired_cb,
+ name_lost_cb,
+ g_main_loop_ref (loop),
+ (GDestroyNotify) g_main_loop_unref);
g_main_loop_run (loop);
g_bus_unown_name (owner_id);
g_main_loop_unref (loop);
- g_dbus_node_info_unref (introspection_data);
+ if (introspection_data)
+ g_dbus_node_info_unref (introspection_data);
g_list_foreach (ev_daemon_docs, (GFunc)ev_doc_free, NULL);
g_list_free (ev_daemon_docs);
- g_object_unref (connection);
+ g_hash_table_destroy (pending_invocations);
return 0;
}