amxd_object_event.c File Reference

#include <stdlib.h>
#include <string.h>
#include <amxc/amxc.h>
#include <amxp/amxp_signal.h>
#include <amxp/amxp_slot.h>
#include <amxp/amxp_timer.h>
#include <amxd/amxd_types.h>
#include <amxd/amxd_object.h>
#include <amxd/amxd_object_event.h>
#include <amxd/amxd_dm.h>
#include <amxd/amxd_dm_functions.h>
#include "amxd_priv.h"
#include "amxd_dm_priv.h"
#include "amxd_assert.h"

Go to the source code of this file.

Macros
#define	_GNU_SOURCE

Functions
static amxd_status_t	amxd_object_delete_timer (amxd_object_t *object, UNUSED amxd_param_t *const p, amxd_action_t reason, UNUSED const amxc_var_t *const args, amxc_var_t *const retval, void *priv)
static void	amxd_periodic_inform (UNUSED amxp_timer_t *timer, void *priv)
static void	amxd_object_instance_sig_data (amxd_object_t *object, amxc_var_t *data)
static bool	amxd_object_event_filter (amxd_object_t *const object, UNUSED int32_t depth, UNUSED void *priv)
static bool	amxd_object_event_filter_add (amxd_object_t *const object, int32_t depth, void *priv)
static void	amxd_object_send_event_add (amxd_object_t *const object, UNUSED int32_t depth, void *priv)
static void	amxd_object_send_event_del (amxd_object_t *const object, UNUSED int32_t depth, void *priv)
static void	amxd_build_param_changed (const char *name, amxc_var_t *values, amxc_var_t *data, amxc_var_t *ovalue)
void	amxd_object_send_signal (amxd_object_t *const object, const char *name, amxc_var_t *const data, bool trigger)
	Send an object signal/event. More...
void	amxd_object_send_add_inst (amxd_object_t *instance, bool trigger)
	Send an add instance object event. More...
void	amxd_object_send_del_object (amxd_object_t *object, bool trigger)
void	amxd_object_send_del_inst (amxd_object_t *instance, bool trigger)
	Send a delete instance object event. More...
void	amxd_object_send_changed (amxd_object_t *object, amxc_var_t *params, bool trigger)
	Send an object changed event. More...
amxd_status_t	amxd_object_new_pi (amxd_object_t *object, uint32_t sec)
	Creates and starts a periodic inform event timer. More...
amxd_status_t	amxd_object_delete_pi (amxd_object_t *object)
	Stops and deletes a periodic inform event timer. More...
amxd_status_t	amxd_object_add_event_ext (amxd_object_t *const object, const char *event_name, amxc_var_t *event_data)
	Adds an event definition to the object. More...
amxd_status_t	amxd_object_add_event (amxd_object_t *const object, const char *event_name)
	Adds an event definition to the object. More...
void	amxd_object_remove_event (amxd_object_t *const object, const char *event_name)
	Removes an event definition to the object. More...
amxc_var_t *	amxd_object_new_event_data (const amxd_object_t *object, const char *event_name)
	Allocates a variant that contains the predefined event data. More...

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

Definition at line 56 of file amxd_object_event.c.

Function Documentation

amxd_build_param_changed()

static void amxd_build_param_changed ( const char *  name, amxc_var_t *  values, amxc_var_t *  data, amxc_var_t *  ovalue  )

static

Definition at line 206 of file amxd_object_event.c.

                                                         {
    amxc_var_t* new_value = NULL;
    amxc_var_t* data_param = NULL;
    int result = 0;
 
    new_value = amxc_var_get_pathf(values,
                                   AMXC_VAR_FLAG_DEFAULT,
                                   "'%s'",
                                   name);
 
    data_param = amxc_var_add_new_key(data, name);
    amxc_var_set_type(data_param, AMXC_VAR_ID_HTABLE);
    amxc_var_set_key(data_param, "from", ovalue, AMXC_VAR_FLAG_COPY);
    amxc_var_set_key(data_param, "to", new_value, AMXC_VAR_FLAG_DEFAULT);
    // when no change in value, remove from event data
    amxc_var_compare(ovalue, new_value, &result);
    if(result == 0) {
        amxc_var_delete(&data_param);
    }
}

amxd_object_delete_timer()

static amxd_status_t amxd_object_delete_timer ( amxd_object_t *  object, UNUSED amxd_param_t *const  p, amxd_action_t  reason, UNUSED const amxc_var_t *const  args, amxc_var_t *const  retval, void *  priv  )

static

Definition at line 77 of file amxd_object_event.c.

                                                          {
    amxd_status_t status = amxd_status_ok;
    amxp_timer_t* timer = (amxp_timer_t*) priv;
 
    when_null(object, exit);
    when_null(timer, exit);
 
    when_true_status(reason != action_object_destroy,
                     exit,
                     status = amxd_status_function_not_implemented);
 
 
    amxp_timer_delete(&timer);
 
    amxc_var_clean(retval);
 
exit:
    return status;
}

amxd_object_event_filter()

static bool amxd_object_event_filter ( amxd_object_t *const  object, UNUSED int32_t  depth, UNUSED void *  priv  )

static

Definition at line 132 of file amxd_object_event.c.

                                                        {
    bool retval = true;
    when_true(amxd_object_get_type(object) == amxd_object_root, exit);
 
    if(amxd_object_is_attr_set(object, amxd_oattr_private)) {
        retval = false;
        goto exit;
    }
 
exit:
    return retval;
}

amxd_object_event_filter_add()

static bool amxd_object_event_filter_add ( amxd_object_t *const  object, int32_t  depth, void *  priv  )

static

Definition at line 147 of file amxd_object_event.c.

                                                     {
    bool retval = amxd_object_event_filter(object, depth, priv);
    when_false(retval, exit);
 
    if(amxd_object_get_type(object) == amxd_object_instance) {
        retval = false;
        goto exit;
    }
 
exit:
    return retval;
}

amxd_object_instance_sig_data()

static void amxd_object_instance_sig_data ( amxd_object_t *  object, amxc_var_t *  data  )

static

Definition at line 120 of file amxd_object_event.c.

                                                            {
    amxc_var_t* params = NULL;
 
    amxc_var_add_key(uint32_t, data, "index", object->index);
    amxc_var_add_key(cstring_t, data, "name", object->name);
    params = amxc_var_add_key(amxc_htable_t, data, "parameters", NULL);
    amxd_object_get_params_filtered(object, params, "attributes.volatile == false", amxd_dm_access_protected);
    params = amxc_var_add_key(amxc_htable_t, data, "keys", NULL);
    amxd_object_get_key_params(object, params, amxd_dm_access_protected);
}

amxd_object_send_del_object()

void amxd_object_send_del_object	(	amxd_object_t *	object,
		bool	trigger
	)

Definition at line 262 of file amxd_object_event.c.

                                                                      {
    when_null(object, exit);
 
    amxd_object_hierarchy_walk(object,
                               amxd_direction_down_reverse,
                               amxd_object_event_filter,
                               amxd_object_send_event_del,
                               INT32_MAX,
                               &trigger);
 
exit:
    return;
}

amxd_object_send_event_add()

static void amxd_object_send_event_add ( amxd_object_t *const  object, UNUSED int32_t  depth, void *  priv  )

static

Definition at line 162 of file amxd_object_event.c.

                                                   {
    bool* trigger = (bool*) priv;
    amxc_var_t data;
 
    amxc_var_init(&data);
    amxc_var_set_type(&data, AMXC_VAR_ID_HTABLE);
 
    if(amxd_object_get_type(object) == amxd_object_instance) {
        amxd_object_t* templ = amxd_object_get_parent(object);
        amxd_object_instance_sig_data(object, &data);
        amxd_dm_event("dm:instance-added", templ, &data, *trigger);
    } else {
        amxc_var_t* params = amxc_var_add_key(amxc_htable_t, &data, "parameters", NULL);
        amxd_object_get_params_filtered(object, params, "attributes.volatile == false", amxd_dm_access_protected);
        amxd_dm_event("dm:object-added", object, &data, *trigger);
    }
 
    amxc_var_clean(&data);
}

amxd_object_send_event_del()

static void amxd_object_send_event_del ( amxd_object_t *const  object, UNUSED int32_t  depth, void *  priv  )

static

Definition at line 184 of file amxd_object_event.c.

                                                   {
    bool* trigger = (bool*) priv;
    amxc_var_t data;
 
    amxc_var_init(&data);
    amxc_var_set_type(&data, AMXC_VAR_ID_HTABLE);
 
    if(amxd_object_get_type(object) == amxd_object_instance) {
        amxd_object_t* templ = amxd_object_get_parent(object);
        amxd_object_instance_sig_data(object, &data);
        amxd_dm_event("dm:instance-removed", templ, &data, *trigger);
    } else {
        amxc_var_t* params = amxc_var_add_key(amxc_htable_t, &data, "parameters", NULL);
        amxd_object_get_params_filtered(object, params, "attributes.volatile == false", amxd_dm_access_protected);
        amxd_dm_event("dm:object-removed", object, &data, *trigger);
    }
 
    amxc_var_clean(&data);
}

amxd_periodic_inform()

static void amxd_periodic_inform ( UNUSED amxp_timer_t *  timer, void *  priv  )

static

Definition at line 102 of file amxd_object_event.c.

                                                                         {
    amxd_object_t* object = (amxd_object_t*) priv;
    amxc_var_t data;
    amxc_var_t* parameters = NULL;
 
    amxc_var_init(&data);
    when_null(object, exit);
    amxc_var_set_type(&data, AMXC_VAR_ID_HTABLE);
 
    parameters = amxc_var_add_key(amxc_htable_t, &data, "parameters", NULL);
    amxd_object_get_params(object, parameters, amxd_dm_access_protected);
    amxd_dm_event("dm:periodic-inform", object, &data, false);
 
exit:
    amxc_var_clean(&data);
    return;
}