efl/src/lib/efl/interfaces/efl_observer.c

#include "config.h"
#include "Efl.h"

typedef struct
{
   Eina_Hash *observers;
} Efl_Observable_Data;

typedef struct
{
   EINA_REFCOUNT;

   Efl_Observer *o;
} Efl_Observer_Refcount;

EOLIAN static Eo *
_efl_observable_efl_object_constructor(Efl_Object *obj, Efl_Observable_Data *pd)
{
   pd->observers = eina_hash_string_superfast_new((Eina_Free_Cb)eina_hash_free);

   obj = efl_constructor(efl_super(obj, EFL_OBSERVABLE_CLASS));

   return obj;
}

EOLIAN static void
_efl_observable_efl_object_destructor(Eo *obj, Efl_Observable_Data *pd)
{
   eina_hash_free(pd->observers);

   efl_destructor(efl_super(obj, EFL_OBSERVABLE_CLASS));
}

EOLIAN static void
_efl_observable_observer_add(Eo *obj EINA_UNUSED, Efl_Observable_Data *pd, const char *key, Efl_Observer *obs)
{
   Eina_Hash *observers;
   Efl_Observer_Refcount *or;

   if (!key) return;

   observers = eina_hash_find(pd->observers, key);
   if (!observers)
     {
        observers = eina_hash_pointer_new(free);
        eina_hash_add(pd->observers, key, observers);
     }

   or = eina_hash_find(observers, &obs);
   if (!or)
     {
        or = calloc(1, sizeof(Efl_Observer_Refcount));
        or->o = obs;
        EINA_REFCOUNT_INIT(or);

        eina_hash_direct_add(observers, &or->o, or);
     }
   else
     {
        EINA_REFCOUNT_REF(or);
     }
}

EOLIAN static void
_efl_observable_observer_del(Eo *obj EINA_UNUSED, Efl_Observable_Data *pd, const char *key, Efl_Observer *obs)
{
   Eina_Hash *observers;
   Efl_Observer_Refcount *or;

   if (!key) return;

   observers = eina_hash_find(pd->observers, key);
   if (!observers) return;

   or = eina_hash_find(observers, &obs);
   if (!or) return;

   EINA_REFCOUNT_UNREF(or)
     {
        eina_hash_del(observers, &or->o, or);

        if (eina_hash_population(observers) == 0)
          {
             eina_hash_del(pd->observers, key, observers);
          }
     }
}

EOLIAN static void
_efl_observable_observer_clean(Eo *obj EINA_UNUSED, Efl_Observable_Data *pd, Efl_Observer *obs)
{
   Eina_Iterator *it;
   Eina_Hash *observers;

   it = eina_hash_iterator_data_new(pd->observers);
   EINA_ITERATOR_FOREACH(it, observers)
     {
        Efl_Observer_Refcount *or;

        or = eina_hash_find(observers, &obs);
        if (!or) continue;

        EINA_REFCOUNT_UNREF(or)
          {
             eina_hash_del(observers, &obs, or);
          }
     }
   eina_iterator_free(it);
}

typedef struct
{
   Eina_Iterator iterator;
   Eina_Iterator *classes;
} Efl_Observer_Iterator;

static Eina_Bool
_efl_observable_observers_iterator_next(Eina_Iterator *it, void **data)
{
   Efl_Observer_Iterator *et = (void *)it;
   Efl_Observer_Refcount *or = NULL;

   if (!eina_iterator_next(et->classes, (void **)&or)) return EINA_FALSE;
   if (!or) return EINA_FALSE;

   *data = or->o;

   return EINA_TRUE;
}

static void *
_efl_observable_observers_iterator_container(Eina_Iterator *it EINA_UNUSED)
{
   return NULL;
}

static void
_efl_observable_observers_iterator_free(Eina_Iterator *it)
{
   Efl_Observer_Iterator *et = (void *)it;

   eina_iterator_free(et->classes);
   EINA_MAGIC_SET(&et->iterator, 0);
   free(et);
}

EOLIAN static Eina_Iterator *
_efl_observable_observers_iterator_new(Eo *obj EINA_UNUSED, Efl_Observable_Data *pd, const char *key)
{
   Eina_Hash *observers;
   Efl_Observer_Iterator *it;

   observers = eina_hash_find(pd->observers, key);
   if (!observers) return NULL;

   it = calloc(1, sizeof(Efl_Observer_Iterator));
   if (!it) return NULL;

   EINA_MAGIC_SET(&it->iterator, EINA_MAGIC_ITERATOR);
   it->classes = eina_hash_iterator_data_new(observers);

   it->iterator.version = EINA_ITERATOR_VERSION;
   it->iterator.next = _efl_observable_observers_iterator_next;
   it->iterator.get_container = _efl_observable_observers_iterator_container;
   it->iterator.free = _efl_observable_observers_iterator_free;

   return &it->iterator;
}

EOLIAN static void
_efl_observable_observers_update(Eo *obj, Efl_Observable_Data *pd EINA_UNUSED, const char *key, void *data)
{
   Eina_Iterator *it;
   Efl_Observer *o;

   it = efl_observable_observers_iterator_new(obj, key);
   if (!it) return;

   EINA_ITERATOR_FOREACH(it, o)
     {
        efl_observer_update(o, obj, key, data);
     }

   eina_iterator_free(it);
}

typedef struct
{
   Eina_Iterator iterator;
   Eina_Iterator *classes;
   Efl_Observable *obs;
   Eina_List *tuples;
} Efl_Observable_Iterator;

static Eina_Bool
_efl_observable_iterator_tuple_next(Eina_Iterator *it, void **data)
{
   Efl_Observable_Iterator *et = (void *)it;
   Efl_Observable_Tuple *tuple;
   const char *key;

   if (!eina_iterator_next(et->classes, (void **)&key)) return EINA_FALSE;
   if (!key) return EINA_FALSE;

   tuple = calloc(1, sizeof(Efl_Observable_Tuple));
   if (!tuple) return EINA_FALSE;

   tuple->key = key;
   tuple->data = efl_observable_observers_iterator_new(et->obs, key);

   et->tuples = eina_list_append(et->tuples, tuple);
   *data = tuple;

   return EINA_TRUE;
}

static void *
_efl_observable_iterator_tuple_container(Eina_Iterator *it EINA_UNUSED)
{
   return NULL;
}

static void
_efl_observable_iterator_tuple_free(Eina_Iterator *it)
{
   Efl_Observable_Iterator *et = (void *)it;
   Efl_Observable_Tuple *tuple;

   eina_iterator_free(et->classes);
   EINA_LIST_FREE(et->tuples, tuple)
     {
        if (tuple->data)
          eina_iterator_free(tuple->data);
        free(tuple);
     }
   EINA_MAGIC_SET(&et->iterator, 0);
   free(et);
}

EOLIAN static Eina_Iterator *
_efl_observable_iterator_tuple_new(Eo *obj, Efl_Observable_Data *pd)
{
   Efl_Observable_Iterator *it;

   it = calloc(1, sizeof(Efl_Observable_Iterator));
   if (!it) return NULL;

   EINA_MAGIC_SET(&it->iterator, EINA_MAGIC_ITERATOR);
   it->classes = eina_hash_iterator_key_new(pd->observers);
   it->obs = obj;

   it->iterator.version = EINA_ITERATOR_VERSION;
   it->iterator.next = _efl_observable_iterator_tuple_next;
   it->iterator.get_container = _efl_observable_iterator_tuple_container;
   it->iterator.free = _efl_observable_iterator_tuple_free;

   return &it->iterator;
}

#include "interfaces/efl_observable.eo.c"
#include "interfaces/efl_observer.eo.c"