amxb_subscription.c File Reference

#include <stdlib.h>
#include <string.h>
#include <amxc/amxc_macros.h>
#include <amxc/amxc.h>
#include <amxp/amxp.h>
#include <amxd/amxd_types.h>
#include <amxd/amxd_path.h>
#include <amxb/amxb_error.h>
#include <amxb/amxb_types.h>
#include <amxb/amxb_subscription.h>
#include <amxb/amxb_subscribe.h>
#include "amxb_priv.h"

Go to the source code of this file.

Macros
#define	_GNU_SOURCE

Functions
static amxb_sub_t *	amxb_sub_alloc (const char *object, amxp_slot_fn_t slot_cb, void *priv)
static bool	amxb_subscription_matches (const char *p1, const char *p2, int len1, int len2)
static amxb_subscription_t *	amxb_subscription_find_relation (amxb_bus_ctx_t *bus_ctx, const char *object, bool parent)
int	amxb_subscription_remove (amxb_subscription_t *subscription)
int	amxb_subscription_new (amxb_subscription_t **subscription, amxb_bus_ctx_t *bus_ctx, const char *object, const char *expression, amxp_slot_fn_t slot_cb, void *priv)
	Creates a subscription object and subscribes for events of a object tree. More...
amxb_subscription_t *	amxb_subscription_find (amxb_bus_ctx_t *bus_ctx, const char *object, amxp_slot_fn_t slot_cb, void *priv)
	Find an exact subscription. More...
amxb_subscription_t *	amxb_subscription_find_parent (amxb_bus_ctx_t *bus_ctx, const char *object)
	Find a parent subscription. More...
amxb_subscription_t *	amxb_subscription_find_child (amxb_bus_ctx_t *bus_ctx, const char *object)
	Find a child subscription. More...
int	amxb_subscription_delete (amxb_subscription_t **subscription)
	Deletes a subscription object and unsubscribe for events of a object tree. More...
void	amxb_subscription_remove_it (amxc_llist_it_t *it)

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

Definition at line 55 of file amxb_subscription.c.

Function Documentation

amxb_sub_alloc()

static amxb_sub_t* amxb_sub_alloc ( const char *  object, amxp_slot_fn_t  slot_cb, void *  priv  )

static

Definition at line 75 of file amxb_subscription.c.

                                              {
    amxb_sub_t* sub = NULL;
    amxd_path_t path;
 
    amxd_path_init(&path, NULL);
 
    when_str_empty(object, exit);
    when_null(slot_cb, exit);
 
    amxd_path_setf(&path, true, "%s", object);
 
    sub = (amxb_sub_t*) calloc(1, sizeof(amxb_sub_t));
    when_null((sub), exit);
    sub->data.slot_cb = slot_cb;
    sub->data.priv = priv;
 
    sub->data.object = amxd_path_get_fixed_part(&path, false);
    if(sub->data.object == NULL) {
        free(sub);
        sub = NULL;
        goto exit;
    }
 
    if(*sub->data.object != 0) {
        sub->data.object[strlen(sub->data.object) - 1] = 0;
    }
 
exit:
    amxd_path_clean(&path);
    return sub;
}

amxb_subscription_find_relation()

static amxb_subscription_t* amxb_subscription_find_relation ( amxb_bus_ctx_t *  bus_ctx, const char *  object, bool  parent  )

static

Definition at line 122 of file amxb_subscription.c.

                                                                         {
    amxb_subscription_t* subscription = NULL;
    amxd_path_t search_path;
    amxd_path_t sub_path;
    char* fsp = NULL;
    int search_len = 0;
 
    amxd_path_init(&search_path, NULL);
    amxd_path_init(&sub_path, NULL);
 
    when_str_empty(object, exit);
 
    amxd_path_setf(&search_path, true, "%s", object);
    fsp = amxd_path_get_fixed_part(&search_path, false);
    search_len = strlen(fsp);
 
    amxc_llist_iterate(it, (&bus_ctx->client_subs)) {
        amxb_sub_t* sub = amxc_container_of(it, amxb_sub_t, it);
        char* fp = NULL;
        int sub_len = 0;
        amxd_path_setf(&sub_path, true, "%s", sub->data.object);
 
        fp = amxd_path_get_fixed_part(&sub_path, false);
        sub_len = strlen(fp);
        subscription = &sub->data;
 
        if(parent) {
            if(amxb_subscription_matches(fp, fsp, sub_len, search_len)) {
                free(fp);
                break;
            }
        } else {
            if(amxb_subscription_matches(fsp, fp, search_len, sub_len)) {
                free(fp);
                break;
            }
        }
        free(fp);
        subscription = NULL;
    }
 
exit:
    amxd_path_clean(&search_path);
    amxd_path_clean(&sub_path);
    free(fsp);
    return subscription;
}

amxb_subscription_matches()

static bool amxb_subscription_matches ( const char *  p1, const char *  p2, int  len1, int  len2  )

static

Definition at line 109 of file amxb_subscription.c.

                                                {
    bool match = false;
    if(len1 < len2) {
        if(strncmp(p1, p2, len1) == 0) {
            match = true;
        }
    }
    return match;
}

amxb_subscription_remove()

int amxb_subscription_remove

(

amxb_subscription_t *

subscription

)

Definition at line 172 of file amxb_subscription.c.

                                                                {
    int rv = AMXB_STATUS_OK;
    amxb_sub_t* sub = amxc_container_of(subscription, amxb_sub_t, data);
 
    if(sub->it.llist != NULL) {
        amxb_bus_ctx_t* bus_ctx = NULL;
        bus_ctx = amxc_container_of(sub->it.llist, amxb_bus_ctx_t, client_subs);
        amxc_llist_it_take(&sub->it);
        rv = amxb_unsubscribe(bus_ctx, subscription->object, subscription->slot_cb,
                              subscription->priv);
    }
 
    return rv;
}

amxb_subscription_remove_it()

void amxb_subscription_remove_it

(

amxc_llist_it_t *

it

)

Definition at line 270 of file amxb_subscription.c.

                                                      {
    amxb_subscription_t* subscription = amxc_container_of(it, amxb_subscription_t, it);
    amxb_subscription_delete(&subscription);
}