1 files changed, 192 insertions, 0 deletions

diff --git a/src/lib/common/gnunet_dbus_lib_object.c b/src/lib/common/gnunet_dbus_lib_object.c
new file mode 100644
index 0000000..816f587
--- /dev/null
+++ b/src/lib/common/gnunet_dbus_lib_object.c
@@ -0,0 +1,192 @@
+#include "config.h"
+
+#include <inttypes.h>
+
+#include <gnunet/platform.h>
+#include <gnunet/gnunet_common.h>
+#include <gnunet/gnunet_container_lib.h>
+
+#include "gnunet_dbus_lib.h"
+
+#define LOG(kind, ...) GNUNET_log_from (kind, "dbus-object", __VA_ARGS__)
+
+struct GNUNET_DBUS_Object
+{
+  struct GNUNET_DBUS_InterfaceIterator *interfaces_front;
+  struct GNUNET_DBUS_InterfaceIterator *interfaces_back;
+
+  struct GNUNET_DBUS_ObjectIterator *subobjects_front;
+  struct GNUNET_DBUS_ObjectIterator *subobjects_back;
+
+  char *name;
+  void *data;
+  unsigned ref_count;
+};
+
+struct GNUNET_DBUS_Object *
+GNUNET_DBUS_object_create (
+    const char *name,
+    void *data)
+{
+  struct GNUNET_DBUS_Object *object = GNUNET_new (struct GNUNET_DBUS_Object);
+  object->name = GNUNET_strdup (name);
+  object->data = data;
+  object->interfaces_front = NULL;
+  object->interfaces_back = NULL;
+  object->subobjects_front = NULL;
+  object->subobjects_back = NULL;
+  object->ref_count = 1;
+  
+  return object;
+};
+
+void
+GNUNET_DBUS_object_ref (
+    struct GNUNET_DBUS_Object *object)
+{
+  object->ref_count++;
+};
+
+void
+GNUNET_DBUS_object_unref (
+    struct GNUNET_DBUS_Object *object)
+{
+  if (object->ref_count == 0)
+  {
+    LOG (GNUNET_ERROR_TYPE_ERROR, "Tried to unreference object with ref count 0\n");
+    GNUNET_abort_ ();
+  };
+  if (0 == --(object->ref_count))
+  {
+    struct GNUNET_DBUS_InterfaceIterator *int_it = object->interfaces_front;
+    while (int_it)
+    {
+      struct GNUNET_DBUS_InterfaceIterator *next = int_it->next;
+      GNUNET_DBUS_interface_unref (int_it->interface);
+      GNUNET_free (int_it);
+      int_it = next;
+    };
+
+    struct GNUNET_DBUS_ObjectIterator *obj_it = object->subobjects_front;
+    while (obj_it)
+    {
+      struct GNUNET_DBUS_ObjectIterator *next = obj_it->next;
+      GNUNET_DBUS_object_unref (obj_it->object);
+      GNUNET_free (obj_it);
+      obj_it = next;
+    };
+
+    GNUNET_free (object->name);
+    GNUNET_free (object);
+  }
+};
+
+const char *
+GNUNET_DBUS_object_get_name (
+    const struct GNUNET_DBUS_Object *object)
+{
+  return object->name;
+};
+
+void
+GNUNET_DBUS_object_add_interface (
+    struct GNUNET_DBUS_Object *object,
+    struct GNUNET_DBUS_Interface *interface)
+{
+  struct GNUNET_DBUS_InterfaceIterator *int_it = GNUNET_new (struct GNUNET_DBUS_InterfaceIterator);
+  int_it->interface = interface;
+  GNUNET_DBUS_interface_ref (interface);
+
+  GNUNET_CONTAINER_DLL_insert (object->interfaces_front,
+                               object->interfaces_back,
+                               int_it);
+};
+
+const struct GNUNET_DBUS_InterfaceIterator *
+GNUNET_DBUS_object_iterate_interfaces (
+    struct GNUNET_DBUS_Object *object)
+{
+  return object->interfaces_front;
+};
+
+void *
+GNUNET_DBUS_object_get_data (
+    struct GNUNET_DBUS_Object *object)
+{
+  return object->data;
+};
+
+struct GNUNET_DBUS_Object *
+GNUNET_DBUS_object_create_uniquely_named_subobject (
+    struct GNUNET_DBUS_Object *object,
+    void *data)
+{
+  while(true)
+  {
+    char name[9];
+    uint32_t id = GNUNET_CRYPTO_random_u32 (GNUNET_CRYPTO_QUALITY_WEAK, 0xffffffff);
+    GNUNET_snprintf (name, sizeof(name), "%08" PRIx32, id);
+    const struct GNUNET_DBUS_ObjectIterator *obj_it = GNUNET_DBUS_object_iterate_subobjects (object);
+    while (true)
+    {
+      if (! obj_it)
+      {
+        struct GNUNET_DBUS_Object *subobject = GNUNET_DBUS_object_create (name, data);
+        GNUNET_DBUS_object_add_subobject (object, subobject);
+        return subobject;
+      }
+
+      const struct GNUNET_DBUS_Object *test_object = obj_it->object;
+      if (0 == strcmp (name, GNUNET_DBUS_object_get_name (test_object)))
+        break;
+
+      obj_it = obj_it->next;
+    }
+  }
+}
+
+void
+GNUNET_DBUS_object_add_subobject (
+    struct GNUNET_DBUS_Object *object,
+    struct GNUNET_DBUS_Object *subobject)
+{
+  struct GNUNET_DBUS_ObjectIterator *obj_it = GNUNET_new (struct GNUNET_DBUS_ObjectIterator);
+  obj_it->object = subobject;
+  GNUNET_DBUS_object_ref (subobject);
+
+  GNUNET_CONTAINER_DLL_insert (object->subobjects_front,
+                               object->subobjects_back,
+                               obj_it);
+};
+
+void
+GNUNET_DBUS_object_remove_subobject (
+    struct GNUNET_DBUS_Object *object,
+    struct GNUNET_DBUS_ObjectIterator *subobject_it)
+{
+  GNUNET_DBUS_object_unref (subobject_it->object);
+  GNUNET_CONTAINER_DLL_remove (object->subobjects_front,
+                               object->subobjects_back,
+                               subobject_it);
+  GNUNET_free (subobject_it);
+};
+
+struct GNUNET_DBUS_ObjectIterator *
+GNUNET_DBUS_object_iterate_subobjects (
+    const struct GNUNET_DBUS_Object *object)
+{
+  return object->subobjects_front;
+}
+
+const struct GNUNET_DBUS_ObjectIterator *
+GNUNET_DBUS_object_find (
+    const struct GNUNET_DBUS_ObjectIterator *object_it,
+    const char *name)
+{
+  while (object_it && strcmp (name, object_it->object->name))
+    object_it = object_it->next;
+
+  return object_it;
+}
+
+