diff options
| -rw-r--r-- | daemon/gvfsjobprogress.c | 105 | ||||
| -rw-r--r-- | 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 00000000..e1ccc773 --- /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 00000000..0e4d35b4 --- /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__ */ |