libamxd  6.4.1
Data Model Manager
amxd_dm_set_function.c File Reference
#include <string.h>
#include <stdlib.h>
#include "amxd_priv.h"
#include <amxd/amxd_dm.h>
#include <amxd/amxd_object.h>
#include <amxd/amxd_path.h>
#include <amxd/amxd_dm_functions.h>
#include <amxd/amxd_transaction.h>
#include "amxd_assert.h"
#include "amxd_object_priv.h"
#include "amxd_dm_priv.h"

Go to the source code of this file.

Functions

static void amxd_add_set (amxd_object_t *object, amxd_trans_t *transaction, amxc_var_t *args)
 
static void amxd_add_result (amxc_var_t *result, amxc_var_t *retval, amxd_status_t status)
 
amxd_status_t amxd_object_func_set (amxd_object_t *object, UNUSED amxd_function_t *func, amxc_var_t *args, amxc_var_t *ret)
 

Function Documentation

◆ amxd_add_result()

static void amxd_add_result ( amxc_var_t *  result,
amxc_var_t *  retval,
amxd_status_t  status 
)
static

Definition at line 77 of file amxd_dm_set_function.c.

79  {
80  amxc_var_for_each(r, result) {
81  const char* path = amxc_var_key(r);
82  amxc_var_t* updated_params = GET_ARG(retval, path);
83 
84  if(updated_params == NULL) {
85  updated_params = amxc_var_add_key(amxc_htable_t, retval, path, NULL);
86  }
87  amxc_var_for_each(param, GET_ARG(r, "parameters")) {
88  const char* param_name = amxc_var_key(param);
89  amxc_var_take_it(param);
90  if(status != amxd_status_ok) {
91  if(!GET_BOOL(param, "required") ||
92  (amxc_var_type_of(param) != AMXC_VAR_ID_HTABLE)) {
93  amxc_var_delete(&param);
94  continue;
95  }
96  }
97  amxc_var_set_key(updated_params, param_name, param, AMXC_VAR_FLAG_DEFAULT);
98  }
99  if(amxc_htable_is_empty(amxc_var_constcast(amxc_htable_t, updated_params))) {
100  amxc_var_delete(&updated_params);
101  }
102  }
103 }
@ amxd_status_ok
Definition: amxd_types.h:78
static amxd_status_t status

◆ amxd_add_set()

static void amxd_add_set ( amxd_object_t object,
amxd_trans_t transaction,
amxc_var_t *  args 
)
static

Definition at line 70 of file amxd_dm_set_function.c.

72  {
73  amxd_trans_select_object(transaction, object);
74  amxd_trans_add_action(transaction, action_object_write, args);
75 }
@ action_object_write
Definition: amxd_types.h:118
amxd_status_t amxd_trans_add_action(amxd_trans_t *const trans, const amxd_action_t reason, const amxc_var_t *data)
Adds an action to a transaction.
amxd_status_t amxd_status_t amxd_trans_select_object(amxd_trans_t *trans, const amxd_object_t *const object)
Selects an object using an object pointer.

◆ amxd_object_func_set()

amxd_status_t amxd_object_func_set ( amxd_object_t object,
UNUSED amxd_function_t func,
amxc_var_t *  args,
amxc_var_t *  ret 
)

Definition at line 105 of file amxd_dm_set_function.c.

108  {
110  amxc_var_t* var_rel_path = GET_ARG(args, "rel_path");
111  const char* rel_path = GET_CHAR(var_rel_path, NULL);
112  amxc_llist_t paths;
113  amxd_dm_t* dm = amxd_object_get_dm(object);
114  amxd_trans_t transaction;
115 
117  amxd_trans_init(&transaction);
118  amxc_llist_init(&paths);
119  amxc_var_set_type(ret, AMXC_VAR_ID_HTABLE);
120 
121  amxc_var_take_it(var_rel_path);
122  if((rel_path != NULL) && (*rel_path != 0)) {
123  retval = amxd_object_resolve_pathf(object, &paths, "%s", rel_path);
124  when_failed(retval, exit);
125  if(amxc_llist_is_empty(&paths)) {
127  goto exit;
128  }
129  amxc_llist_for_each(it, (&paths)) {
130  amxc_string_t* path = amxc_string_from_llist_it(it);
131  object = amxd_dm_findf(dm, "%s", amxc_string_get(path, 0));
132  amxd_add_set(object, &transaction, args);
133  }
134  } else {
135  amxd_add_set(object, &transaction, args);
136  }
137 
138  retval = amxd_trans_apply(&transaction, amxd_object_get_dm(object));
139 
140  if((rel_path != NULL) && (*rel_path != 0)) {
141  uint32_t index = 1;
142  amxc_llist_for_each(it, (&paths)) {
143  amxc_var_t* result = GETI_ARG(&transaction.retvals, index);
144  amxd_add_result(result, ret, retval);
145  index += 2;
146  }
147  } else {
148  amxc_var_t* result = GETI_ARG(&transaction.retvals, 1);
149  amxd_add_result(result, ret, retval);
150  }
151 
152  if(amxc_htable_is_empty(amxc_var_constcast(amxc_htable_t, ret))) {
153  amxc_var_set_type(ret, AMXC_VAR_ID_NULL);
154  }
155 
156 exit:
157  amxc_var_delete(&var_rel_path);
158  amxc_llist_clean(&paths, amxc_string_list_it_free);
159  amxd_trans_clean(&transaction);
160  return retval;
161 }
amxd_object_t * amxd_dm_findf(amxd_dm_t *const dm, const char *abs_path,...) __attribute__((format(printf
void PRIVATE amxd_def_funcs_remove_args(amxc_var_t *args)
static void amxd_add_result(amxc_var_t *result, amxc_var_t *retval, amxd_status_t status)
static void amxd_add_set(amxd_object_t *object, amxd_trans_t *transaction, amxc_var_t *args)
enum _amxd_status amxd_status_t
@ amxd_status_object_not_found
Definition: amxd_types.h:80
@ amxd_status_unknown_error
Definition: amxd_types.h:79
amxd_dm_t * amxd_object_get_dm(const amxd_object_t *const object)
Get the data model.
amxd_object_t amxd_status_t amxd_object_resolve_pathf(amxd_object_t *object, amxc_llist_t *paths, const char *rel_path,...) __attribute__((format(printf
Resolves a search path into a list of matching object paths.
void amxd_trans_clean(amxd_trans_t *const trans)
Cleans the transaction object.
amxd_status_t amxd_trans_apply(amxd_trans_t *const trans, amxd_dm_t *const dm)
Applies all previously added actions.
amxd_status_t amxd_trans_init(amxd_trans_t *const trans)
Initializes a transaction object.
static amxd_dm_t dm