[gvfs/gdbus-core: 29/29] gdbus: Push new GVfsJobProgress class

[Tomas Bzatek <tbzatek src gnome org>]

commit 4163c37d1eddd6e415f4a41bc08c6ab65a1fa524
Author: Tomas Bzatek <tbzatek redhat com>
Date:   Fri Jul 13 11:00:39 2012 +0200

    gdbus: Push new GVfsJobProgress class
    
    Forgotten from the 722ebaf0ab949ca5b844a387dc684b4e3185db75 commit

 daemon/gvfsjobprogress.c |  105 ++++++++++++++++++++++++++++++++++++++++++++++
 daemon/gvfsjobprogress.h |   67 +++++++++++++++++++++++++++++
 2 files changed, 172 insertions(+), 0 deletions(-)
---
diff --git a/daemon/gvfsjobprogress.c b/daemon/gvfsjobprogress.c
new file mode 100644
index 0000000..e1ccc77
--- /dev/null
+++ b/daemon/gvfsjobprogress.c
@@ -0,0 +1,105 @@
+/* GIO - GLib Input, Output and Streaming Library
+ * 
+ * Copyright (C) 2012 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 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., 59 Temple Place, Suite 330,
+ * Boston, MA 02111-1307, USA.
+ *
+ * Author: Tomas Bzatek <tbzatek redhat com>
+ */
+
+#include <config.h>
+
+#include <unistd.h>
+#include <sys/types.h>
+#include <sys/socket.h>
+#include <sys/un.h>
+
+#include <glib.h>
+#include <glib/gi18n.h>
+#include "gvfsjobprogress.h"
+
+G_DEFINE_TYPE (GVfsJobProgress, g_vfs_job_progress, G_VFS_TYPE_JOB_DBUS)
+
+static void
+g_vfs_job_progress_finalize (GObject *object)
+{
+  GVfsJobProgress *job;
+
+  job = G_VFS_JOB_PROGRESS (object);
+
+  g_free (job->callback_obj_path);
+
+  if (G_OBJECT_CLASS (g_vfs_job_progress_parent_class)->finalize)
+    (*G_OBJECT_CLASS (g_vfs_job_progress_parent_class)->finalize) (object);
+}
+
+static void
+g_vfs_job_progress_class_init (GVfsJobProgressClass *klass)
+{
+  GObjectClass *gobject_class = G_OBJECT_CLASS (klass);
+  
+  gobject_class->finalize = g_vfs_job_progress_finalize;
+}
+
+static void
+g_vfs_job_progress_init (GVfsJobProgress *job)
+{
+}
+
+void
+g_vfs_job_progress_callback (goffset current_num_bytes,
+                             goffset total_num_bytes,
+                             gpointer user_data)
+{
+  GVfsJobProgress *job = G_VFS_JOB_PROGRESS (user_data);
+  GVfsJobDBus *dbus_job = G_VFS_JOB_DBUS (job);
+
+  g_debug ("g_vfs_job_progress_callback %" G_GOFFSET_FORMAT "/%" G_GOFFSET_FORMAT "\n", current_num_bytes, total_num_bytes);
+
+  if (job->callback_obj_path == NULL || job->progress_proxy == NULL)
+    return;
+
+  gvfs_dbus_progress_call_progress (job->progress_proxy,
+                                    current_num_bytes,
+                                    total_num_bytes,
+                                    NULL,
+                                    NULL,
+                                    NULL);
+  g_dbus_connection_flush_sync (g_dbus_method_invocation_get_connection (dbus_job->invocation), NULL, NULL);
+}
+
+void
+g_vfs_job_progress_construct_proxy (GVfsJob *job)
+{
+  GVfsJobDBus *dbus_job = G_VFS_JOB_DBUS (job);
+  GVfsJobProgress *progress_job = G_VFS_JOB_PROGRESS (job);
+  GError *error = NULL;
+
+  if (!progress_job->send_progress)
+    return;
+  
+  progress_job->progress_proxy = gvfs_dbus_progress_proxy_new_sync (g_dbus_method_invocation_get_connection (dbus_job->invocation),
+                                                                    G_DBUS_PROXY_FLAGS_DO_NOT_LOAD_PROPERTIES | G_DBUS_PROXY_FLAGS_DO_NOT_CONNECT_SIGNALS,
+                                                                    g_dbus_method_invocation_get_sender (dbus_job->invocation),
+                                                                    progress_job->callback_obj_path,
+                                                                    NULL,
+                                                                    &error);
+  if (!progress_job->progress_proxy)
+    {
+      g_warning ("g_vfs_job_progress_construct_proxy: %s (%s, %d)\n", error->message, g_quark_to_string (error->domain), error->code);
+      g_error_free (error);
+    }
+}
diff --git a/daemon/gvfsjobprogress.h b/daemon/gvfsjobprogress.h
new file mode 100644
index 0000000..0e4d35b
--- /dev/null
+++ b/daemon/gvfsjobprogress.h
@@ -0,0 +1,67 @@
+/* GIO - GLib Input, Output and Streaming Library
+ * 
+ * Copyright (C) 2012 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 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., 59 Temple Place, Suite 330,
+ * Boston, MA 02111-1307, USA.
+ *
+ * Author: Tomas Bzatek <tbzatek redhat com>
+ */
+
+#ifndef __G_VFS_JOB_PROGRESS_H__
+#define __G_VFS_JOB_PROGRESS_H__
+
+#include <gvfsjob.h>
+#include <gvfsjobdbus.h>
+#include <gvfsbackend.h>
+
+G_BEGIN_DECLS
+
+#define G_VFS_TYPE_JOB_PROGRESS         (g_vfs_job_progress_get_type ())
+#define G_VFS_JOB_PROGRESS(o)           (G_TYPE_CHECK_INSTANCE_CAST ((o), G_VFS_TYPE_JOB_PROGRESS, GVfsJobProgress))
+#define G_VFS_JOB_PROGRESS_CLASS(k)     (G_TYPE_CHECK_CLASS_CAST((k), G_VFS_TYPE_JOB_PROGRESS, GVfsJobProgressClass))
+#define G_VFS_IS_JOB_PROGRESS(o)        (G_TYPE_CHECK_INSTANCE_TYPE ((o), G_VFS_TYPE_JOB_PROGRESS))
+#define G_VFS_IS_JOB_PROGRESS_CLASS(k)  (G_TYPE_CHECK_CLASS_TYPE ((k), G_VFS_TYPE_JOB_PROGRESS))
+#define G_VFS_JOB_PROGRESS_GET_CLASS(o) (G_TYPE_INSTANCE_GET_CLASS ((o), G_VFS_TYPE_JOB_PROGRESS, GVfsJobProgressClass))
+
+typedef struct _GVfsJobProgress        GVfsJobProgress;
+typedef struct _GVfsJobProgressClass   GVfsJobProgressClass;
+
+struct _GVfsJobProgress
+{
+  GVfsJobDBus parent_instance;
+
+  gboolean send_progress;
+  char *callback_obj_path;
+  GVfsDBusProgress *progress_proxy;
+};
+
+struct _GVfsJobProgressClass
+{
+  GVfsJobDBusClass parent_class;
+};
+
+GType g_vfs_job_progress_get_type (void) G_GNUC_CONST;
+
+void g_vfs_job_progress_callback (goffset current_num_bytes,
+                                  goffset total_num_bytes,
+                                  gpointer user_data);
+
+void g_vfs_job_progress_construct_proxy (GVfsJob *job);
+
+
+G_END_DECLS
+
+#endif /* __G_VFS_JOB_PROGRESS_H__ */