amxb_ba_subscribe.c File Reference

#include <stdlib.h>
#include <errno.h>
#include <fcntl.h>
#include <string.h>
#include <amxc/amxc.h>
#include <amxp/amxp.h>
#include <amxp/amxp_expression.h>
#include <amxd/amxd_common.h>
#include <amxd/amxd_dm.h>
#include <amxd/amxd_object.h>
#include <amxd/amxd_object_event.h>
#include <amxd/amxd_path.h>
#include <amxb/amxb_be_intf.h>
#include <amxb/amxb.h>
#include "amxb_priv.h"

Go to the source code of this file.

Macros
#define	_GNU_SOURCE

Functions
static int	amxb_subscribe_local_impl (amxb_bus_ctx_t *ctx, const char *path, const char *expression, amxp_slot_fn_t slot_cb, void *priv)
static int	amxb_subscribe_be_impl (amxb_bus_ctx_t *ctx, const char *path, const char *expression, amxp_slot_fn_t slot_cb, void *priv)
static void	amxb_build_path (amxc_var_t *info, amxd_path_t *path)
static int	amxb_build_expression (amxc_string_t *str_expr, amxd_path_t *obj_path, const char *expression)
int	amxb_subscribe (amxb_bus_ctx_t *const ctx, const char *object, const char *expression, amxp_slot_fn_t slot_cb, void *priv)
	Subscribes for events of a object tree. More...
int	amxb_unsubscribe (amxb_bus_ctx_t *const ctx, const char *object, amxp_slot_fn_t slot_cb, void *priv)
	Removes an event subscription. More...
int	amxb_publish (amxb_bus_ctx_t *const ctx, const char *object, const char *name, amxc_var_t *data)
	Publish an event for a specific object. More...

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

Definition at line 56 of file amxb_ba_subscribe.c.

Function Documentation

amxb_build_expression()

static int amxb_build_expression ( amxc_string_t *  str_expr, amxd_path_t *  obj_path, const char *  expression  )

static

Definition at line 171 of file amxb_ba_subscribe.c.

                                                         {
    amxp_expr_status_t status = amxp_expr_status_ok;
    const char* sep = "";
    amxp_expr_t expr;
 
    if(amxd_path_is_search_path(obj_path)) {
        amxc_string_setf(str_expr, "%s", amxd_path_get(obj_path, AMXD_OBJECT_TERMINATE));
        amxc_string_replace(str_expr, "'", "\"", UINT32_MAX);
        amxc_string_prependf(str_expr, "path starts with search_path('");
        amxc_string_appendf(str_expr, "')");
        sep = " && ";
    } else {
        amxc_string_setf(str_expr, "%s", amxd_path_get(obj_path, AMXD_OBJECT_TERMINATE));
        amxc_string_replace(str_expr, "'", "\"", UINT32_MAX);
        amxc_string_prependf(str_expr, "(path starts with '");
        amxc_string_appendf(str_expr, "' || !(contains('path') && contains('object')))");
        sep = " && ";
    }
 
    if((expression != NULL) && (*expression != 0)) {
        amxc_string_appendf(str_expr, "%s(%s)", sep, expression);
    }
 
    if(!amxc_string_is_empty(str_expr)) {
        status = amxp_expr_init(&expr, amxc_string_get(str_expr, 0));
        amxp_expr_clean(&expr);
    }
 
    return status == amxp_expr_status_ok ? 0 : -1;
}

amxb_build_path()

static void amxb_build_path ( amxc_var_t *  info, amxd_path_t *  path  )

static

Definition at line 152 of file amxb_ba_subscribe.c.

                                                                 {
    amxc_var_t* obj_data = GETI_ARG(info, 0);
    uint32_t type = amxc_var_dyncast(uint32_t, GET_ARG(obj_data, "type_id"));
    const char* obj_path = GET_CHAR(obj_data, "path");
    uint32_t index = amxc_var_dyncast(uint32_t, GET_ARG(obj_data, "index"));
    char* spath = NULL;
 
    free(amxd_path_get_fixed_part(path, true));
    spath = strdup(amxd_path_get(path, AMXD_OBJECT_TERMINATE));
 
    if(type == amxd_object_instance) {
        amxd_path_setf(path, false, "%s%d.%s", obj_path, index, spath);
    } else {
        amxd_path_setf(path, false, "%s%s", obj_path, spath);
    }
 
    free(spath);
}

amxb_subscribe_be_impl()

static int amxb_subscribe_be_impl ( amxb_bus_ctx_t *  ctx, const char *  path, const char *  expression, amxp_slot_fn_t  slot_cb, void *  priv  )

static

Definition at line 124 of file amxb_ba_subscribe.c.

                                              {
    int retval = -1;
    amxp_signal_t* signal = NULL;
 
    signal = amxp_sigmngr_find_signal(&ctx->sigmngr, path);
    if(signal == NULL) {
        const amxb_be_funcs_t* fns = ctx->bus_fn;
        if(amxb_is_valid_be_func(fns, subscribe, fns->subscribe)) {
            retval = fns->subscribe(ctx->bus_ctx, path);
            when_failed(retval, exit);
            amxp_sigmngr_add_signal(&ctx->sigmngr, path);
        } else {
            retval = AMXB_ERROR_NOT_SUPPORTED_OP;
            goto exit;
        }
    }
    amxp_slot_connect(&ctx->sigmngr, path, expression, slot_cb, priv);
 
    retval = 0;
 
exit:
    return retval;
}

amxb_subscribe_local_impl()

static int amxb_subscribe_local_impl ( amxb_bus_ctx_t *  ctx, const char *  path, const char *  expression, amxp_slot_fn_t  slot_cb, void *  priv  )

static

Definition at line 79 of file amxb_ba_subscribe.c.

                                                 {
    int retval = -1;
    amxd_dm_t* dm = ctx->dm;
    amxd_object_t* object = amxd_dm_findf(dm, "%s", path);
    amxp_signal_t* signal = NULL;
    amxc_string_t local_expr;
    amxc_htable_it_t* sub_hit = NULL;
 
    amxc_string_init(&local_expr, 0);
 
    when_null(object, exit);
 
    signal = amxp_sigmngr_find_signal(&ctx->sigmngr, path);
    if(signal == NULL) {
        amxp_sigmngr_add_signal(&ctx->sigmngr, path);
    }
    retval = amxp_slot_connect(&ctx->sigmngr, path, expression, slot_cb, priv);
    when_failed(retval, exit);
 
    if(amxc_htable_contains(&ctx->subscriptions, path)) {
        goto exit;
    }
 
    sub_hit = (amxc_htable_it_t*) calloc(1, sizeof(amxc_htable_it_t));
    amxc_htable_insert(&ctx->subscriptions, path, sub_hit);
 
    amxc_string_appendf(&local_expr,
                        "object starts with \"%s.\" || path starts with \"%s.\"",
                        path,
                        path);
    retval = amxp_slot_connect(&ctx->dm->sigmngr,
                               "*",
                               amxc_string_get(&local_expr, 0),
                               amxb_dm_event_to_object_event,
                               sub_hit);
 
exit:
    amxc_string_clean(&local_expr);
    return retval;
}