2009-02-19 Mark Doffman <mark.doffman@codethink.co.uk>
[platform/core/uifw/at-spi2-atk.git] / atk-adaptor / accessible-register.c
index af9f752..494763b 100644 (file)
@@ -77,7 +77,7 @@
 
 static GHashTable *ref2ptr = NULL; /* Used for converting a D-Bus path (Reference) to the object pointer */
 
-static guint counter = 1;
+static guint reference_counter = 0;
 
 static GStaticRecMutex registration_mutex = G_STATIC_REC_MUTEX_INIT;
 
@@ -116,10 +116,11 @@ recursion_check_unset ()
 static guint
 assign_reference(void)
 {
-  counter++;
+  reference_counter++;
   /* Reference of 0 not allowed as used as direct key in hash table */
-  if (counter == 0)
-    counter++;
+  if (reference_counter == 0)
+    reference_counter++;
+  return reference_counter;
 }
 
 /*
@@ -152,7 +153,7 @@ static void
 deregister_accessible (gpointer data, GObject *accessible)
 {
   guint ref;
-  g_assert (ATK_IS_OBJECT (accessible));
+  g_return_if_fail (ATK_IS_OBJECT (accessible));
 
   ref = object_to_ref (ATK_OBJECT(accessible));
   if (ref != 0)
@@ -168,7 +169,7 @@ static void
 register_accessible (AtkObject *accessible)
 {
   guint ref;
-  g_assert(ATK_IS_OBJECT(accessible));
+  g_return_if_fail (ATK_IS_OBJECT(accessible));
 
   ref = assign_reference();
 
@@ -230,6 +231,29 @@ has_manages_descendants (AtkObject *accessible)
    return result;
 }
 
+static void
+append_children (AtkObject *accessible, GQueue *traversal)
+{
+  AtkObject *current;
+  guint i;
+
+  for (i =0; i < atk_object_get_n_accessible_children (accessible); i++)
+    {
+      current = atk_object_ref_accessible_child (accessible, i);
+#ifdef SPI_ATK_DEBUG
+      non_owned_accessible (current);
+#endif
+      if (!has_manages_descendants (current))
+        {
+          g_queue_push_tail (traversal, current);
+        }
+      else
+        {
+          g_object_unref (G_OBJECT (current));
+        }
+    }
+}
+
 /*
  * Registers a subtree of accessible objects
  * rooted at the accessible object provided.
@@ -242,88 +266,43 @@ has_manages_descendants (AtkObject *accessible)
 void
 register_subtree (AtkObject *accessible)
 {
-  AtkObject *current, *tmp;
-  GQueue    *stack;
-  guint      i;
-  gboolean   recurse;
-
+  AtkObject *current;
+  GQueue    *traversal;
+  GQueue    *emit_update;
 
-  current = g_object_ref (accessible);
-  if (has_manages_descendants (current))
-    {
-      g_object_unref (current);
-      return;
-    }
+  g_return_if_fail (ATK_IS_OBJECT (accessible));
 
-  stack = g_queue_new ();
+  traversal = g_queue_new ();
+  emit_update = g_queue_new ();
 
-  register_accessible (current);
-  g_queue_push_head (stack, GINT_TO_POINTER (0));
+  g_object_ref (accessible);
+  g_queue_push_tail (traversal, accessible);
 
-  /*
-   * The index held on the stack is the next child node
-   * that needs processing at the corresponding level in the tree.
-   */
-  while (!g_queue_is_empty (stack))
+  while (!g_queue_is_empty (traversal))
     {
-      /* Find the next child node that needs processing */
-
-      i = GPOINTER_TO_INT(g_queue_peek_head (stack));
-      recurse = FALSE;
-
-      while (i < atk_object_get_n_accessible_children (current) &&
-             recurse == FALSE)
+      current = g_queue_pop_head (traversal);
+      g_queue_push_tail (emit_update, current);
+      if (!object_to_ref (current))
         {
-          tmp = atk_object_ref_accessible_child (current, i);
-
+          register_accessible (current);
 #ifdef SPI_ATK_DEBUG
-          non_owned_accessible (tmp);
+          g_debug ("REG  - %s - %d - %s", atk_object_get_name     (current),
+                                          atk_object_get_role     (current),
+                                          atk_dbus_object_to_path (current));
 #endif
-
-          if (object_to_ref (tmp))
-            {
-              /* If its already registered, just update */
-              spi_emit_cache_update (tmp, atk_adaptor_app_data->bus);
-            }
-          else if (has_manages_descendants (tmp))
-            {
-              /* If it has manages descendants, just register and update */
-              register_accessible (tmp);
-              spi_emit_cache_update (tmp, atk_adaptor_app_data->bus);
-            }
-          else
-            {
-              recurse = TRUE;
-            }
-
-          if (!recurse)
-            {
-              g_object_unref (G_OBJECT (tmp));
-            }
-
-          i++;
+          append_children (current, traversal);
         }
+    }
 
-      if (recurse)
-        {
-          /* Push onto stack */
-          current = tmp;
-          register_accessible (current);
-
-          g_queue_peek_head_link (stack)->data = GINT_TO_POINTER (i);
-          g_queue_push_head (stack, GINT_TO_POINTER (0));
-        }
-      else
-        {
-          /* Pop from stack */
-          spi_emit_cache_update (current, atk_adaptor_app_data->bus);
-          tmp = current;
-          current = atk_object_get_parent (current);
-          g_object_unref (G_OBJECT (tmp));
-          g_queue_pop_head (stack);
-        }
+  while (!g_queue_is_empty (emit_update))
+    {
+      current = g_queue_pop_head (emit_update);
+      spi_emit_cache_update (current, atk_adaptor_app_data->bus);
+      g_object_unref (G_OBJECT (current));
     }
-    g_queue_free (stack);
+
+  g_queue_free (traversal);
+  g_queue_free (emit_update);
 }
 
 /*---------------------------------------------------------------------------*/
@@ -336,7 +315,7 @@ static void
 update_accessible (AtkObject *accessible)
 {
   guint  ref = 0;
-  g_assert(ATK_IS_OBJECT(accessible));
+  g_return_if_fail (ATK_IS_OBJECT(accessible));
 
   ref = object_to_ref (accessible);
   if (ref)
@@ -362,7 +341,7 @@ atk_dbus_path_to_object (const char *path)
   guint index;
   void *data;
 
-  g_assert (path);
+  g_return_val_if_fail (path, NULL);
 
   if (strncmp(path, SPI_ATK_OBJECT_PATH_PREFIX, SPI_ATK_PATH_PREFIX_LENGTH) != 0)
     return NULL;
@@ -431,15 +410,18 @@ tree_update_listener (GSignalInvocationHint *signal_hint,
    * have their signals processed.
    */
   accessible = g_value_get_object (&param_values[0]);
-  g_assert (ATK_IS_OBJECT (accessible));
+  g_return_val_if_fail (ATK_IS_OBJECT (accessible), TRUE);
 
   if (object_to_ref (accessible))
     {
 #ifdef SPI_ATK_DEBUG
       if (recursion_check_and_set ())
           g_warning ("AT-SPI: Recursive use of registration module");
+
+      g_debug ("AT-SPI: Tree update listener");
 #endif
 
+
       values = (AtkPropertyValues*) g_value_get_pointer (&param_values[1]);
       pname = values[0].property_name;
       if (strcmp (pname, "accessible-name") == 0 ||
@@ -479,13 +461,15 @@ tree_update_children_listener (GSignalInvocationHint *signal_hint,
    * have their signals processed.
    */
   accessible = g_value_get_object (&param_values[0]);
-  g_assert (ATK_IS_OBJECT (accessible));
+  g_return_val_if_fail (ATK_IS_OBJECT (accessible), TRUE);
 
   if (object_to_ref (accessible))
     {
 #ifdef SPI_ATK_DEBUG
       if (recursion_check_and_set ())
           g_warning ("AT-SPI: Recursive use of registration module");
+
+      g_debug ("AT-SPI: Tree update children listener");
 #endif
 
       if (signal_hint->detail)
@@ -530,6 +514,8 @@ atk_dbus_initialize (AtkObject *root)
 #ifdef SPI_ATK_DEBUG
   if (g_thread_supported ())
       g_message ("AT-SPI: Threads enabled");
+
+  g_debug ("AT-SPI: Initial Atk tree regisration");
 #endif
 
   register_subtree (root);