Initial work on the new way to track mountpoints.

Daemon side only.

Original git commit by Alexander Larsson <alex@greebo.(none)> at 1165492556 +0100

svn path=/trunk/; revision=219

1 files changed, 162 insertions, 0 deletions

diff --git a/daemon/gvfsjobdbus.c b/daemon/gvfsjobdbus.c
new file mode 100644
index 00000000..d693f346
--- /dev/null
+++ b/daemon/gvfsjobdbus.c
@@ -0,0 +1,162 @@
+#include <config.h>
+
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/un.h>
+
+#include <glib.h>
+#include <dbus/dbus.h>
+#include <glib/gi18n.h>
+#include "gvfsjobdbus.h"
+#include "gvfsdaemonutils.h"
+
+G_DEFINE_TYPE (GVfsJobDBus, g_vfs_job_dbus, G_TYPE_VFS_JOB);
+
+/* TODO: Real P_() */
+#define P_(_x) (_x)
+
+enum {
+  PROP_0,
+  PROP_MESSAGE,
+  PROP_CONNECTION,
+};
+
+static void send_reply                  (GVfsJob      *job);
+static void g_vfs_job_dbus_get_property (GObject      *object,
+					 guint         prop_id,
+					 GValue       *value,
+					 GParamSpec   *pspec);
+static void g_vfs_job_dbus_set_property (GObject      *object,
+					 guint         prop_id,
+					 const GValue *value,
+					 GParamSpec   *pspec);
+
+static void
+g_vfs_job_dbus_finalize (GObject *object)
+{
+  GVfsJobDBus *job;
+
+  job = G_VFS_JOB_DBUS (object);
+
+  if (job->message)
+    dbus_message_unref (job->message);
+
+  if (job->connection)
+    dbus_connection_unref (job->connection);
+  
+  if (G_OBJECT_CLASS (g_vfs_job_dbus_parent_class)->finalize)
+    (*G_OBJECT_CLASS (g_vfs_job_dbus_parent_class)->finalize) (object);
+}
+
+static void
+g_vfs_job_dbus_class_init (GVfsJobDBusClass *klass)
+{
+  GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
+  GVfsJobClass *job_class = G_VFS_JOB_CLASS (klass);
+  
+  gobject_class->finalize = g_vfs_job_dbus_finalize;
+  gobject_class->set_property = g_vfs_job_dbus_set_property;
+  gobject_class->get_property = g_vfs_job_dbus_get_property;
+
+  job_class->send_reply = send_reply;
+
+  g_object_class_install_property (gobject_class,
+				   PROP_CONNECTION,
+				   g_param_spec_pointer ("connection",
+							P_("VFS Backend"),
+							P_("The implementation for this job operartion."),
+							G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
+							G_PARAM_STATIC_NAME|G_PARAM_STATIC_NICK|G_PARAM_STATIC_BLURB));
+  g_object_class_install_property (gobject_class,
+				   PROP_MESSAGE,
+				   g_param_spec_pointer ("message",
+							P_("VFS Backend"),
+							P_("The implementation for this job operartion."),
+							G_PARAM_READWRITE | G_PARAM_CONSTRUCT_ONLY |
+							G_PARAM_STATIC_NAME|G_PARAM_STATIC_NICK|G_PARAM_STATIC_BLURB));
+}
+
+static void
+g_vfs_job_dbus_init (GVfsJobDBus *job)
+{
+}
+
+static void
+g_vfs_job_dbus_set_property (GObject         *object,
+			     guint            prop_id,
+			     const GValue    *value,
+			     GParamSpec      *pspec)
+{
+  GVfsJobDBus *job = G_VFS_JOB_DBUS (object);
+  
+  switch (prop_id)
+    {
+    case PROP_MESSAGE:
+      job->message = dbus_message_ref (g_value_get_pointer (value));
+      break;
+    case PROP_CONNECTION:
+      job->connection = dbus_connection_ref (g_value_get_pointer (value));
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+    }
+}
+
+static void
+g_vfs_job_dbus_get_property (GObject    *object,
+			     guint       prop_id,
+			     GValue     *value,
+			     GParamSpec *pspec)
+{
+  GVfsJobDBus *job = G_VFS_JOB_DBUS (object);
+
+  switch (prop_id)
+    {
+    case PROP_MESSAGE:
+      g_value_set_pointer (value, job->message);
+      break;
+    case PROP_CONNECTION:
+      g_value_set_pointer (value, job->connection);
+      break;
+    default:
+      G_OBJECT_WARN_INVALID_PROPERTY_ID (object, prop_id, pspec);
+      break;
+    }
+}
+
+/* Might be called on an i/o thread */
+static void
+send_reply (GVfsJob *job)
+{
+  GVfsJobDBus *dbus_job = G_VFS_JOB_DBUS (job);
+  DBusMessage *reply;
+  GVfsJobDBusClass *class;
+
+  g_print ("send_reply, failed=%d (%s)\n", job->failed, job->failed?job->error->message:"");
+  
+  class = G_VFS_JOB_DBUS_GET_CLASS (job);
+  
+  if (job->failed) 
+    reply = dbus_message_new_error_from_gerror (dbus_job->message, job->error);
+  else
+    reply = class->create_reply (job, dbus_job->connection, dbus_job->message);
+ 
+  g_assert (reply != NULL);
+
+  /* Queues reply (threadsafely), actually sends it in mainloop */
+  dbus_connection_send (dbus_job->connection, reply, NULL);
+  dbus_message_unref (reply);
+
+  g_vfs_job_emit_finished (job);
+}
+
+gboolean
+g_vfs_job_dbus_is_serial (GVfsJobDBus *job_dbus,
+			  DBusConnection *connection,
+			  dbus_uint32_t serial)
+{
+  return job_dbus->connection == connection &&
+    dbus_message_get_serial (job_dbus->message) == serial;
+}