dnotifier.c

Go to the documentation of this file.

#include <cfg/debug.h>

#include <dt/dtag.h>
#include <dt/dnotifier.h>
#include <struct/list.h>

static void notifier_update(DNotifier *n, dtag_t tag, dval_t val)
{
    dnotify_targets(n, tag, val);
}

void notifier_init(DNotifier *n)
{
    // Init instance
    n->update = notifier_update;
    LIST_INIT(&n->targets);
}

void filter_update(DFilter *f, dtag_t tag, dval_t val)
{

    const DFilterMap *map = f->map;

    if (map)
    {
        while (map->src.tag != TAG_END)
        {
            if ((map->src.tag == tag) && (map->src.val == val))
            {
                tag = map->dst.tag;
                val = map->dst.val;
                break;
            }
            /* TAG_ANY matches anything */
            if (map->src.tag == TAG_ANY)
                break;
            map++;
        }

        if (map->src.tag != TAG_END)
            dnotify(f->target, tag, val);
    }
    else
        dnotify(f->target, tag, val);
}


void filter_mask_update(DFilter *f, dtag_t tag, dval_t val)
{

    const DFilterMap *map = f->map;
    dfilter_mask_t mask;

    if (map)
    {
        while (map->src.tag != TAG_END)
        {
            mask = (dfilter_mask_t) map->src.val;
            if ((map->src.tag == tag) && ((mask & (dfilter_mask_t)val) == mask))
            {
                tag = map->dst.tag;
                val = map->dst.val;
                break;
            }
            /* TAG_ANY matches anything */
            if (map->src.tag == TAG_ANY)
                break;
            map++;
        }


        if (map->src.tag != TAG_END)
            dnotify(f->target, tag, val);
    }
    else
        dnotify(f->target, tag, val);
}


#define FILTER_MAGIC_ACTIVE 0xAA

void filter_init(DFilter *f, const DFilterMap *map, bool masked, DNotifier *source, DNotifier *target)
{
    // Init instance
    if (masked)
        f->update = (update_filter_ptr)filter_mask_update;
    else
        f->update = (update_filter_ptr)filter_update;

    /* set filter map and target */
    f->map = map;
    f->target = target;

    /* these ensure that the filter is not inserted in more than one list */
    ASSERT(f->magic != FILTER_MAGIC_ACTIVE);
    DB(f->magic = FILTER_MAGIC_ACTIVE;)

    /* Add the filter to source filter list */
    ADDTAIL(&source->targets, &f->link);
}