Added checking the result of g_kdbus_send_message() function.

diff --git a/gio/gdbusprivate.c b/gio/gdbusprivate.c
index 1c11c9b..14d05bc 100644 (file)
--- a/gio/gdbusprivate.c
+++ b/gio/gdbusprivate.c
@@ -995,8 +995,14 @@ write_message_continue_writing (MessageToWriteData *data)
     {
       GError *error;
 
-      g_print("TEST KDBUS!\n");
-      g_kdbus_send_message(data->worker->kdbus, data->message, data->blob, data->blob_size, error);
+      data->total_written = g_kdbus_send_message(data->worker->kdbus, data->message, data->blob, data->blob_size, error);
+      
+      if (data->total_written == data->blob_size)
+        {
+          g_simple_async_result_complete (simple);
+          g_object_unref (simple);
+          goto out;
+        }
     }
   else
     {

diff --git a/gio/gkdbus.c b/gio/gkdbus.c
index 1262976..77e35c9 100644 (file)
--- a/gio/gkdbus.c
+++ b/gio/gkdbus.c
@@ -214,9 +214,9 @@ g_kdbus_open (GKdbus         *kdbus,
              GError         **error)
 {
   g_return_val_if_fail (G_IS_KDBUS (kdbus), FALSE);
-
+  g_print ("ADDRESS: %s\n",address);
   kdbus->priv->fd = open(address, O_RDWR|O_CLOEXEC|O_NONBLOCK);
-
+  g_print ("FD: %d\n",kdbus->priv->fd);
   return TRUE;
 }
 
@@ -279,7 +279,7 @@ gboolean g_kdbus_register(GKdbus           *kdbus)
 
        if (ioctl(kdbus->priv->fd, KDBUS_CMD_HELLO, &hello))
        {
-               g_print("Failed to send hello: %m, %d",errno);
+               g_print("FD: %d Failed to send hello: %m, %d",kdbus->priv->fd,errno);
                return FALSE;
        }