[tracker/gdbus-porting-rebased: 46/65] libtracker-common: Fix tracker_dbus_send_and_splice_async() so GSimpleAsyncResult has a source_tag
- From: Philip Van Hoof <pvanhoof src gnome org>
- To: commits-list gnome org
- Cc:
- Subject: [tracker/gdbus-porting-rebased: 46/65] libtracker-common: Fix tracker_dbus_send_and_splice_async() so GSimpleAsyncResult has a source_tag
- Date: Wed, 12 Jan 2011 11:19:39 +0000 (UTC)
commit 26592bb8e9fec212a1d2955e1aecce98dbbb23d8
Author: Martyn Russell <martyn lanedo com>
Date: Wed Jan 5 16:27:38 2011 +0000
libtracker-common: Fix tracker_dbus_send_and_splice_async() so GSimpleAsyncResult has a source_tag
src/libtracker-common/tracker-dbus.c | 22 +++++++++++++---------
1 files changed, 13 insertions(+), 9 deletions(-)
---
diff --git a/src/libtracker-common/tracker-dbus.c b/src/libtracker-common/tracker-dbus.c
index 479a097..6ee35f2 100644
--- a/src/libtracker-common/tracker-dbus.c
+++ b/src/libtracker-common/tracker-dbus.c
@@ -592,6 +592,7 @@ tracker_dbus_send_and_splice_async (GDBusConnection *connection
GInputStream *unix_input_stream;
GInputStream *buffered_input_stream;
GOutputStream *output_stream;
+ GSimpleAsyncResult *result;
g_return_val_if_fail (connection != NULL, FALSE);
g_return_val_if_fail (message != NULL, FALSE);
@@ -603,12 +604,10 @@ tracker_dbus_send_and_splice_async (GDBusConnection *connection
TRACKER_DBUS_PIPE_BUFFER_SIZE);
output_stream = g_memory_output_stream_new (NULL, 0, g_realloc, NULL);
- data = send_and_splice_data_new (unix_input_stream,
- buffered_input_stream,
- output_stream,
- cancellable,
- callback,
- user_data);
+ result = g_simple_async_result_new (G_OBJECT (connection),
+ tracker_dbus_send_and_splice_async_finish,
+ user_data,
+ g_dbus_connection_send_message_with_reply);
g_dbus_connection_send_message_with_reply (connection,
message,
@@ -617,9 +616,14 @@ tracker_dbus_send_and_splice_async (GDBusConnection *connection
NULL,
cancellable,
tracker_g_async_ready_callback,
- g_simple_async_result_new (G_OBJECT (connection),
- tracker_dbus_send_and_splice_async_finish,
- user_data, NULL));
+ result);
+
+ data = send_and_splice_data_new (unix_input_stream,
+ buffered_input_stream,
+ output_stream,
+ cancellable,
+ callback,
+ user_data);
g_output_stream_splice_async (data->output_stream,
data->buffered_input_stream,
[
Date Prev][
Date Next] [
Thread Prev][
Thread Next]
[
Thread Index]
[
Date Index]
[
Author Index]