Changeset 0e4270e1bce5187de37334ee01883a30ed677ab3

Timestamp:

09/03/11 03:10:51 (21 months ago)

Author:

Nedko Arnaudov <nedko@…>

Children:

eccd9d26adc9eb13bed129595ad9253e4566ff5c

Parents:

e2b94615472d554203a776407f02d793eafa42f0

git-committer:

Nedko Arnaudov <nedko@arnaudov.name> / 2011-09-03T03:10:51Z+0300

Message:

cdbus: new function - cdbus_call_async()

Location:

dbus

Files:

• helpers.c (modified) (1 diff)
• helpers.h (modified) (1 diff)

dbus/helpers.c

@@ -564 +564 @@
 }
 
+struct cdbus_async_call_context
+{
+  void * context;
+  void (* callback)(void * context, void * cookie, DBusMessage * reply_ptr);
+  dbus_uint64_t cookie[0];
+};
+
+#define ctx_ptr ((struct cdbus_async_call_context *)user_data)
+
+static void cdbus_async_call_reply_handler(DBusPendingCall * pending_call_ptr, void * user_data)
+{
+        DBusMessage * reply_ptr;
+
+  reply_ptr = dbus_pending_call_steal_reply(pending_call_ptr);
+  if (reply_ptr == NULL)
+  {
+    log_error("pending call notify called but reply is NULL");
+  }
+  else
+  {
+    ctx_ptr->callback(ctx_ptr->context, ctx_ptr->cookie, reply_ptr);
+    ctx_ptr->callback = NULL;   /* mark that callback is already called */
+
+    dbus_message_unref(reply_ptr);
+  }
+}
+
+static void cdbus_async_call_reply_context_free(void * user_data)
+{
+  if (ctx_ptr->callback != NULL)
+  {
+    ctx_ptr->callback(ctx_ptr->context, ctx_ptr->cookie, NULL);
+  }
+
+  free(ctx_ptr);
+}
+
+#undef ctx_ptr
+
+bool
+cdbus_call_async(
+  DBusMessage * request_ptr,
+  void * context,
+  void * cookie,
+  size_t cookie_size,
+  void (* callback)(void * context, void * cookie, DBusMessage * reply_ptr))
+{
+  bool ret;
+  DBusPendingCall * pending_call_ptr;
+  struct cdbus_async_call_context * ctx_ptr;
+
+  ret = false;
+
+  if (!dbus_connection_send_with_reply(cdbus_g_dbus_connection, request_ptr, &pending_call_ptr, DBUS_TIMEOUT_INFINITE))
+  {
+    log_error("dbus_connection_send_with_reply() failed.");
+    goto exit;
+  }
+
+  if (pending_call_ptr == NULL)
+  {
+    log_error("dbus_connection_send_with_reply() returned NULL pending call object pointer.");
+    goto exit;
+  }
+
+  ctx_ptr = malloc(sizeof(struct cdbus_async_call_context) + cookie_size);
+  if (ctx_ptr == NULL)
+  {
+    log_error("malloc() failed to allocate cdbus_async_call_context struct with cookie size of %zu", cookie_size);
+    goto unref;
+  }
+
+  ctx_ptr->context = context;
+  ctx_ptr->callback = callback;
+  memcpy(ctx_ptr->cookie, cookie, cookie_size);
+
+  ret = dbus_pending_call_set_notify(pending_call_ptr, cdbus_async_call_reply_handler, ctx_ptr, cdbus_async_call_reply_context_free);
+  if (!ret)
+  {
+    log_error("dbus_pending_call_set_notify() failed.");
+    goto free;
+  }
+
+  goto unref;
+
+free:
+  free(ctx_ptr);
+unref:
+  dbus_pending_call_unref(pending_call_ptr);
+exit:
+  return ret;
+}
+
 static
 const char *

dbus/helpers.h

@@ -58 +58 @@
   const char * input_signature,
   ...);
+
+bool
+cdbus_call_async(
+  DBusMessage * request_ptr,
+  void * context,
+  void * cookie,
+  size_t cookie_size,
+  void (* callback)(void * context, void * cookie, DBusMessage * reply_ptr));
 
 DBusMessage *