[tracker/dbus-fd-experiment: 20/20] libtracker-client: Avoid duplicate code for D-Bus calls

[Jürg Billeter <juergbi src gnome org>]

commit 29cd72769ee723d6b7d03501343253cb29f66d92
Author: Jürg Billeter <j bitron ch>
Date:   Tue Jun 15 15:07:48 2010 +0200

    libtracker-client: Avoid duplicate code for D-Bus calls

 src/libtracker-client/tracker.c |  117 +++++++-------------------------------
 1 files changed, 22 insertions(+), 95 deletions(-)
---
diff --git a/src/libtracker-client/tracker.c b/src/libtracker-client/tracker.c
index 261764b..a2376b1 100644
--- a/src/libtracker-client/tracker.c
+++ b/src/libtracker-client/tracker.c
@@ -959,17 +959,16 @@ sparql_update_fast_callback (DBusPendingCall *call,
 }
 
 static DBusMessage*
-sparql_update_fast (TrackerClient      *client,
-                    const gchar        *query,
-                    FastOperationType   type,
-                    GError            **error)
+sparql_update_fast_send (TrackerClient      *client,
+                         const gchar        *query,
+                         FastOperationType   type,
+                         GError            **error)
 {
 	TrackerClientPrivate *private;
 	DBusConnection *connection;
 	gchar *dbus_method;
 	DBusMessage *message;
 	DBusMessageIter iter;
-	DBusMessage *reply;
 	DBusPendingCall *call;
 	DBusError dbus_error;
 	int pipefd[2];
@@ -1063,6 +1062,22 @@ sparql_update_fast (TrackerClient      *client,
 	g_object_unref (buffered_output_stream);
 	g_object_unref (output_stream);
 
+	return call;
+}
+
+static DBusMessage*
+sparql_update_fast (TrackerClient      *client,
+                    const gchar        *query,
+                    FastOperationType   type,
+                    GError            **error)
+{
+	DBusMessage *call, *reply;
+
+	call = sparql_update_fast_send (client, query, type, error);
+	if (!call) {
+		return NULL;
+	}
+
 	dbus_pending_call_block (call);
 
 	reply = dbus_pending_call_steal_reply (call);
@@ -1086,101 +1101,13 @@ sparql_update_fast_async (TrackerClient      *client,
                           FastAsyncData      *data,
                           GError            **error)
 {
-	TrackerClientPrivate *private;
-	DBusConnection *connection;
-	gchar *dbus_method;
-	DBusMessage *message;
-	DBusMessageIter iter;
-	DBusPendingCall *call;
-	DBusError dbus_error;
-	int pipefd[2];
-	GOutputStream *output_stream;
-	GOutputStream *buffered_output_stream;
-	GDataOutputStream *data_output_stream;
-	GError *inner_error = NULL;
-
-	private = TRACKER_CLIENT_GET_PRIVATE (client);
-
-	if (pipe (pipefd) < 0) {
-		g_set_error (error,
-		             TRACKER_CLIENT_ERROR,
-		             TRACKER_CLIENT_ERROR_UNSUPPORTED,
-		             "Cannot open pipe");
-		return;
-	}
-
-	connection = dbus_g_connection_get_connection (private->connection);
-
-	dbus_error_init (&dbus_error);
-
-	switch (data->operation) {
-		case FAST_UPDATE:
-			dbus_method = "Update";
-			break;
-		case FAST_UPDATE_BLANK:
-			dbus_method = "UpdateBlank";
-			break;
-		case FAST_UPDATE_BATCH:
-			dbus_method = "BatchUpdate";
-			break;
-		default:
-			g_assert_not_reached ();
-	}
-
-	message = dbus_message_new_method_call (TRACKER_STEROIDS_SERVICE,
-	                                        TRACKER_STEROIDS_PATH,
-	                                        TRACKER_STEROIDS_INTERFACE,
-	                                        dbus_method);
-	dbus_message_iter_init_append (message, &iter);
-	dbus_message_iter_append_basic (&iter, DBUS_TYPE_UNIX_FD, &pipefd[0]);
-	dbus_connection_send_with_reply (connection,
-	                                 message,
-	                                 &call,
-	                                 -1);
-	dbus_message_unref (message);
-	close (pipefd[0]);
+	DBusMessage *call;
 
+	call = sparql_update_fast_send (client, dat->query, data->type, error);
 	if (!call) {
-		g_set_error (error,
-		             TRACKER_CLIENT_ERROR,
-		             TRACKER_CLIENT_ERROR_UNSUPPORTED,
-		             "FD passing unsupported or connection disconnected");
 		return;
 	}
 
-	output_stream = g_unix_output_stream_new (pipefd[1], TRUE);
-	buffered_output_stream = g_buffered_output_stream_new_sized (output_stream,
-	                                                             TRACKER_STEROIDS_BUFFER_SIZE);
-	data_output_stream = g_data_output_stream_new (buffered_output_stream);
-
-	g_data_output_stream_put_int32 (data_output_stream,
-	                                strlen (data->query),
-	                                NULL,
-	                                &inner_error);
-
-	if (inner_error) {
-		g_propagate_error (error, inner_error);
-		g_object_unref (data_output_stream);
-		g_object_unref (output_stream);
-		return;
-	}
-
-	g_data_output_stream_put_string (data_output_stream,
-	                                 data->query,
-	                                 NULL,
-	                                 &inner_error);
-
-	if (inner_error) {
-		g_propagate_error (error, inner_error);
-		g_object_unref (data_output_stream);
-		g_object_unref (output_stream);
-		return;
-	}
-
-	g_object_unref (data_output_stream);
-	g_object_unref (buffered_output_stream);
-	g_object_unref (output_stream);
-
 	dbus_pending_call_set_notify (call, sparql_update_fast_callback, data, NULL);
 }