amxb_ba_op_set.c File Reference

#include <stdlib.h>
#include <stdio.h>
#include <errno.h>
#include <fcntl.h>
#include <string.h>
#include <amxc/amxc.h>
#include <amxp/amxp.h>
#include <amxd/amxd_common.h>
#include <amxd/amxd_dm.h>
#include <amxd/amxd_path.h>
#include <amxd/amxd_object.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_invoke_set (amxb_bus_ctx_t *const bus_ctx, const char *object, const char *rel_path, uint32_t flags, amxc_var_t *values, amxc_var_t *ovalues, amxc_var_t *ret, int timeout)
int	amxb_set_impl (amxb_bus_ctx_t *const bus_ctx, const char *object, uint32_t flags, amxc_var_t *values, amxc_var_t *ovalues, amxc_var_t *ret, int timeout)
int	amxb_set (amxb_bus_ctx_t *const bus_ctx, const char *object, amxc_var_t *values, amxc_var_t *ret, int timeout)
	Sets parameter values of one single object or of multiple instance objects. More...

Macro Definition Documentation

_GNU_SOURCE

#define _GNU_SOURCE

Definition at line 56 of file amxb_ba_op_set.c.

Function Documentation

amxb_invoke_set()

static int amxb_invoke_set ( amxb_bus_ctx_t *const  bus_ctx, const char *  object, const char *  rel_path, uint32_t  flags, amxc_var_t *  values, amxc_var_t *  ovalues, amxc_var_t *  ret, int  timeout  )

static

Definition at line 78 of file amxb_ba_op_set.c.

                                        {
 
    amxb_invoke_t* invoke_ctx = NULL;
    amxc_var_t args;
    amxc_var_t* params;
    int retval = amxd_status_unknown_error;
 
    amxc_var_init(&args);
    when_true(amxc_var_type_of(values) != AMXC_VAR_ID_HTABLE &&
              !amxc_var_is_null(values), exit);
    when_true(amxc_var_type_of(ovalues) != AMXC_VAR_ID_HTABLE &&
              !amxc_var_is_null(ovalues), exit);
 
    amxc_var_set_type(&args, AMXC_VAR_ID_HTABLE);
    if((rel_path != NULL) && (*rel_path != 0)) {
        amxc_var_add_key(cstring_t, &args, "rel_path", rel_path);
    }
    amxc_var_add_key(uint32_t, &args, "access", bus_ctx->access);
    if(values != NULL) {
        params = amxc_var_add_key(amxc_htable_t, &args, "parameters", NULL);
        amxc_var_move(params, values);
    }
    if(ovalues != NULL) {
        params = amxc_var_add_key(amxc_htable_t, &args, "oparameters", NULL);
        amxc_var_move(params, ovalues);
    }
 
    if((flags & AMXB_FLAG_PARTIAL) == AMXB_FLAG_PARTIAL) {
        amxc_var_add_key(bool, &args, "allow_partial", true);
    }
 
    retval = amxb_new_invoke(&invoke_ctx, bus_ctx, object, NULL, "_set");
    when_failed(retval, exit);
    retval = amxb_invoke(invoke_ctx, &args, ret, NULL, NULL, timeout);
    when_failed(retval, exit);
 
exit:
    amxb_free_invoke(&invoke_ctx);
    amxc_var_clean(&args);
    return retval;
}

amxb_set_impl()

int amxb_set_impl	(	amxb_bus_ctx_t *const	bus_ctx,
		const char *	object,
		uint32_t	flags,
		amxc_var_t *	values,
		amxc_var_t *	ovalues,
		amxc_var_t *	ret,
		int	timeout
	)

Definition at line 127 of file amxb_ba_op_set.c.

                               {
    int retval = amxd_status_unknown_error;
    const amxb_be_funcs_t* fns = NULL;
    bool lobject = false;
    amxd_path_t path;
    char* fixed = NULL;
    const char* rel_path = NULL;
 
    amxd_path_init(&path, NULL);
    when_null(bus_ctx, exit);
    when_null(bus_ctx->bus_ctx, exit);
 
    amxd_path_setf(&path, true, "%s", object);
 
    while(amxd_path_get_type(&path) == amxd_path_reference) {
        retval = amxb_follow_reference(bus_ctx, &path, timeout);
        when_failed(retval, exit);
    }
 
    fixed = amxd_path_get_fixed_part(&path, true);
    rel_path = amxd_path_get(&path, AMXD_OBJECT_TERMINATE);
 
    lobject = amxb_is_local_object(bus_ctx, fixed);
    fns = bus_ctx->bus_fn;
 
    if(lobject || !amxb_is_valid_be_func(fns, set, fns->set)) {
        retval = amxb_invoke_set(bus_ctx, fixed, rel_path, flags,
                                 values, ovalues, ret, timeout);
    } else {
        retval = fns->set(bus_ctx->bus_ctx, fixed, rel_path, flags,
                          values, ovalues, bus_ctx->access, ret, timeout);
    }
 
exit:
    free(fixed);
    amxd_path_clean(&path);
    return retval;
}