}
/* can only be called from private thread with read-lock held - takes ownership of @message */
-static void
+void
_g_dbus_worker_queue_or_deliver_received_message (GDBusWorker *worker,
GDBusMessage *message)
{
{
GError *error;
error = NULL;
- data->total_written = g_kdbus_send_message(data->worker->kdbus, data->message, data->blob, data->blob_size, &error);
+ data->total_written = g_kdbus_send_message(data->worker, data->worker->kdbus, data->message, data->blob, data->blob_size, &error);
if (data->total_written == data->blob_size)
{
void _g_dbus_worker_close (GDBusWorker *worker,
GCancellable *cancellable,
GSimpleAsyncResult *result);
-
+/* Samsung change */
+void _g_dbus_worker_queue_or_deliver_received_message (GDBusWorker *worker,
+ GDBusMessage *message);
/* ---------------------------------------------------------------------------------------------------- */
void _g_dbus_initialize (void);
}
static gboolean
-g_kdbus_send_reply(GKdbus *kdbus, GDBusMessage *dbus_msg)
+g_kdbus_send_reply(GDBusWorker *worker,
+ GKdbus *kdbus,
+ GDBusMessage *dbus_msg)
{
GDBusMessage *reply = NULL;
char *unique_name = NULL;
g_dbus_message_set_body(reply, g_variant_new ("(s)", unique_name));
- //_g_dbus_worker_queue_or_deliver_received_message (worker, message);
+ _g_dbus_worker_queue_or_deliver_received_message (worker, reply);
}
* @kdbus: a #GKdbus
*/
gssize
-g_kdbus_send_message (GKdbus *kdbus,
+g_kdbus_send_message (GDBusWorker *worker,
+ GKdbus *kdbus,
GDBusMessage *dbus_msg,
gchar *blob,
gsize blob_size,
return -1;
}
- g_kdbus_send_reply(kdbus, dbus_msg);
+ g_kdbus_send_reply(worker, kdbus, dbus_msg);
#endif
#include <gio/giotypes.h>
+#include "gdbusprivate.h"
G_BEGIN_DECLS
void *data,
GError **error);
GLIB_AVAILABLE_IN_ALL
-gssize g_kdbus_send_message (GKdbus *kdbus,
+gssize g_kdbus_send_message (GDBusWorker *worker,
+ GKdbus *kdbus,
GDBusMessage *dbus_msg,
gchar *blob,
gsize blob_size,