amxp_slot.c File Reference

#include <stdlib.h>
#include <string.h>
#include <amxc/amxc.h>
#include <amxp/amxp_expression.h>
#include <amxp_signal_priv.h>

Go to the source code of this file.

Macros
#define	_GNU_SOURCE

Functions
static amxp_slot_t *	amxp_slot_find (const amxp_signal_t *const sig, amxp_slot_fn_t fn, amxp_slot_t *start)
static amxp_signal_t *	amxp_slot_find_signal (const amxp_signal_mngr_t *const sig_mngr, const char *const sig_name)
static amxp_slot_t *	amxp_slot_new (amxp_slot_fn_t fn, const char *regexp, const char *expression, void *const priv)
static int	amxp_slot_connect_impl (amxp_signal_t *sig, amxp_slot_fn_t fn, const char *expression, void *const priv)
static int	amxp_slot_connnect_all_of (amxp_signal_mngr_t *const sigmngr, amxp_slot_fn_t fn, const char *const regexp_str, const char *expression, void *const priv)
static int	amxp_slot_connnect_all_sigmngrs (const amxc_llist_t *const sigmngrs, amxp_slot_fn_t fn, const char *const regexp, const char *expression, void *const priv)
static void	amxp_slot_delete_all (amxp_signal_t *sig, amxp_slot_t *slot, amxp_slot_fn_t fn)
static void	amxp_slot_disconnnect_all_of (const amxp_signal_mngr_t *const sigmngr, amxp_slot_fn_t fn)
static void	amxp_slot_disconnect_all_sgmngrs (const amxc_llist_t *const sigmngrs, amxp_slot_fn_t fn)
static int	amxp_slot_disconnect_name (amxp_signal_mngr_t *sig_mngr, const char *const sig_name, amxp_slot_fn_t fn)
int	amxp_slot_connect (amxp_signal_mngr_t *const sig_mngr, const char *const sig_name, const char *const expression, amxp_slot_fn_t fn, void *const priv)
	Connects a slot (function) to a named signal of a signal manager. More...
int	amxp_slot_connect_filtered (amxp_signal_mngr_t *const sig_mngr, const char *const sig_reg_exp, const char *const expression, amxp_slot_fn_t fn, void *const priv)
	Connects a slot (function) to signals using a regular expression. More...
int	amxp_slot_connect_all (const char *sig_reg_exp, const char *const expression, amxp_slot_fn_t fn, void *const priv)
	Connects a slot to all existing and future signals. More...
int	amxp_slot_disconnect (amxp_signal_mngr_t *const sig_mngr, const char *const sig_name, amxp_slot_fn_t fn)
	Disconnects a slot from (a) signal(s). More...
int	amxp_slot_disconnect_with_priv (amxp_signal_mngr_t *sig_mngr, amxp_slot_fn_t fn, void *priv)
	Disconnects a slot from (a) signal(s). More...
int	amxp_slot_disconnect_signal_with_priv (amxp_signal_mngr_t *sig_mngr, const char *sig_name, amxp_slot_fn_t fn, void *priv)
	Disconnects a slot from a signal. More...
void	amxp_slot_disconnect_all (amxp_slot_fn_t fn)
	Disconnects a slot from all signals it was connected to. More...

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

Definition at line 56 of file amxp_slot.c.

Function Documentation

amxp_slot_connect_impl()

static int amxp_slot_connect_impl ( amxp_signal_t *  sig, amxp_slot_fn_t  fn, const char *  expression, void *const  priv  )

static

Definition at line 128 of file amxp_slot.c.

                                                    {
    int retval = -1;
    amxp_slot_t* slot = NULL;
 
    slot = amxp_slot_find(sig, fn, NULL);
    if(slot != NULL) {
        if((expression == NULL) && (slot->expr == NULL) && (priv == NULL)) {
            if(slot->deleted) {
                slot->deleted = false;
            }
            retval = 0;
            goto exit;
        }
    }
 
    slot = amxp_slot_new(fn, NULL, expression, priv);
    when_null(slot, exit);
    amxc_llist_append(&sig->slots, &slot->it);
 
    retval = 0;
 
exit:
    return retval;
}

amxp_slot_connnect_all_of()

static int amxp_slot_connnect_all_of ( amxp_signal_mngr_t *const  sigmngr, amxp_slot_fn_t  fn, const char *const  regexp_str, const char *  expression, void *const  priv  )

static

Definition at line 156 of file amxp_slot.c.

                                                       {
    int retval = -1;
    bool use_reg_exp = false;
    const amxc_htable_t* signals = amxp_get_signals(sigmngr);
 
    if((regexp_str != NULL) && (regexp_str[0] != 0)) {
        regex_t regexp;
        retval = regcomp(&regexp, regexp_str, REG_NOSUB | REG_EXTENDED);
        if(retval != 0) {
            goto exit;
        }
        regfree(&regexp);
        use_reg_exp = true;
    }
 
    if(use_reg_exp) {
        amxp_slot_t* slot = amxp_slot_new(fn, regexp_str, expression, priv);
        if(slot == NULL) {
            retval = -1;
            goto exit;
        }
        amxc_llist_append(&sigmngr->regexp_slots, &slot->it);
        retval = 0;
    } else {
        amxc_htable_for_each(it, signals) {
            amxp_signal_t* sig = amxc_htable_it_get_data(it, amxp_signal_t, hit);
            retval = amxp_slot_connect_impl(sig, fn, expression, priv);
            when_failed(retval, exit);
        }
    }
 
exit:
    return retval;
}

amxp_slot_connnect_all_sigmngrs()

static int amxp_slot_connnect_all_sigmngrs ( const amxc_llist_t *const  sigmngrs, amxp_slot_fn_t  fn, const char *const  regexp, const char *  expression, void *const  priv  )

static

Definition at line 195 of file amxp_slot.c.

                                                             {
    int retval = -1;
 
    amxc_llist_for_each(it, sigmngrs) {
        amxp_signal_mngr_t* sigmngr = amxc_llist_it_get_data(it,
                                                             amxp_signal_mngr_t,
                                                             it);
        when_failed(amxp_slot_connnect_all_of(sigmngr,
                                              fn,
                                              regexp,
                                              expression,
                                              priv), exit);
    }
 
    retval = 0;
 
exit:
    return retval;
}

amxp_slot_delete_all()

static void amxp_slot_delete_all ( amxp_signal_t *  sig, amxp_slot_t *  slot, amxp_slot_fn_t  fn  )

static

Definition at line 219 of file amxp_slot.c.

                                                    {
    while(slot != NULL) {
        slot->deleted = true;
        slot = amxp_slot_find(sig, fn, slot);
    }
}

amxp_slot_disconnect_all_sgmngrs()

static void amxp_slot_disconnect_all_sgmngrs ( const amxc_llist_t *const  sigmngrs, amxp_slot_fn_t  fn  )

static

Definition at line 253 of file amxp_slot.c.

                                                                {
 
    amxc_llist_for_each(it, sigmngrs) {
        amxp_signal_mngr_t* sigmngr = amxc_llist_it_get_data(it,
                                                             amxp_signal_mngr_t,
                                                             it);
        amxp_slot_disconnnect_all_of(sigmngr, fn);
    }
}

amxp_slot_disconnect_name()

static int amxp_slot_disconnect_name ( amxp_signal_mngr_t *  sig_mngr, const char *const  sig_name, amxp_slot_fn_t  fn  )

static

Definition at line 264 of file amxp_slot.c.

                                                        {
    int retval = -1;
    amxp_signal_t* sig = NULL;
    amxp_slot_t* slot = NULL;
    sig_mngr = amxp_get_sigmngr(sig_mngr);
 
    sig = amxp_slot_find_signal(sig_mngr, sig_name);
    if(sig != NULL) {
        slot = amxp_slot_find(sig, fn, NULL);
    }
    if((sig != NULL) && (slot != NULL)) {
        amxp_slot_delete_all(sig, slot, fn);
        retval = 0;
    } else {
        amxc_llist_it_t* it = amxc_llist_get_first(&sig_mngr->regexp_slots);
        amxc_llist_it_t* next = NULL;
        while(it) {
            regex_t regexp;
            slot = amxc_llist_it_get_data(it, amxp_slot_t, it);
            next = amxc_llist_it_get_next(it);
            regcomp(&regexp, slot->regexp, REG_NOSUB | REG_EXTENDED);
            if((slot->fn == fn) &&
               ( regexec(&regexp, sig_name, 0, NULL, 0) == 0)) {
                slot->deleted = true;
                retval = 0;
            }
            regfree(&regexp);
            it = next;
        }
    }
 
    return retval;
}

amxp_slot_disconnnect_all_of()

static void amxp_slot_disconnnect_all_of ( const amxp_signal_mngr_t *const  sigmngr, amxp_slot_fn_t  fn  )

static

Definition at line 228 of file amxp_slot.c.

                                                            {
    const amxc_htable_t* signals = amxp_get_signals(sigmngr);
    amxc_llist_it_t* next = NULL;
    amxc_llist_it_t* regexp_it = NULL;
    amxc_htable_for_each(it, signals) {
        amxp_slot_t* slot = NULL;
        amxp_signal_t* sig = NULL;
        sig = amxc_htable_it_get_data(it, amxp_signal_t, hit);
        slot = amxp_slot_find(sig, fn, NULL);
        amxp_slot_delete_all(sig, slot, fn);
    }
 
    regexp_it = amxc_llist_get_first(&sigmngr->regexp_slots);
    while(regexp_it) {
        amxp_slot_t* slot = NULL;
        next = amxc_llist_it_get_next(regexp_it);
        slot = amxc_llist_it_get_data(regexp_it, amxp_slot_t, it);
        if(slot->fn == fn) {
            slot->deleted = true;
        }
        regexp_it = next;
    }
}

amxp_slot_find()

static amxp_slot_t* amxp_slot_find ( const amxp_signal_t *const  sig, amxp_slot_fn_t  fn, amxp_slot_t *  start  )

static

Definition at line 67 of file amxp_slot.c.

                                                       {
    amxp_slot_t* slot = start;
    amxc_llist_it_t* it = slot == NULL ? amxc_llist_get_first(&sig->slots) :
        amxc_llist_it_get_next(&slot->it);
 
    while(it != NULL) {
        slot = amxc_llist_it_get_data(it, amxp_slot_t, it);
        if(slot->fn == fn) {
            goto exit;
        }
        it = amxc_llist_it_get_next(&slot->it);
    }
 
    slot = NULL;
 
exit:
    return slot;
}

amxp_slot_find_signal()

static amxp_signal_t* amxp_slot_find_signal ( const amxp_signal_mngr_t *const  sig_mngr, const char *const  sig_name  )

static

Definition at line 88 of file amxp_slot.c.

                                                                        {
    amxc_htable_it_t* hit = NULL;
    const amxc_htable_t* signals = amxp_get_signals(sig_mngr);
    amxp_signal_t* sig = NULL;
 
    hit = amxc_htable_get(signals, sig_name);
    when_null(hit, exit);
 
    sig = amxc_htable_it_get_data(hit, amxp_signal_t, hit);
 
exit:
    return sig;
}

amxp_slot_new()

static amxp_slot_t* amxp_slot_new ( amxp_slot_fn_t  fn, const char *  regexp, const char *  expression, void *const  priv  )

static

Definition at line 103 of file amxp_slot.c.

                                                    {
    int retval = -1;
    amxp_slot_t* slot = (amxp_slot_t*) calloc(1, sizeof(amxp_slot_t));
    when_null(slot, exit);
    slot->fn = fn;
    slot->priv = priv;
    slot->regexp = regexp == NULL ? NULL : strdup(regexp);
    if(expression != NULL) {
        when_failed(amxp_expr_new(&slot->expr, expression), exit);
    }
    retval = 0;
 
exit:
    if((retval != 0) && (slot != NULL)) {
        amxp_expr_delete(&slot->expr);
        free(slot->regexp);
        free(slot);
        slot = NULL;
    }
    return slot;
}