533 lines
16 KiB
C
533 lines
16 KiB
C
|
/*
|
||
|
|
* Copyright (C) 2009 Intel Corporation
|
||
|
|
*
|
||
|
|
* 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) version 3.
|
||
|
|
*
|
||
|
|
* 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
|
||
|
|
*/
|
||
|
|
|
||
|
|
#include <glib-object.h>
|
||
|
|
#include <string.h>
|
||
|
|
|
||
|
|
#include "syncevo-session.h"
|
||
|
|
#include "syncevo-marshal.h"
|
||
|
|
#include "syncevo-session-bindings.h"
|
||
|
|
|
||
|
|
typedef struct _SessionAsyncData {
|
||
|
|
SyncevoSession *session;
|
||
|
|
GCallback callback;
|
||
|
|
gpointer userdata;
|
||
|
|
} SessionAsyncData;
|
||
|
|
|
||
|
|
enum {
|
||
|
|
STATUS_CHANGED,
|
||
|
|
PROGRESS_CHANGED,
|
||
|
|
LAST_SIGNAL
|
||
|
|
};
|
||
|
|
static guint32 signals[LAST_SIGNAL] = {0, };
|
||
|
|
|
||
|
|
typedef struct _SyncevoSessionPrivate {
|
||
|
|
DBusGProxy *proxy;
|
||
|
|
} SyncevoSessionPrivate;
|
||
|
|
|
||
|
|
#define GET_PRIVATE(o) (G_TYPE_INSTANCE_GET_PRIVATE ((o), SYNCEVO_TYPE_SESSION, SyncevoSessionPrivate))
|
||
|
|
G_DEFINE_TYPE (SyncevoSession, syncevo_session, G_TYPE_OBJECT);
|
||
|
|
|
||
|
|
static SessionAsyncData*
|
||
|
|
session_async_data_new (SyncevoSession *session,
|
||
|
|
GCallback callback,
|
||
|
|
gpointer userdata)
|
||
|
|
{
|
||
|
|
SessionAsyncData *data;
|
||
|
|
|
||
|
|
data = g_slice_new0 (SessionAsyncData);
|
||
|
|
data->session = session;
|
||
|
|
data->callback = G_CALLBACK (callback);
|
||
|
|
data->userdata = userdata;
|
||
|
|
|
||
|
|
return data;
|
||
|
|
}
|
||
|
|
|
||
|
|
static void
|
||
|
|
session_async_data_free (SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
g_slice_free (SessionAsyncData, data);
|
||
|
|
}
|
||
|
|
|
||
|
|
static void
|
||
|
|
status_changed_cb (DBusGProxy *proxy,
|
||
|
|
SyncevoSessionStatus status,
|
||
|
|
guint error_code,
|
||
|
|
SyncevoSourceStatuses *source_statuses,
|
||
|
|
SyncevoSession *session)
|
||
|
|
{
|
||
|
|
g_signal_emit (session, signals[STATUS_CHANGED], 0,
|
||
|
|
status,
|
||
|
|
error_code,
|
||
|
|
source_statuses);
|
||
|
|
}
|
||
|
|
|
||
|
|
static void
|
||
|
|
progress_changed_cb (DBusGProxy *proxy,
|
||
|
|
guint progress,
|
||
|
|
SyncevoSourceProgresses *source_progresses,
|
||
|
|
SyncevoSession *session)
|
||
|
|
{
|
||
|
|
g_signal_emit (session, signals[PROGRESS_CHANGED], 0,
|
||
|
|
progress,
|
||
|
|
source_progresses);
|
||
|
|
}
|
||
|
|
|
||
|
|
static void
|
||
|
|
dispose (GObject *object)
|
||
|
|
{
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (object);
|
||
|
|
|
||
|
|
if (priv->proxy) {
|
||
|
|
dbus_g_proxy_disconnect_signal (priv->proxy, "ProgressChanged",
|
||
|
|
G_CALLBACK (progress_changed_cb),
|
||
|
|
object);
|
||
|
|
dbus_g_proxy_disconnect_signal (priv->proxy, "StatusChanged",
|
||
|
|
G_CALLBACK (status_changed_cb),
|
||
|
|
object);
|
||
|
|
|
||
|
|
g_object_unref (priv->proxy);
|
||
|
|
priv->proxy = NULL;
|
||
|
|
}
|
||
|
|
|
||
|
|
G_OBJECT_CLASS (syncevo_session_parent_class)->dispose (object);
|
||
|
|
}
|
||
|
|
|
||
|
|
static void
|
||
|
|
syncevo_session_init (SyncevoSession *session)
|
||
|
|
{
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (session);
|
||
|
|
|
||
|
|
/* ProgressChanged */
|
||
|
|
dbus_g_object_register_marshaller (syncevo_marshal_VOID__INT_BOXED,
|
||
|
|
G_TYPE_NONE,
|
||
|
|
G_TYPE_INT,
|
||
|
|
G_TYPE_BOXED,
|
||
|
|
G_TYPE_INVALID);
|
||
|
|
/* StatusChanged */
|
||
|
|
dbus_g_object_register_marshaller (syncevo_marshal_VOID__INT_INT_BOXED,
|
||
|
|
G_TYPE_NONE,
|
||
|
|
G_TYPE_INT,
|
||
|
|
G_TYPE_INT,
|
||
|
|
G_TYPE_BOXED,
|
||
|
|
G_TYPE_INVALID);
|
||
|
|
|
||
|
|
/*TODO init proxy in the path setter
|
||
|
|
priv->proxy = dbus_g_proxy_new_for_name (connection,
|
||
|
|
SYNCEVO_SESSION_DBUS_SERVICE,
|
||
|
|
path,
|
||
|
|
SYNCEVO_SESSION_DBUS_INTERFACE);
|
||
|
|
if (priv->proxy == NULL) {
|
||
|
|
g_printerr ("dbus_g_proxy_new_for_name() failed for path '%s'", path);
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
*/
|
||
|
|
|
||
|
|
/* TODO for all signals
|
||
|
|
dbus_g_proxy_add_signal
|
||
|
|
dbus_g_proxy_connect_signal
|
||
|
|
|
||
|
|
*/
|
||
|
|
}
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
static void
|
||
|
|
generic_callback (DBusGProxy *proxy,
|
||
|
|
GError *error,
|
||
|
|
SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
if (data->callback) {
|
||
|
|
(*(SyncevoSessionGenericCb)data->callback) (data->session,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
}
|
||
|
|
session_async_data_free (data);
|
||
|
|
}
|
||
|
|
|
||
|
|
static gboolean
|
||
|
|
generic_error (SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
GError *error;
|
||
|
|
|
||
|
|
error = g_error_new_literal (g_quark_from_static_string ("syncevo-session"),
|
||
|
|
SYNCEVO_SESSION_ERROR_NO_DBUS_OBJECT,
|
||
|
|
"The D-Bus object does not exist");
|
||
|
|
(*(SyncevoSessionGenericCb)data->callback) (data->session,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
session_async_data_free (data);
|
||
|
|
|
||
|
|
return FALSE;
|
||
|
|
}
|
||
|
|
|
||
|
|
static void
|
||
|
|
get_config_callback (DBusGProxy *proxy,
|
||
|
|
SyncevoConfig *configuration,
|
||
|
|
GError *error,
|
||
|
|
SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
if (data->callback) {
|
||
|
|
(*(SyncevoSessionGetConfigCb)data->callback) (data->session,
|
||
|
|
configuration,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
}
|
||
|
|
session_async_data_free (data);
|
||
|
|
}
|
||
|
|
|
||
|
|
static gboolean
|
||
|
|
get_config_error (SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
GError *error;
|
||
|
|
|
||
|
|
error = g_error_new_literal (g_quark_from_static_string ("syncevo-session"),
|
||
|
|
SYNCEVO_SESSION_ERROR_NO_DBUS_OBJECT,
|
||
|
|
"The D-Bus object does not exist");
|
||
|
|
(*(SyncevoSessionGetConfigCb)data->callback) (data->session,
|
||
|
|
NULL,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
session_async_data_free (data);
|
||
|
|
|
||
|
|
return FALSE;
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
syncevo_session_get_config (SyncevoSession *session,
|
||
|
|
SyncevoSessionGetConfigCb callback,
|
||
|
|
gpointer userdata)
|
||
|
|
{
|
||
|
|
SessionAsyncData *data;
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (session);
|
||
|
|
|
||
|
|
data = session_async_data_new (session, G_CALLBACK (callback), userdata);
|
||
|
|
|
||
|
|
if (!priv->proxy) {
|
||
|
|
if (callback) {
|
||
|
|
g_idle_add ((GSourceFunc)get_config_error, data);
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
org_syncevolution_Session_get_config_async
|
||
|
|
(priv->proxy,
|
||
|
|
(org_syncevolution_Session_get_config_reply) get_config_callback,
|
||
|
|
data);
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
syncevo_session_set_config (SyncevoSession *session,
|
||
|
|
gboolean update,
|
||
|
|
gboolean temporary,
|
||
|
|
SyncevoConfig *config,
|
||
|
|
SyncevoSessionGenericCb callback,
|
||
|
|
gpointer userdata)
|
||
|
|
{
|
||
|
|
SessionAsyncData *data;
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (session);
|
||
|
|
|
||
|
|
data = session_async_data_new (session, G_CALLBACK (callback), userdata);
|
||
|
|
|
||
|
|
if (!priv->proxy) {
|
||
|
|
if (callback) {
|
||
|
|
g_idle_add ((GSourceFunc)generic_error, data);
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
org_syncevolution_Session_set_config_async
|
||
|
|
(priv->proxy,
|
||
|
|
update,
|
||
|
|
temporary,
|
||
|
|
config,
|
||
|
|
(org_syncevolution_Session_set_config_reply) generic_callback,
|
||
|
|
data);
|
||
|
|
}
|
||
|
|
|
||
|
|
static void
|
||
|
|
get_reports_callback (DBusGProxy *proxy,
|
||
|
|
SyncevoReports *reports,
|
||
|
|
GError *error,
|
||
|
|
SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
if (data->callback) {
|
||
|
|
(*(SyncevoSessionGetReportsCb)data->callback) (data->session,
|
||
|
|
reports,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
}
|
||
|
|
session_async_data_free (data);
|
||
|
|
}
|
||
|
|
|
||
|
|
static gboolean
|
||
|
|
get_reports_error (SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
GError *error;
|
||
|
|
|
||
|
|
error = g_error_new_literal (g_quark_from_static_string ("syncevo-session"),
|
||
|
|
SYNCEVO_SESSION_ERROR_NO_DBUS_OBJECT,
|
||
|
|
"The D-Bus object does not exist");
|
||
|
|
(*(SyncevoSessionGetReportsCb)data->callback) (data->session,
|
||
|
|
NULL,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
session_async_data_free (data);
|
||
|
|
|
||
|
|
return FALSE;
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
syncevo_session_get_reports (SyncevoSession *session,
|
||
|
|
guint start,
|
||
|
|
guint count,
|
||
|
|
SyncevoSessionGetReportsCb callback,
|
||
|
|
gpointer userdata)
|
||
|
|
{
|
||
|
|
SessionAsyncData *data;
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (session);
|
||
|
|
|
||
|
|
data = session_async_data_new (session, G_CALLBACK (callback), userdata);
|
||
|
|
|
||
|
|
if (!priv->proxy) {
|
||
|
|
if (callback) {
|
||
|
|
g_idle_add ((GSourceFunc)get_reports_error, data);
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
org_syncevolution_Session_get_reports_async
|
||
|
|
(priv->proxy,
|
||
|
|
start,
|
||
|
|
count,
|
||
|
|
(org_syncevolution_Session_get_reports_reply)get_reports_callback,
|
||
|
|
data);
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
syncevo_session_sync (SyncevoSession *session,
|
||
|
|
SyncevoSyncMode mode,
|
||
|
|
SyncevoSourceModes *source_modes,
|
||
|
|
SyncevoSessionGenericCb callback,
|
||
|
|
gpointer userdata)
|
||
|
|
{
|
||
|
|
SessionAsyncData *data;
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (session);
|
||
|
|
|
||
|
|
data = session_async_data_new (session, G_CALLBACK (callback), userdata);
|
||
|
|
|
||
|
|
if (!priv->proxy) {
|
||
|
|
if (callback) {
|
||
|
|
g_idle_add ((GSourceFunc)generic_error, data);
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
org_syncevolution_Session_sync_async
|
||
|
|
(priv->proxy,
|
||
|
|
syncevo_sync_mode_to_string (mode),
|
||
|
|
source_modes,
|
||
|
|
(org_syncevolution_Session_sync_reply) generic_callback,
|
||
|
|
data);
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
syncevo_session_abort (SyncevoSession *session,
|
||
|
|
SyncevoSessionGenericCb callback,
|
||
|
|
gpointer userdata)
|
||
|
|
{
|
||
|
|
SessionAsyncData *data;
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (session);
|
||
|
|
|
||
|
|
data = session_async_data_new (session, G_CALLBACK (callback), userdata);
|
||
|
|
|
||
|
|
if (!priv->proxy) {
|
||
|
|
if (callback) {
|
||
|
|
g_idle_add ((GSourceFunc)generic_error, data);
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
org_syncevolution_Session_abort_async
|
||
|
|
(priv->proxy,
|
||
|
|
(org_syncevolution_Session_abort_reply) generic_callback,
|
||
|
|
data);
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
syncevo_session_suspend (SyncevoSession *session,
|
||
|
|
SyncevoSessionGenericCb callback,
|
||
|
|
gpointer userdata)
|
||
|
|
{
|
||
|
|
SessionAsyncData *data;
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (session);
|
||
|
|
|
||
|
|
data = session_async_data_new (session, G_CALLBACK (callback), userdata);
|
||
|
|
|
||
|
|
if (!priv->proxy) {
|
||
|
|
if (callback) {
|
||
|
|
g_idle_add ((GSourceFunc)generic_error, data);
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
org_syncevolution_Session_suspend_async
|
||
|
|
(priv->proxy,
|
||
|
|
(org_syncevolution_Session_suspend_reply) generic_callback,
|
||
|
|
data);
|
||
|
|
}
|
||
|
|
|
||
|
|
static void
|
||
|
|
get_status_callback (DBusGProxy *proxy,
|
||
|
|
char *status,
|
||
|
|
guint error_code,
|
||
|
|
SyncevoSourceStatuses *sources,
|
||
|
|
GError *error,
|
||
|
|
SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
if (data->callback) {
|
||
|
|
(*(SyncevoSessionGetStatusCb)data->callback) (data->session,
|
||
|
|
syncevo_session_status_from_string (status),
|
||
|
|
error_code,
|
||
|
|
sources,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
}
|
||
|
|
session_async_data_free (data);
|
||
|
|
}
|
||
|
|
|
||
|
|
static gboolean
|
||
|
|
get_status_error (SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
GError *error;
|
||
|
|
|
||
|
|
error = g_error_new_literal (g_quark_from_static_string ("syncevo-session"),
|
||
|
|
SYNCEVO_SESSION_ERROR_NO_DBUS_OBJECT,
|
||
|
|
"The D-Bus object does not exist");
|
||
|
|
(*(SyncevoSessionGetStatusCb)data->callback) (data->session,
|
||
|
|
SYNCEVO_STATUS_UNKNOWN,
|
||
|
|
0,
|
||
|
|
NULL,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
session_async_data_free (data);
|
||
|
|
|
||
|
|
return FALSE;
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
syncevo_session_get_status (SyncevoSession *session,
|
||
|
|
SyncevoSessionGetStatusCb callback,
|
||
|
|
gpointer userdata)
|
||
|
|
{
|
||
|
|
SessionAsyncData *data;
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (session);
|
||
|
|
|
||
|
|
data = session_async_data_new (session, G_CALLBACK (callback), userdata);
|
||
|
|
|
||
|
|
if (!priv->proxy) {
|
||
|
|
if (callback) {
|
||
|
|
g_idle_add ((GSourceFunc)get_status_error, data);
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
org_syncevolution_Session_get_status_async
|
||
|
|
(priv->proxy,
|
||
|
|
(org_syncevolution_Session_get_status_reply) get_status_callback,
|
||
|
|
data);
|
||
|
|
}
|
||
|
|
static void
|
||
|
|
get_progress_callback (DBusGProxy *proxy,
|
||
|
|
int progress,
|
||
|
|
SyncevoSourceProgresses *source_progresses,
|
||
|
|
GError *error,
|
||
|
|
SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
if (data->callback) {
|
||
|
|
(*(SyncevoSessionGetProgressCb)data->callback) (data->session,
|
||
|
|
progress,
|
||
|
|
source_progresses,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
}
|
||
|
|
session_async_data_free (data);
|
||
|
|
}
|
||
|
|
|
||
|
|
static gboolean
|
||
|
|
get_progress_error (SessionAsyncData *data)
|
||
|
|
{
|
||
|
|
GError *error;
|
||
|
|
|
||
|
|
error = g_error_new_literal (g_quark_from_static_string ("syncevo-session"),
|
||
|
|
SYNCEVO_SESSION_ERROR_NO_DBUS_OBJECT,
|
||
|
|
"The D-Bus object does not exist");
|
||
|
|
(*(SyncevoSessionGetProgressCb)data->callback) (data->session,
|
||
|
|
-1,
|
||
|
|
NULL,
|
||
|
|
error,
|
||
|
|
data->userdata);
|
||
|
|
session_async_data_free (data);
|
||
|
|
|
||
|
|
return FALSE;
|
||
|
|
}
|
||
|
|
|
||
|
|
void
|
||
|
|
syncevo_session_get_progress (SyncevoSession *session,
|
||
|
|
SyncevoSessionGetProgressCb callback,
|
||
|
|
gpointer userdata)
|
||
|
|
{
|
||
|
|
SessionAsyncData *data;
|
||
|
|
SyncevoSessionPrivate *priv;
|
||
|
|
|
||
|
|
priv = GET_PRIVATE (session);
|
||
|
|
|
||
|
|
data = session_async_data_new (session, G_CALLBACK (callback), userdata);
|
||
|
|
|
||
|
|
if (!priv->proxy) {
|
||
|
|
if (callback) {
|
||
|
|
g_idle_add ((GSourceFunc)get_progress_error, data);
|
||
|
|
}
|
||
|
|
return;
|
||
|
|
}
|
||
|
|
|
||
|
|
org_syncevolution_Session_get_progress_async
|
||
|
|
(priv->proxy,
|
||
|
|
(org_syncevolution_Session_get_progress_reply) get_progress_callback,
|
||
|
|
data);
|
||
|
|
}
|