Mon Aug 31 12:30:34 2015

Asterisk developer's documentation


data.c File Reference

Data retrieval API. More...

#include "asterisk.h"
#include "asterisk/_private.h"
#include <regex.h>
#include "asterisk/module.h"
#include "asterisk/utils.h"
#include "asterisk/lock.h"
#include "asterisk/data.h"
#include "asterisk/astobj2.h"
#include "asterisk/xml.h"
#include "asterisk/cli.h"
#include "asterisk/term.h"
#include "asterisk/manager.h"
#include "asterisk/test.h"
#include "asterisk/frame.h"

Go to the source code of this file.

Data Structures

struct  ast_data
 The data tree to be returned by the callbacks and managed by functions local to this file. More...
struct  ast_data_iterator
 This structure is used by the iterator. More...
struct  ast_data_search
 The list of nodes with their search requirement. More...
struct  data_filter
 The filter node. More...
struct  data_provider
 A data container node pointing to the registered handler. More...
struct  glob_list_t
 glob list More...

Defines

#define data_read_lock()   ast_rwlock_rdlock(&root_data.lock)
#define data_unlock()   ast_rwlock_unlock(&root_data.lock)
#define data_write_lock()   ast_rwlock_wrlock(&root_data.lock)
#define NUM_DATA_FILTER_BUCKETS   59
#define NUM_DATA_NODE_BUCKETS   59
#define NUM_DATA_RESULT_BUCKETS   59
#define NUM_DATA_SEARCH_BUCKETS   59

Enumerations

enum  data_search_comparison {
  DATA_CMP_UNKNOWN, DATA_CMP_EQ, DATA_CMP_NEQ, DATA_CMP_GT,
  DATA_CMP_GE, DATA_CMP_LT, DATA_CMP_LE
}
 

Type of comparisons allow in the search string.

More...

Functions

static struct ast_data__ast_data_add (struct ast_data *root, const char *name, enum ast_data_type type, void *ptr)
int __ast_data_add_structure (struct ast_data *root, const struct ast_data_mapping_structure *mapping, size_t mapping_len, void *structure)
 Add a complete structure to a node.
int __ast_data_register (const char *path, const struct ast_data_handler *handler, const char *registrar, struct ast_module *mod)
 Register a data provider.
int __ast_data_register_multiple (const struct ast_data_entry *data_entries, size_t entries, const char *registrar, struct ast_module *mod)
 Register multiple data providers at once.
int __ast_data_search_cmp_structure (const struct ast_data_search *search, const struct ast_data_mapping_structure *mapping, size_t mapping_len, void *structure, const char *structure_name)
 Based on a search tree, evaluate every member of a structure against it.
int __ast_data_unregister (const char *path, const char *registrar)
 Unregister a data provider.
static void __data_result_print_cli (int fd, const struct ast_data *root, uint32_t depth)
struct ast_dataast_data_add_bool (struct ast_data *root, const char *childname, unsigned int boolean)
 Add a boolean node type.
struct ast_dataast_data_add_char (struct ast_data *root, const char *name, char value)
 Add a char node type.
int ast_data_add_codecs (struct ast_data *root, const char *node_name, format_t capability)
 Add the list of codecs in the root node based on the capability parameter.
struct ast_dataast_data_add_dbl (struct ast_data *root, const char *childname, double dbl)
 Add a floating point node type.
struct ast_dataast_data_add_int (struct ast_data *root, const char *name, int value)
 Add an integer node type.
struct ast_dataast_data_add_ipaddr (struct ast_data *root, const char *childname, struct in_addr addr)
 Add a ipv4 address type.
struct ast_dataast_data_add_milliseconds (struct ast_data *root, const char *childname, unsigned int milliseconds)
 Add a milliseconds node type.
struct ast_dataast_data_add_node (struct ast_data *root, const char *name)
 Add a container child.
struct ast_dataast_data_add_password (struct ast_data *root, const char *childname, const char *value)
 Add a password node type.
struct ast_dataast_data_add_ptr (struct ast_data *root, const char *childname, void *ptr)
 Add a ptr node type.
struct ast_dataast_data_add_seconds (struct ast_data *root, const char *childname, unsigned int seconds)
 Add a seconds node type.
struct ast_dataast_data_add_str (struct ast_data *root, const char *childname, const char *value)
 Add a string node type.
struct ast_dataast_data_add_timestamp (struct ast_data *root, const char *childname, unsigned int timestamp)
 Add a timestamp node type.
struct ast_dataast_data_add_uint (struct ast_data *root, const char *name, unsigned int value)
 Add an unsigned integer node type.
void ast_data_free (struct ast_data *root)
 Release the allocated memory of a tree.
struct ast_dataast_data_get (const struct ast_data_query *query)
 Retrieve a subtree from the asterisk data API.
struct ast_xml_doc * ast_data_get_xml (const struct ast_data_query *query)
 Retrieve a subtree from the asterisk data API in XML format..
int ast_data_init (void)
void ast_data_iterator_end (struct ast_data_iterator *iterator)
 Release (stop using) an iterator.
struct ast_data_iteratorast_data_iterator_init (struct ast_data *tree, const char *elements)
 Initialize an iterator.
struct ast_dataast_data_iterator_next (struct ast_data_iterator *iterator)
 Get the next node of the tree.
void ast_data_remove_node (struct ast_data *root, struct ast_data *child)
 Remove a node that was added using ast_data_add_.
int ast_data_retrieve (struct ast_data *tree, const char *path, struct ast_data_retrieve *content)
 Retrieve a value from a node in the tree.
char * ast_data_retrieve_name (struct ast_data *node)
 Get the node name.
enum ast_data_type ast_data_retrieve_type (struct ast_data *node, const char *path)
 Get a node type.
int ast_data_search_match (const struct ast_data_search *search, struct ast_data *data)
 Check the current generated node to know if it matches the search condition.
static struct data_filterdata_filter_add_child (struct ao2_container *root, char *name)
static int data_filter_add_nodes (struct ao2_container *root, char *path)
static struct data_filterdata_filter_alloc (const char *name)
static int data_filter_cmp (void *obj, void *arg, int flags)
static void data_filter_destructor (void *obj)
static struct data_filterdata_filter_find (struct ao2_container *parent, const char *name)
static struct data_filterdata_filter_generate (const char *constfilter)
static int data_filter_hash (const void *obj, const int flags)
static void data_filter_release (struct data_filter *filter)
static void data_get_xml_add_child (struct ast_data *parent_data, struct ast_xml_node *parent_xml)
static struct data_providerdata_provider_add_child (struct ao2_container *parent, const char *name, const struct ast_data_handler *handler, const char *registrar)
static int data_provider_cmp (void *obj1, void *obj2, int flags)
static struct data_providerdata_provider_create (struct ao2_container *parent, const char *path, const char *registrar)
static void data_provider_destructor (void *obj)
static struct data_providerdata_provider_find (struct ao2_container *parent, const char *name, const char *registrar)
static int data_provider_hash (const void *obj, const int flags)
static struct data_providerdata_provider_new (const char *name, const struct ast_data_handler *handler, const char *registrar)
static void data_provider_print_cli (int fd, const char *name, struct ao2_container *container, struct ast_str *path)
static int data_provider_release (struct ao2_container *parent, const char *path, const char *registrar)
static void data_provider_release_all (struct ao2_container *parent, const char *registrar)
static void data_result_add_child (struct ast_data *root, struct ast_data *child)
static int data_result_cmp (void *obj, void *arg, int flags)
static struct ast_datadata_result_create (const char *name)
static void data_result_destructor (void *obj)
static struct ast_datadata_result_find_child (struct ast_data *root, const char *name)
static struct ast_datadata_result_generate (const struct ast_data_query *query, const char *search_path)
static struct ast_datadata_result_generate_node (const struct ast_data_query *query, const struct data_provider *root_provider, const char *parent_node_name, const struct ast_data_search *search, const struct data_filter *filter)
static int data_result_get_color (enum ast_data_type type)
static struct ast_datadata_result_get_node (struct ast_data *node, const char *path)
static int data_result_hash (const void *obj, const int flags)
static void data_result_manager_output (struct mansession *s, const char *name, struct ao2_container *container, struct ast_str *path, int id)
static void data_result_print_cli (int fd, const struct ast_data *root)
static void data_result_print_cli_node (int fd, const struct ast_data *node, uint32_t depth)
static struct ast_data_searchdata_search_add_child (struct ao2_container *parent, const char *name)
static struct ast_data_searchdata_search_alloc (const char *name)
static int data_search_cmp (void *obj, void *arg, int flags)
static int data_search_cmp_bool (const struct ast_data_search *root, const char *name, unsigned int value)
static int data_search_cmp_char (const struct ast_data_search *root, const char *name, char value)
static int data_search_cmp_dbl (const struct ast_data_search *root, const char *name, double value)
static int data_search_cmp_int (const struct ast_data_search *root, const char *name, int value)
static int data_search_cmp_ipaddr (const struct ast_data_search *root, const char *name, struct in_addr addr)
static int data_search_cmp_ptr (const struct ast_data_search *root, const char *name, void *ptr)
static int data_search_cmp_string (const struct ast_data_search *root, const char *name, char *value)
static int data_search_cmp_uint (const struct ast_data_search *root, const char *name, unsigned int value)
static int data_search_comparison_char (char a)
static int data_search_comparison_result (int cmpval, enum data_search_comparison comparison_type)
static enum data_search_comparison data_search_comparison_type (const char *comparison)
static struct ast_data_searchdata_search_create (struct ao2_container *parent, const char *path)
static void data_search_destructor (void *obj)
static struct ast_data_searchdata_search_find (struct ao2_container *parent, const char *name)
static struct ast_data_searchdata_search_generate (const char *search_string)
static struct ast_data_searchdata_search_get_node (const struct ast_data_search *node, const char *path)
static int data_search_hash (const void *obj, const int flags)
static int data_search_mapping_find (const struct ast_data_mapping_structure *map, size_t mapping_len, const char *member_name)
static void data_search_release (struct ast_data_search *search)
static void data_shutdown (void)
static int data_structure_compatible (int structure_version, uint32_t latest_compatible, uint32_t current)
static char * handle_cli_data_get (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static char * handle_cli_data_show_providers (struct ast_cli_entry *e, int cmd, struct ast_cli_args *a)
static int manager_data_get (struct mansession *s, const struct message *m)
static char * next_node_name (char **path)

Variables

static struct ast_cli_entry cli_data []
static const uint32_t current_handler_version = AST_DATA_HANDLER_VERSION
 Current handler structure version.
static const uint32_t current_query_version = AST_DATA_QUERY_VERSION
 Current query structure version.
struct {
   int   color
   enum ast_data_type   type
data_result_color []
static const uint32_t latest_handler_compatible_version = 0
 The last compatible version.
static const uint32_t latest_query_compatible_version = 0
 The last compatible version.
struct {
   struct ao2_container *   container
 The asterisk data main content structure.
   ast_rwlock_t   lock
 asterisk data locking mechanism.
root_data

Detailed Description

Data retrieval API.

Author:
Brett Bryant <brettbryant@gmail.com>
Eliel C. Sardanons (LU1ALY) <eliels@gmail.com>

Definition in file data.c.


Define Documentation

 
#define data_read_lock (  )     ast_rwlock_rdlock(&root_data.lock)

Definition at line 238 of file data.c.

Referenced by ast_data_get(), and handle_cli_data_show_providers().

 
#define data_unlock (  )     ast_rwlock_unlock(&root_data.lock)
 
#define data_write_lock (  )     ast_rwlock_wrlock(&root_data.lock)

Definition at line 231 of file data.c.

Referenced by __ast_data_register(), and __ast_data_unregister().

#define NUM_DATA_FILTER_BUCKETS   59

Definition at line 69 of file data.c.

Referenced by data_filter_alloc().

#define NUM_DATA_NODE_BUCKETS   59

Definition at line 66 of file data.c.

Referenced by ast_data_init(), and data_provider_new().

#define NUM_DATA_RESULT_BUCKETS   59

Definition at line 67 of file data.c.

Referenced by data_result_create().

#define NUM_DATA_SEARCH_BUCKETS   59

Definition at line 68 of file data.c.

Referenced by data_search_alloc().


Enumeration Type Documentation

Type of comparisons allow in the search string.

Enumerator:
DATA_CMP_UNKNOWN 
DATA_CMP_EQ 
DATA_CMP_NEQ 
DATA_CMP_GT 
DATA_CMP_GE 
DATA_CMP_LT 
DATA_CMP_LE 

Definition at line 111 of file data.c.

00111                             {
00112    DATA_CMP_UNKNOWN,
00113    DATA_CMP_EQ,   /* =  */
00114    DATA_CMP_NEQ,  /* != */
00115    DATA_CMP_GT,   /* >  */
00116    DATA_CMP_GE,   /* >= */
00117    DATA_CMP_LT,   /* <  */
00118    DATA_CMP_LE /* <= */
00119 };


Function Documentation

static struct ast_data* __ast_data_add ( struct ast_data root,
const char *  name,
enum ast_data_type  type,
void *  ptr 
) [static, read]

Definition at line 2240 of file data.c.

References ao2_ref, AST_DATA_BOOLEAN, AST_DATA_CHARACTER, AST_DATA_CONTAINER, AST_DATA_DOUBLE, AST_DATA_INTEGER, AST_DATA_IPADDR, AST_DATA_MILLISECONDS, AST_DATA_PASSWORD, AST_DATA_POINTER, AST_DATA_SECONDS, AST_DATA_STRING, AST_DATA_TIMESTAMP, AST_DATA_UNSIGNED_INTEGER, ast_data::boolean, ast_data::character, data_filter::children, ast_data::children, data_filter_find(), data_result_add_child(), data_result_create(), ast_data::dbl, ast_data::filter, filter(), ast_data::ipaddr, ast_data::payload, ast_data::ptr, ast_data::sint, ast_data::str, ast_data::type, and ast_data::uint.

Referenced by ast_data_add_bool(), ast_data_add_char(), ast_data_add_dbl(), ast_data_add_int(), ast_data_add_ipaddr(), ast_data_add_milliseconds(), ast_data_add_node(), ast_data_add_password(), ast_data_add_ptr(), ast_data_add_seconds(), ast_data_add_str(), ast_data_add_timestamp(), and ast_data_add_uint().

02242 {
02243    struct ast_data *node;
02244    struct data_filter *filter, *filter_child = NULL;
02245 
02246    if (!root || !root->children) {
02247       /* invalid data result node. */
02248       return NULL;
02249    }
02250 
02251    /* check if we need to add this node, based on the filter. */
02252    if (root->filter) {
02253       filter = data_filter_find(root->filter->children, name);
02254       if (!filter) {
02255          return NULL;
02256       }
02257       ao2_ref(filter, -1);
02258    }
02259 
02260    node = data_result_create(name);
02261    if (!node) {
02262       return NULL;
02263    }
02264 
02265    node->type = type;
02266 
02267    switch (type) {
02268    case AST_DATA_BOOLEAN:
02269       node->payload.boolean = *(unsigned int *) ptr;
02270       break;
02271    case AST_DATA_INTEGER:
02272       node->payload.sint = *(int *) ptr;
02273       break;
02274    case AST_DATA_TIMESTAMP:
02275    case AST_DATA_SECONDS:
02276    case AST_DATA_MILLISECONDS:
02277    case AST_DATA_UNSIGNED_INTEGER:
02278       node->payload.uint = *(unsigned int *) ptr;
02279       break;
02280    case AST_DATA_DOUBLE:
02281       node->payload.dbl = *(double *) ptr;
02282       break;
02283    case AST_DATA_PASSWORD:
02284    case AST_DATA_STRING:
02285       node->payload.str = (char *) ptr;
02286       break;
02287    case AST_DATA_CHARACTER:
02288       node->payload.character = *(char *) ptr;
02289       break;
02290    case AST_DATA_POINTER:
02291       node->payload.ptr = ptr;
02292       break;
02293    case AST_DATA_IPADDR:
02294       node->payload.ipaddr = *(struct in_addr *) ptr;
02295       break;
02296    case AST_DATA_CONTAINER:
02297       if (root->filter) {
02298          filter_child = data_filter_find(root->filter->children, name);
02299          if (filter_child) {
02300             /* do not increment the refcount because it is not neccesary. */
02301             ao2_ref(filter_child, -1);
02302          }
02303       }
02304       node->filter = filter_child;
02305       break;
02306    default:
02307       break;
02308    }
02309 
02310    data_result_add_child(root, node);
02311 
02312    ao2_ref(node, -1);
02313 
02314    return node;
02315 }

int __ast_data_add_structure ( struct ast_data root,
const struct ast_data_mapping_structure mapping,
size_t  mapping_len,
void *  structure 
)

Add a complete structure to a node.

Parameters:
[in] root Where to add the structure.
[in] mapping The structure mapping array.
[in] mapping_len The lenght of the mapping array.
[in] structure The structure pointer.
Return values:
0 on success.
1 on error.

Definition at line 2422 of file data.c.

References ast_data_add_bool(), ast_data_add_char(), ast_data_add_dbl(), ast_data_add_int(), ast_data_add_ipaddr(), ast_data_add_milliseconds(), ast_data_add_password(), ast_data_add_ptr(), ast_data_add_seconds(), ast_data_add_str(), ast_data_add_timestamp(), ast_data_add_uint(), AST_DATA_BOOLEAN, AST_DATA_CHARACTER, AST_DATA_CONTAINER, AST_DATA_DOUBLE, AST_DATA_INTEGER, AST_DATA_IPADDR, AST_DATA_MILLISECONDS, AST_DATA_PASSWORD, AST_DATA_POINTER, AST_DATA_SECONDS, AST_DATA_STRING, AST_DATA_TIMESTAMP, AST_DATA_UNSIGNED_INTEGER, data_filter::name, and type.

02425 {
02426    int i;
02427 
02428    for (i = 0; i < mapping_len; i++) {
02429       switch (mapping[i].type) {
02430       case AST_DATA_INTEGER:
02431          ast_data_add_int(root, mapping[i].name,
02432             mapping[i].get.AST_DATA_INTEGER(structure));
02433          break;
02434       case AST_DATA_UNSIGNED_INTEGER:
02435          ast_data_add_uint(root, mapping[i].name,
02436             mapping[i].get.AST_DATA_UNSIGNED_INTEGER(structure));
02437          break;
02438       case AST_DATA_DOUBLE:
02439          ast_data_add_dbl(root, mapping[i].name,
02440             mapping[i].get.AST_DATA_DOUBLE(structure));
02441          break;
02442       case AST_DATA_BOOLEAN:
02443          ast_data_add_bool(root, mapping[i].name,
02444             mapping[i].get.AST_DATA_BOOLEAN(structure));
02445          break;
02446       case AST_DATA_PASSWORD:
02447          ast_data_add_password(root, mapping[i].name,
02448             mapping[i].get.AST_DATA_PASSWORD(structure));
02449          break;
02450       case AST_DATA_TIMESTAMP:
02451          ast_data_add_timestamp(root, mapping[i].name,
02452             mapping[i].get.AST_DATA_TIMESTAMP(structure));
02453          break;
02454       case AST_DATA_SECONDS:
02455          ast_data_add_seconds(root, mapping[i].name,
02456             mapping[i].get.AST_DATA_SECONDS(structure));
02457          break;
02458       case AST_DATA_MILLISECONDS:
02459          ast_data_add_milliseconds(root, mapping[i].name,
02460             mapping[i].get.AST_DATA_MILLISECONDS(structure));
02461          break;
02462       case AST_DATA_STRING:
02463          ast_data_add_str(root, mapping[i].name,
02464             mapping[i].get.AST_DATA_STRING(structure));
02465          break;
02466       case AST_DATA_CHARACTER:
02467          ast_data_add_char(root, mapping[i].name,
02468             mapping[i].get.AST_DATA_CHARACTER(structure));
02469          break;
02470       case AST_DATA_CONTAINER:
02471          break;
02472       case AST_DATA_IPADDR:
02473          ast_data_add_ipaddr(root, mapping[i].name,
02474             mapping[i].get.AST_DATA_IPADDR(structure));
02475          break;
02476       case AST_DATA_POINTER:
02477          ast_data_add_ptr(root, mapping[i].name,
02478             mapping[i].get.AST_DATA_POINTER(structure));
02479          break;
02480       }
02481    }
02482 
02483    return 0;
02484 }

int __ast_data_register ( const char *  path,
const struct ast_data_handler handler,
const char *  registrar,
struct ast_module mod 
)

Register a data provider.

Parameters:
[in] path The path of the node to register.
[in] handler The structure defining this node handler.
[in] registrar Who is registering this node.
[in] mod The module registering this handler.
See also:
ast_data_unregister
Return values:
<0 on error.
0 on success.
See also:
__ast_data_unregister, __ast_data_register_multiple

Definition at line 518 of file data.c.

References ao2_container_count(), ao2_ref, ast_log(), data_provider::children, data_provider_create(), data_structure_compatible(), data_unlock, data_write_lock, data_provider::handler, LOG_ERROR, data_provider::module, data_provider::name, root_data, and ast_data_handler::version.

Referenced by __ast_data_register_multiple().

00520 {
00521    struct data_provider *node;
00522 
00523    if (!path) {
00524       return -1;
00525    }
00526 
00527    /* check if the handler structure is compatible. */
00528    if (!data_structure_compatible(handler->version,
00529       latest_handler_compatible_version,
00530       current_handler_version)) {
00531       return -1;
00532    }
00533 
00534    /* create the node structure for the registered handler. */
00535    data_write_lock();
00536 
00537    node = data_provider_create(root_data.container, path, registrar);
00538    if (!node) {
00539       ast_log(LOG_ERROR, "Unable to create the specified path (%s) "
00540          "for '%s'.\n", path, registrar);
00541       data_unlock();
00542       return -1;
00543    }
00544 
00545    if (ao2_container_count(node->children) || node->handler) {
00546       ast_log(LOG_ERROR, "The node '%s' was already registered. "
00547          "We were unable to register '%s' for registrar '%s'.\n",
00548          node->name, path, registrar);
00549       ao2_ref(node, -1);
00550       data_unlock();
00551       return -1;
00552    }
00553 
00554    /* add handler to that node. */
00555    node->handler = handler;
00556    node->module = mod;
00557 
00558    ao2_ref(node, -1);
00559 
00560    data_unlock();
00561 
00562    return 0;
00563 }

int __ast_data_register_multiple ( const struct ast_data_entry data_entries,
size_t  entries,
const char *  registrar,
struct ast_module mod 
)

Register multiple data providers at once.

Parameters:
[in] data_entries An array of data_entries structures.
[in] entries The number of entries in the data_entries array.
[in] registrar Who is registering this nodes.
[in] mod The module registering this handlers.
Return values:
<0 on error (none of the nodes are being registered on error).
0 on success.
See also:
__ast_data_register, __ast_data_unregister

Definition at line 565 of file data.c.

References __ast_data_register(), __ast_data_unregister(), and data_provider::handler.

00567 {
00568    int i, res;
00569 
00570    for (i = 0; i < entries; i++) {
00571       res = __ast_data_register(data_entries[i].path, data_entries[i].handler,
00572             registrar, mod);
00573       if (res) {
00574          /* unregister all the already registered nodes, and make
00575           * this an atomic action. */
00576          while ((--i) >= 0) {
00577             __ast_data_unregister(data_entries[i].path, registrar);
00578          }
00579          return -1;
00580       }
00581    }
00582 
00583    return 0;
00584 }

int __ast_data_search_cmp_structure ( const struct ast_data_search search,
const struct ast_data_mapping_structure mapping,
size_t  mapping_len,
void *  structure,
const char *  structure_name 
)

Based on a search tree, evaluate every member of a structure against it.

Parameters:
[in] search The search tree.
[in] mapping The structure mapping.
[in] mapping_len The lenght of the structure mapping.
[in] structure The structure pointer.
[in] structure_name The name of the structure to compare.
Return values:
0 If the structure matches.
1 If the structure doesn't match.

Definition at line 1272 of file data.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_data_mapping_structure::AST_DATA_BOOLEAN, AST_DATA_BOOLEAN, ast_data_mapping_structure::AST_DATA_CHARACTER, AST_DATA_CHARACTER, AST_DATA_CONTAINER, ast_data_mapping_structure::AST_DATA_DOUBLE, AST_DATA_DOUBLE, ast_data_mapping_structure::AST_DATA_INTEGER, AST_DATA_INTEGER, ast_data_mapping_structure::AST_DATA_IPADDR, AST_DATA_IPADDR, ast_data_mapping_structure::AST_DATA_MILLISECONDS, AST_DATA_MILLISECONDS, ast_data_mapping_structure::AST_DATA_PASSWORD, AST_DATA_PASSWORD, ast_data_mapping_structure::AST_DATA_POINTER, AST_DATA_POINTER, ast_data_mapping_structure::AST_DATA_SECONDS, AST_DATA_SECONDS, ast_data_mapping_structure::AST_DATA_STRING, AST_DATA_STRING, ast_data_mapping_structure::AST_DATA_TIMESTAMP, AST_DATA_TIMESTAMP, ast_data_mapping_structure::AST_DATA_UNSIGNED_INTEGER, AST_DATA_UNSIGNED_INTEGER, ast_data_search::children, data_search_cmp_bool(), data_search_cmp_char(), data_search_cmp_dbl(), data_search_cmp_int(), data_search_cmp_ipaddr(), data_search_cmp_ptr(), data_search_cmp_string(), data_search_cmp_uint(), data_search_get_node(), data_search_mapping_find(), ast_data_mapping_structure::get, ast_data_search::name, and type.

01275 {
01276    struct ao2_iterator i;
01277    struct ast_data_search *node, *struct_children;
01278    int member, notmatch = 0;
01279 
01280    if (!search) {
01281       return 0;
01282    }
01283 
01284    struct_children = data_search_get_node(search, structure_name);
01285    if (!struct_children) {
01286       return 0;
01287    }
01288 
01289    i = ao2_iterator_init(struct_children->children, 0);
01290    while ((node = ao2_iterator_next(&i))) {
01291       member = data_search_mapping_find(mapping, mapping_len, node->name);
01292       if (member < 0) {
01293          /* the structure member name doesn't match! */
01294          ao2_ref(node, -1);
01295          ao2_ref(struct_children, -1);
01296          ao2_iterator_destroy(&i);
01297          return 0;
01298       }
01299 
01300       notmatch = 0;
01301       switch (mapping[member].type) {
01302       case AST_DATA_PASSWORD:
01303          notmatch = data_search_cmp_string(struct_children,
01304             node->name,
01305             mapping[member].get.AST_DATA_PASSWORD(structure));
01306          break;
01307       case AST_DATA_TIMESTAMP:
01308          notmatch = data_search_cmp_uint(struct_children,
01309             node->name,
01310             mapping[member].get.AST_DATA_TIMESTAMP(structure));
01311          break;
01312       case AST_DATA_SECONDS:
01313          notmatch = data_search_cmp_uint(struct_children,
01314             node->name,
01315             mapping[member].get.AST_DATA_SECONDS(structure));
01316          break;
01317       case AST_DATA_MILLISECONDS:
01318          notmatch = data_search_cmp_uint(struct_children,
01319             node->name,
01320             mapping[member].get.AST_DATA_MILLISECONDS(structure));
01321          break;
01322       case AST_DATA_STRING:
01323          notmatch = data_search_cmp_string(struct_children,
01324             node->name,
01325             mapping[member].get.AST_DATA_STRING(structure));
01326          break;
01327       case AST_DATA_CHARACTER:
01328          notmatch = data_search_cmp_char(struct_children,
01329             node->name,
01330             mapping[member].get.AST_DATA_CHARACTER(structure));
01331          break;
01332       case AST_DATA_INTEGER:
01333          notmatch = data_search_cmp_int(struct_children,
01334             node->name,
01335             mapping[member].get.AST_DATA_INTEGER(structure));
01336          break;
01337       case AST_DATA_BOOLEAN:
01338          notmatch = data_search_cmp_bool(struct_children,
01339             node->name,
01340             mapping[member].get.AST_DATA_BOOLEAN(structure));
01341          break;
01342       case AST_DATA_UNSIGNED_INTEGER:
01343          notmatch = data_search_cmp_uint(struct_children,
01344             node->name,
01345             mapping[member].get.AST_DATA_UNSIGNED_INTEGER(structure));
01346          break;
01347       case AST_DATA_DOUBLE:
01348          notmatch = data_search_cmp_dbl(struct_children,
01349             node->name,
01350             mapping[member].get.AST_DATA_DOUBLE(structure));
01351          break;
01352       case AST_DATA_IPADDR:
01353          notmatch = data_search_cmp_ipaddr(struct_children,
01354             node->name,
01355             mapping[member].get.AST_DATA_IPADDR(structure));
01356          break;
01357       case AST_DATA_POINTER:
01358          notmatch = data_search_cmp_ptr(struct_children,
01359             node->name,
01360             mapping[member].get.AST_DATA_POINTER(structure));
01361          break;
01362       case AST_DATA_CONTAINER:
01363          break;
01364       }
01365 
01366       ao2_ref(node, -1);
01367    }
01368    ao2_iterator_destroy(&i);
01369 
01370    ao2_ref(struct_children, -1);
01371 
01372    return notmatch;
01373 }

int __ast_data_unregister ( const char *  path,
const char *  registrar 
)

Unregister a data provider.

Parameters:
[in] path Which node to unregister, if path is NULL unregister every node registered by the passed 'registrar'.
[in] registrar Who is trying to unregister this node, only the owner (the one who registered the node) will be able to unregister it.
See also:
ast_data_register
Return values:
<0 on error.
0 on success.
See also:
__ast_data_register, __ast_data_register_multiple

Definition at line 586 of file data.c.

References ast_log(), data_provider_release(), data_provider_release_all(), data_unlock, data_write_lock, LOG_ERROR, and root_data.

Referenced by __ast_data_register_multiple().

00587 {
00588    int ret = 0;
00589 
00590    data_write_lock();
00591    if (path) {
00592       ret = data_provider_release(root_data.container, path, registrar);
00593    } else {
00594       data_provider_release_all(root_data.container, registrar);
00595    }
00596    data_unlock();
00597 
00598    if (path && ret) {
00599       ast_log(LOG_ERROR, "Unable to unregister '%s' for '%s'\n",
00600          path, registrar);
00601    }
00602 
00603    return ret;
00604 }

static void __data_result_print_cli ( int  fd,
const struct ast_data root,
uint32_t  depth 
) [static]

Definition at line 2819 of file data.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, AST_DATA_CONTAINER, ast_data::children, data_result_print_cli_node(), and ast_data::type.

Referenced by data_result_print_cli(), and data_result_print_cli_node().

02820 {
02821    struct ao2_iterator iter;
02822    struct ast_data *node;
02823 
02824    if (root->type == AST_DATA_CONTAINER) {
02825       iter = ao2_iterator_init(root->children, 0);
02826       while ((node = ao2_iterator_next(&iter))) {
02827          data_result_print_cli_node(fd, node, depth + 1);
02828          ao2_ref(node, -1);
02829       }
02830       ao2_iterator_destroy(&iter);
02831    } else {
02832       data_result_print_cli_node(fd, root, depth);
02833    }
02834 }

struct ast_data* ast_data_add_bool ( struct ast_data root,
const char *  childname,
unsigned int  boolean 
) [read]

Add a boolean node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] boolean The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2344 of file data.c.

References __ast_data_add(), and AST_DATA_BOOLEAN.

Referenced by __ast_data_add_structure(), agents_data_provider_get(), ast_channel_data_add_structure(), channel_data_add_flags(), dahdi_status_data_provider_get(), data_channeltypes_provider_handler(), data_odbc_provider_handler(), peers_data_provider_get(), and users_data_provider_get().

02346 {
02347    return __ast_data_add(root, childname, AST_DATA_BOOLEAN, &boolean);
02348 }

struct ast_data* ast_data_add_char ( struct ast_data root,
const char *  childname,
char  value 
) [read]

Add a char node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] value The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2327 of file data.c.

References __ast_data_add(), and AST_DATA_CHARACTER.

Referenced by __ast_data_add_structure().

02328 {
02329    return __ast_data_add(root, name, AST_DATA_CHARACTER, &value);
02330 }

int ast_data_add_codecs ( struct ast_data root,
const char *  node_name,
format_t  capability 
)

Add the list of codecs in the root node based on the capability parameter.

Parameters:
[in] root The astdata root node where to add the codecs node.
[in] node_name The name of the node where we are going to add the list of codecs.
[in] capability The codecs allowed.
Returns:
< 0 on error.
0 on success.

Definition at line 3112 of file data.c.

References ast_data_add_int(), ast_data_add_node(), ast_data_add_str(), ast_get_format_list(), ast_format_list::bits, desc, ast_format_list::fr_len, data_filter::name, and ast_format_list::samplespersecond.

Referenced by ast_channel_data_add_structure(), data_channeltypes_provider_handler(), peers_data_provider_get(), and users_data_provider_get().

03113 {
03114    struct ast_data *codecs, *codec;
03115    size_t fmlist_size;
03116    const struct ast_format_list *fmlist;
03117    int x;
03118 
03119    codecs = ast_data_add_node(root, node_name);
03120    if (!codecs) {
03121       return -1;
03122    }
03123    fmlist = ast_get_format_list(&fmlist_size);
03124    for (x = 0; x < fmlist_size; x++) {
03125       if (fmlist[x].bits & capability) {
03126          codec = ast_data_add_node(codecs, "codec");
03127          if (!codec) {
03128             return -1;
03129          }
03130          ast_data_add_str(codec, "name", fmlist[x].name);
03131          ast_data_add_int(codec, "samplespersecond", fmlist[x].samplespersecond);
03132          ast_data_add_str(codec, "description", fmlist[x].desc);
03133          ast_data_add_int(codec, "frame_length", fmlist[x].fr_len);
03134       }
03135    }
03136 
03137    return 0;
03138 }

struct ast_data* ast_data_add_dbl ( struct ast_data root,
const char *  childname,
double  dbl 
) [read]

Add a floating point node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] dbl The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2338 of file data.c.

References __ast_data_add(), and AST_DATA_DOUBLE.

Referenced by __ast_data_add_structure().

02340 {
02341    return __ast_data_add(root, childname, AST_DATA_DOUBLE, &dbl);
02342 }

struct ast_data* ast_data_add_int ( struct ast_data root,
const char *  childname,
int  value 
) [read]

Add an integer node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] value The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2322 of file data.c.

References __ast_data_add(), and AST_DATA_INTEGER.

Referenced by __ast_data_add_structure(), ast_cdr_data_add_structure(), ast_channel_data_add_structure(), ast_data_add_codecs(), dahdi_status_data_provider_get(), data_odbc_provider_handler(), hints_data_provider_get(), peers_data_provider_get(), queues_data_provider_get_helper(), user_add_provider_cb(), users_data_provider_get(), and vm_users_data_provider_get_helper().

02323 {
02324    return __ast_data_add(root, name, AST_DATA_INTEGER, &value);
02325 }

struct ast_data* ast_data_add_ipaddr ( struct ast_data root,
const char *  childname,
struct in_addr  addr 
) [read]

Add a ipv4 address type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] addr The ipv4 address value.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2350 of file data.c.

References __ast_data_add(), and AST_DATA_IPADDR.

Referenced by __ast_data_add_structure().

02352 {
02353    return __ast_data_add(root, childname, AST_DATA_IPADDR, &addr);
02354 }

struct ast_data* ast_data_add_milliseconds ( struct ast_data root,
const char *  childname,
unsigned int  milliseconds 
) [read]

Add a milliseconds node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] milliseconds The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2374 of file data.c.

References __ast_data_add(), and AST_DATA_MILLISECONDS.

Referenced by __ast_data_add_structure().

02376 {
02377    return __ast_data_add(root, childname, AST_DATA_MILLISECONDS, &milliseconds);
02378 }

struct ast_data* ast_data_add_node ( struct ast_data root,
const char *  childname 
) [read]
struct ast_data* ast_data_add_password ( struct ast_data root,
const char *  childname,
const char *  string 
) [read]

Add a password node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] string The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2380 of file data.c.

References __ast_data_add(), AST_DATA_PASSWORD, ast_free, ast_malloc, ast_strlen_zero(), and data_filter::name.

Referenced by __ast_data_add_structure(), and users_data_provider_get().

02382 {
02383    char *name;
02384    size_t namelen = 1 + (ast_strlen_zero(value) ? 0 : strlen(value));
02385    struct ast_data *res;
02386 
02387    if (!(name = ast_malloc(namelen))) {
02388       return NULL;
02389    }
02390 
02391    strcpy(name, (ast_strlen_zero(value) ? "" : value));
02392 
02393    res = __ast_data_add(root, childname, AST_DATA_PASSWORD, name);
02394    if (!res) {
02395       ast_free(name);
02396    }
02397 
02398    return res;
02399 }

struct ast_data* ast_data_add_ptr ( struct ast_data root,
const char *  childname,
void *  ptr 
) [read]

Add a ptr node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] ptr The pointer value to add.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2356 of file data.c.

References __ast_data_add(), and AST_DATA_POINTER.

Referenced by __ast_data_add_structure().

02358 {
02359    return __ast_data_add(root, childname, AST_DATA_POINTER, ptr);
02360 }

struct ast_data* ast_data_add_seconds ( struct ast_data root,
const char *  childname,
unsigned int  seconds 
) [read]

Add a seconds node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] seconds The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2368 of file data.c.

References __ast_data_add(), and AST_DATA_SECONDS.

Referenced by __ast_data_add_structure().

02370 {
02371    return __ast_data_add(root, childname, AST_DATA_SECONDS, &seconds);
02372 }

struct ast_data* ast_data_add_str ( struct ast_data root,
const char *  childname,
const char *  string 
) [read]

Add a string node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] string The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2401 of file data.c.

References __ast_data_add(), AST_DATA_STRING, ast_free, ast_malloc, ast_strlen_zero(), and data_filter::name.

Referenced by __ast_data_add_structure(), agents_data_provider_get(), ast_cdr_data_add_structure(), ast_channel_data_add_structure(), ast_data_add_codecs(), dahdi_status_data_provider_get(), dahdi_version_data_provider_get(), data_channeltypes_provider_handler(), data_odbc_provider_handler(), hints_data_provider_get(), peers_data_provider_get(), queues_data_provider_get_helper(), and users_data_provider_get().

02403 {
02404    char *name;
02405    size_t namelen = 1 + (ast_strlen_zero(value) ? 0 : strlen(value));
02406    struct ast_data *res;
02407 
02408    if (!(name = ast_malloc(namelen))) {
02409       return NULL;
02410    }
02411 
02412    strcpy(name, (ast_strlen_zero(value) ? "" : value));
02413 
02414    res = __ast_data_add(root, childname, AST_DATA_STRING, name);
02415    if (!res) {
02416       ast_free(name);
02417    }
02418 
02419    return res;
02420 }

struct ast_data* ast_data_add_timestamp ( struct ast_data root,
const char *  childname,
unsigned int  timestamp 
) [read]

Add a timestamp node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] timestamp The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2362 of file data.c.

References __ast_data_add(), and AST_DATA_TIMESTAMP.

Referenced by __ast_data_add_structure().

02364 {
02365    return __ast_data_add(root, childname, AST_DATA_TIMESTAMP, &timestamp);
02366 }

struct ast_data* ast_data_add_uint ( struct ast_data root,
const char *  childname,
unsigned int  value 
) [read]

Add an unsigned integer node type.

Parameters:
[in] root The root of the ast_data to insert into.
[in] childname The name of the child element to be added.
[in] value The value for the new node.
Return values:
NULL on error (memory exhaustion only).
non-NULL a newly allocated node.

Definition at line 2332 of file data.c.

References __ast_data_add(), and AST_DATA_UNSIGNED_INTEGER.

Referenced by __ast_data_add_structure(), and ast_channel_data_add_structure().

02334 {
02335    return __ast_data_add(root, name, AST_DATA_UNSIGNED_INTEGER, &value);
02336 }

void ast_data_free ( struct ast_data root  ) 

Release the allocated memory of a tree.

Parameters:
[in] root The sub-tree pointer returned by a call to ast_data_get.
See also:
ast_data_get

Definition at line 2491 of file data.c.

References ao2_ref.

Referenced by ast_data_get_xml(), handle_cli_data_get(), and manager_data_get().

02492 {
02493    /* destroy it, this will destroy all the internal nodes. */
02494    ao2_ref(root, -1);
02495 }

struct ast_data* ast_data_get ( const struct ast_data_query query  )  [read]

Retrieve a subtree from the asterisk data API.

Parameters:
[in] query The query structure specifying what nodes to retrieve.
Return values:
NULL on error.
non-NULL The dynamically allocated requested sub-tree (it needs to be released using ast_data_free.
See also:
ast_data_free, ast_data_get_xml

Definition at line 2065 of file data.c.

References ast_log(), data_read_lock, data_result_generate(), data_structure_compatible(), data_unlock, LOG_ERROR, ast_data_query::path, and ast_data_query::version.

Referenced by ast_data_get_xml(), handle_cli_data_get(), and manager_data_get().

02066 {
02067    struct ast_data *res;
02068 
02069    /* check compatibility */
02070    if (!data_structure_compatible(query->version, latest_query_compatible_version,
02071       current_query_version)) {
02072       return NULL;
02073    }
02074 
02075    data_read_lock();
02076    res = data_result_generate(query, query->path);
02077    data_unlock();
02078 
02079    if (!res) {
02080       ast_log(LOG_ERROR, "Unable to get data from %s\n", query->path);
02081       return NULL;
02082    }
02083 
02084    return res;
02085 }

struct ast_xml_doc* ast_data_get_xml ( const struct ast_data_query query  )  [read]

Retrieve a subtree from the asterisk data API in XML format..

Parameters:
[in] query The query structure specifying what nodes to retrieve.
Return values:
NULL on error.
non-NULL The dynamically allocated requested sub-tree (it needs to be released using ast_data_free.
See also:
ast_data_free, ast_data_get

Definition at line 2181 of file data.c.

References ast_data_free(), ast_data_get(), ast_xml_close(), ast_xml_new(), ast_xml_new_node(), ast_xml_set_root(), data_get_xml_add_child(), and ast_data::name.

02182 {
02183    struct ast_xml_doc *doc;
02184    struct ast_xml_node *root;
02185    struct ast_data *res;
02186 
02187    res = ast_data_get(query);
02188    if (!res) {
02189       return NULL;
02190    }
02191 
02192    doc = ast_xml_new();
02193    if (!doc) {
02194       ast_data_free(res);
02195       return NULL;
02196    }
02197 
02198    root = ast_xml_new_node(res->name);
02199    if (!root) {
02200       ast_xml_close(doc);
02201    }
02202 
02203    ast_xml_set_root(doc, root);
02204 
02205    data_get_xml_add_child(res, root);
02206 
02207    ast_data_free(res);
02208 
02209    return doc;
02210 }

int ast_data_init ( void   ) 

Provided by data.c

Definition at line 3297 of file data.c.

References ao2_container_alloc, ARRAY_LEN, ast_cli_register_multiple(), ast_manager_register_xml, ast_register_atexit(), ast_rwlock_init, AST_TEST_REGISTER, cli_data, data_provider_cmp(), data_provider_hash(), data_shutdown(), manager_data_get(), NUM_DATA_NODE_BUCKETS, and root_data.

Referenced by main().

03298 {
03299    int res = 0;
03300 
03301    ast_rwlock_init(&root_data.lock);
03302 
03303    if (!(root_data.container = ao2_container_alloc(NUM_DATA_NODE_BUCKETS,
03304       data_provider_hash, data_provider_cmp))) {
03305       return -1;
03306    }
03307 
03308    res |= ast_cli_register_multiple(cli_data, ARRAY_LEN(cli_data));
03309 
03310    res |= ast_manager_register_xml("DataGet", 0, manager_data_get);
03311 
03312    AST_TEST_REGISTER(test_data_get);
03313 
03314    ast_register_atexit(data_shutdown);
03315 
03316    return res;
03317 }

void ast_data_iterator_end ( struct ast_data_iterator iterator  ) 

Release (stop using) an iterator.

Parameters:
[in] iterator The iterator created by ast_data_iterator_start.
See also:
ast_data_iterator_start

Definition at line 2542 of file data.c.

References ao2_iterator_destroy(), ao2_ref, ast_free, ast_data_iterator::internal_iterator, ast_data_iterator::is_pattern, ast_data_iterator::last, and ast_data_iterator::regex_pattern.

02543 {
02544    /* decrement the reference counter. */
02545    if (iterator->last) {
02546       ao2_ref(iterator->last, -1);
02547    }
02548 
02549    /* release the generated pattern. */
02550    if (iterator->is_pattern) {
02551       regfree(&(iterator->regex_pattern));
02552    }
02553 
02554    ao2_iterator_destroy(&(iterator->internal_iterator));
02555 
02556    ast_free(iterator);
02557    iterator = NULL;
02558 }

struct ast_data_iterator* ast_data_iterator_init ( struct ast_data tree,
const char *  elements 
) [read]

Initialize an iterator.

Parameters:
[in] tree The returned tree by a call to ast_data_get.
[in] elements Which elements to iterate through.
Return values:
NULL on error.
non-NULL A dinamically allocated iterator structure.

Definition at line 2497 of file data.c.

References ao2_iterator_init(), ast_calloc, ast_strdupa, data_result_get_node(), ast_data_iterator::internal_iterator, ast_data_iterator::is_pattern, ast_data_iterator::pattern, ast_data::ptr, and ast_data_iterator::regex_pattern.

02499 {
02500    struct ast_data_iterator *iterator;
02501    struct ao2_iterator i;
02502    struct ast_data *internal = tree;
02503    char *path, *ptr = NULL;
02504 
02505    if (!elements) {
02506       return NULL;
02507    }
02508 
02509    /* tree is the node we want to use to iterate? or we are going
02510     * to iterate thow an internal node? */
02511    path = ast_strdupa(elements);
02512 
02513    ptr = strrchr(path, '/');
02514    if (ptr) {
02515       *ptr = '\0';
02516       internal = data_result_get_node(tree, path);
02517       if (!internal) {
02518          return NULL;
02519       }
02520    }
02521 
02522    iterator = ast_calloc(1, sizeof(*iterator));
02523    if (!iterator) {
02524       return NULL;
02525    }
02526 
02527    i = ao2_iterator_init(internal->children, 0);
02528 
02529    iterator->pattern = (ptr ? strrchr(elements, '/') + 1 : elements);
02530 
02531    /* is the last node a regular expression?, compile it! */
02532    if (!regcomp(&(iterator->regex_pattern), iterator->pattern,
02533          REG_EXTENDED | REG_NOSUB | REG_ICASE)) {
02534       iterator->is_pattern = 1;
02535    }
02536 
02537    iterator->internal_iterator = i;
02538 
02539    return iterator;
02540 }

struct ast_data* ast_data_iterator_next ( struct ast_data_iterator iterator  )  [read]

Get the next node of the tree.

Parameters:
[in] iterator The iterator structure returned by ast_data_iterator_start.
Return values:
NULL when no more nodes to return.
non-NULL A node of the ast_data tree.
See also:
ast_data_iterator_start, ast_data_iterator_stop

Definition at line 2560 of file data.c.

References ao2_iterator_next, ao2_ref, ast_data_iterator::internal_iterator, ast_data_iterator::is_pattern, ast_data_iterator::last, ast_data::name, ast_data_iterator::pattern, and ast_data_iterator::regex_pattern.

02561 {
02562    struct ast_data *res;
02563 
02564    if (iterator->last) {
02565       /* release the last retrieved node reference. */
02566       ao2_ref(iterator->last, -1);
02567    }
02568 
02569    while ((res = ao2_iterator_next(&iterator->internal_iterator))) {
02570       /* if there is no node name pattern specified, return
02571        * the next node. */
02572       if (!iterator->pattern) {
02573          break;
02574       }
02575 
02576       /* if the pattern is a regular expression, check if this node
02577        * matches. */
02578       if (iterator->is_pattern && !regexec(&(iterator->regex_pattern),
02579          res->name, 0, NULL, 0)) {
02580          break;
02581       }
02582 
02583       /* if there is a pattern specified, check if this node matches
02584        * the wanted node names. */
02585       if (!iterator->is_pattern && (iterator->pattern &&
02586             !strcasecmp(res->name, iterator->pattern))) {
02587          break;
02588       }
02589 
02590       ao2_ref(res, -1);
02591    }
02592 
02593    iterator->last = res;
02594 
02595    return res;
02596 }

void ast_data_remove_node ( struct ast_data root,
struct ast_data child 
)

Remove a node that was added using ast_data_add_.

Parameters:
[in] root The root node of the node to be removed.
[in] child The node pointer to remove.

Definition at line 2486 of file data.c.

References ao2_unlink, and ast_data::children.

Referenced by agents_data_provider_get(), dahdi_channels_data_provider_get(), dahdi_status_data_provider_get(), data_channels_provider_handler(), data_channeltypes_provider_handler(), data_odbc_provider_handler(), hints_data_provider_get(), meetme_data_provider_get(), peers_data_provider_get(), queues_data_provider_get_helper(), users_data_provider_get(), and vm_users_data_provider_get_helper().

02487 {
02488    ao2_unlink(root->children, child);
02489 }

int ast_data_retrieve ( struct ast_data tree,
const char *  path,
struct ast_data_retrieve content 
)

Retrieve a value from a node in the tree.

Parameters:
[in] tree The structure returned by a call to ast_data_get.
[in] path The path to the node.
[out] content The node content.
Return values:
0 on success.
<0 on error.

Definition at line 2598 of file data.c.

References ast_data_retrieve::AST_DATA_BOOLEAN, AST_DATA_BOOLEAN, ast_data_retrieve::AST_DATA_CHARACTER, AST_DATA_CHARACTER, AST_DATA_CONTAINER, ast_data_retrieve::AST_DATA_DOUBLE, AST_DATA_DOUBLE, ast_data_retrieve::AST_DATA_INTEGER, AST_DATA_INTEGER, ast_data_retrieve::AST_DATA_IPADDR, AST_DATA_IPADDR, ast_data_retrieve::AST_DATA_MILLISECONDS, AST_DATA_MILLISECONDS, ast_data_retrieve::AST_DATA_PASSWORD, AST_DATA_PASSWORD, ast_data_retrieve::AST_DATA_POINTER, AST_DATA_POINTER, ast_data_retrieve::AST_DATA_SECONDS, AST_DATA_SECONDS, ast_data_retrieve::AST_DATA_STRING, AST_DATA_STRING, ast_data_retrieve::AST_DATA_TIMESTAMP, AST_DATA_TIMESTAMP, ast_data_retrieve::AST_DATA_UNSIGNED_INTEGER, AST_DATA_UNSIGNED_INTEGER, ast_log(), ast_data::boolean, ast_data::character, data_result_get_node(), ast_data::dbl, ast_data::ipaddr, LOG_ERROR, ast_data::payload, ast_data::ptr, ast_data::sint, ast_data::str, ast_data::type, ast_data_retrieve::type, ast_data::uint, and ast_data_retrieve::value.

Referenced by ast_data_retrieve_bool(), ast_data_retrieve_char(), ast_data_retrieve_dbl(), ast_data_retrieve_int(), ast_data_retrieve_ipaddr(), ast_data_retrieve_password(), ast_data_retrieve_ptr(), ast_data_retrieve_string(), and ast_data_retrieve_uint().

02600 {
02601    struct ast_data *node;
02602 
02603    if (!content) {
02604       return -1;
02605    }
02606 
02607    node = data_result_get_node(tree, path);
02608    if (!node) {
02609       ast_log(LOG_ERROR, "Invalid internal node %s\n", path);
02610       return -1;
02611    }
02612 
02613    content->type = node->type;
02614    switch (node->type) {
02615    case AST_DATA_STRING:
02616       content->value.AST_DATA_STRING = node->payload.str;
02617       break;
02618    case AST_DATA_PASSWORD:
02619       content->value.AST_DATA_PASSWORD = node->payload.str;
02620       break;
02621    case AST_DATA_TIMESTAMP:
02622       content->value.AST_DATA_TIMESTAMP = node->payload.uint;
02623       break;
02624    case AST_DATA_SECONDS:
02625       content->value.AST_DATA_SECONDS = node->payload.uint;
02626       break;
02627    case AST_DATA_MILLISECONDS:
02628       content->value.AST_DATA_MILLISECONDS = node->payload.uint;
02629       break;
02630    case AST_DATA_CHARACTER:
02631       content->value.AST_DATA_CHARACTER = node->payload.character;
02632       break;
02633    case AST_DATA_INTEGER:
02634       content->value.AST_DATA_INTEGER = node->payload.sint;
02635       break;
02636    case AST_DATA_UNSIGNED_INTEGER:
02637       content->value.AST_DATA_UNSIGNED_INTEGER = node->payload.uint;
02638       break;
02639    case AST_DATA_BOOLEAN:
02640       content->value.AST_DATA_BOOLEAN = node->payload.boolean;
02641       break;
02642    case AST_DATA_IPADDR:
02643       content->value.AST_DATA_IPADDR = node->payload.ipaddr;
02644       break;
02645    case AST_DATA_DOUBLE:
02646       content->value.AST_DATA_DOUBLE = node->payload.dbl;
02647       break;
02648    case AST_DATA_CONTAINER:
02649       break;
02650    case AST_DATA_POINTER:
02651       content->value.AST_DATA_POINTER = node->payload.ptr;
02652       break;
02653    }
02654 
02655    return 0;
02656 }

char* ast_data_retrieve_name ( struct ast_data node  ) 

Get the node name.

Parameters:
[in] node The node pointer.
Returns:
The node name.

Definition at line 2225 of file data.c.

References ast_data::name.

02226 {
02227    return node->name;
02228 }

enum ast_data_type ast_data_retrieve_type ( struct ast_data res,
const char *  path 
)

Get a node type.

Parameters:
[in] res A pointer to the ast_data result set.
[in] path A path to the node to get the type.
Returns:
The type of the requested node type.

Definition at line 2213 of file data.c.

References data_result_get_node().

02214 {
02215    struct ast_data *internal;
02216 
02217    internal = data_result_get_node(node, path);
02218    if (!internal) {
02219       return -1;
02220    }
02221 
02222    return internal->type;
02223 }

int ast_data_search_match ( const struct ast_data_search search,
struct ast_data data 
)

Check the current generated node to know if it matches the search condition.

Parameters:
[in] search The search condition.
[in] data The AstData node generated.
Returns:
1 If the "data" node matches the search condition.
0 If the "data" node does not matches the search condition.
See also:
ast_data_remove_node

Definition at line 1458 of file data.c.

References ao2_container_count(), ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, AST_DATA_BOOLEAN, AST_DATA_CHARACTER, AST_DATA_CONTAINER, AST_DATA_DOUBLE, AST_DATA_INTEGER, AST_DATA_IPADDR, AST_DATA_MILLISECONDS, AST_DATA_PASSWORD, AST_DATA_POINTER, ast_data_search_match(), AST_DATA_SECONDS, AST_DATA_STRING, AST_DATA_TIMESTAMP, AST_DATA_UNSIGNED_INTEGER, ast_data::boolean, ast_data::character, ast_data::children, ast_data_search::children, data_result_find_child(), data_search_cmp_bool(), data_search_cmp_char(), data_search_cmp_int(), data_search_cmp_ipaddr(), data_search_cmp_ptr(), data_search_cmp_string(), data_search_cmp_uint(), data_search_find(), ast_data::dbl, ast_data::ipaddr, ast_data_search::name, ast_data::name, ast_data::payload, ast_data::ptr, ast_data::sint, ast_data::str, ast_data::type, and ast_data::uint.

Referenced by agents_data_provider_get(), ast_data_search_match(), dahdi_channels_data_provider_get(), dahdi_status_data_provider_get(), data_channels_provider_handler(), data_channeltypes_provider_handler(), data_odbc_provider_handler(), hints_data_provider_get(), meetme_data_provider_get(), peers_data_provider_get(), queues_data_provider_get_helper(), users_data_provider_get(), and vm_users_data_provider_get_helper().

01459 {
01460    struct ao2_iterator i, ii;
01461    struct ast_data_search *s, *s_child;
01462    struct ast_data *d_child;
01463    int notmatch = 1;
01464 
01465    if (!search) {
01466       return 1;
01467    }
01468 
01469    s_child = data_search_find(search->children, data->name);
01470    if (!s_child) {
01471       /* nothing to compare */
01472       ao2_ref(s_child, -1);
01473       return 1;
01474    }
01475 
01476    i = ao2_iterator_init(s_child->children, 0);
01477    while ((s = ao2_iterator_next(&i))) {
01478       if (!ao2_container_count(s->children)) {
01479          /* compare this search node with every data node */
01480          d_child = data_result_find_child(data, s->name);
01481          if (!d_child) {
01482             ao2_ref(s, -1);
01483             notmatch = 1;
01484             continue;
01485          }
01486 
01487          switch (d_child->type) {
01488          case AST_DATA_PASSWORD:
01489          case AST_DATA_STRING:
01490             notmatch = data_search_cmp_string(s_child, d_child->name,
01491                d_child->payload.str);
01492             break;
01493          case AST_DATA_CHARACTER:
01494             notmatch = data_search_cmp_char(s_child, d_child->name,
01495                d_child->payload.character);
01496             break;
01497          case AST_DATA_INTEGER:
01498             notmatch = data_search_cmp_int(s_child, d_child->name,
01499                d_child->payload.sint);
01500             break;
01501          case AST_DATA_BOOLEAN:
01502             notmatch = data_search_cmp_bool(s_child, d_child->name,
01503                d_child->payload.boolean);
01504             break;
01505          case AST_DATA_UNSIGNED_INTEGER:
01506             notmatch = data_search_cmp_uint(s_child, d_child->name,
01507                d_child->payload.uint);
01508             break;
01509          case AST_DATA_TIMESTAMP:
01510          case AST_DATA_SECONDS:
01511          case AST_DATA_MILLISECONDS:
01512          case AST_DATA_DOUBLE:
01513             notmatch = data_search_cmp_uint(s_child, d_child->name,
01514                d_child->payload.dbl);
01515             break;
01516          case AST_DATA_IPADDR:
01517             notmatch = data_search_cmp_ipaddr(s_child, d_child->name,
01518                d_child->payload.ipaddr);
01519             break;
01520          case AST_DATA_POINTER:
01521             notmatch = data_search_cmp_ptr(s_child, d_child->name,
01522                d_child->payload.ptr);
01523             break;
01524          case AST_DATA_CONTAINER:
01525             break;
01526          }
01527          ao2_ref(d_child, -1);
01528       } else {
01529          ii = ao2_iterator_init(data->children, 0);
01530          while ((d_child = ao2_iterator_next(&ii))) {
01531             if (strcmp(d_child->name, s->name)) {
01532                ao2_ref(d_child, -1);
01533                continue;
01534             }
01535             if (!(notmatch = !ast_data_search_match(s_child, d_child))) {
01536                /* do not continue if we have a match. */
01537                ao2_ref(d_child, -1);
01538                break;
01539             }
01540             ao2_ref(d_child, -1);
01541          }
01542          ao2_iterator_destroy(&ii);
01543       }
01544       ao2_ref(s, -1);
01545       if (notmatch) {
01546          /* do not continue if we don't have a match. */
01547          break;
01548       }
01549    }
01550    ao2_iterator_destroy(&i);
01551 
01552    ao2_ref(s_child, -1);
01553 
01554    return !notmatch;
01555 }

static struct data_filter* data_filter_add_child ( struct ao2_container root,
char *  name 
) [static, read]

Definition at line 1780 of file data.c.

References ao2_link, data_filter_alloc(), and data_filter_find().

Referenced by data_filter_add_nodes().

01782 {
01783    struct data_filter *node;
01784 
01785    node = data_filter_find(root, name);
01786    if (node) {
01787       return node;
01788    }
01789 
01790    node = data_filter_alloc(name);
01791    if (!node) {
01792       return NULL;
01793    }
01794 
01795    ao2_link(root, node);
01796 
01797    return node;
01798 }

static int data_filter_add_nodes ( struct ao2_container root,
char *  path 
) [static]

Definition at line 1808 of file data.c.

References ao2_ref, ast_strdupa, data_filter::children, data_filter_add_child(), and next_node_name().

Referenced by data_filter_generate().

01809 {
01810    struct data_filter *node;
01811    char *savepath, *saveptr, *token, *node_name;
01812    int ret = 0;
01813 
01814    if (!path) {
01815       return 0;
01816    }
01817 
01818    savepath = ast_strdupa(path);
01819 
01820    node_name = next_node_name(&savepath);
01821 
01822    if (!node_name) {
01823       return 0;
01824    }
01825 
01826    for (token = strtok_r(node_name, "|", &saveptr);
01827          token; token = strtok_r(NULL, "|", &saveptr)) {
01828       node = data_filter_add_child(root, token);
01829       if (!node) {
01830          continue;
01831       }
01832       data_filter_add_nodes(node->children, savepath);
01833       ret = 1;
01834       ao2_ref(node, -1);
01835    }
01836 
01837    return ret;
01838 }

static struct data_filter* data_filter_alloc ( const char *  name  )  [static, read]

Definition at line 1647 of file data.c.

References ao2_alloc, ao2_container_alloc, ao2_ref, AST_LIST_INSERT_TAIL, ast_strdupa, data_filter::children, data_filter_cmp(), data_filter_destructor(), data_filter_hash(), data_filter::glob_list, data_filter::list, data_filter::name, and NUM_DATA_FILTER_BUCKETS.

Referenced by data_filter_add_child(), data_filter_find(), and data_filter_generate().

01648 {
01649    char *globname, *token;
01650    struct data_filter *res, *globfilter;
01651    size_t name_len = strlen(name) + 1;
01652 
01653    res = ao2_alloc(sizeof(*res) + name_len, data_filter_destructor);
01654    if (!res) {
01655       return NULL;
01656    }
01657 
01658    res->children = ao2_container_alloc(NUM_DATA_FILTER_BUCKETS, data_filter_hash,
01659       data_filter_cmp);
01660 
01661    if (!res) {
01662       ao2_ref(res, -1);
01663       return NULL;
01664    }
01665 
01666    strcpy(res->name, name);
01667 
01668    if (strchr(res->name, '*')) {
01669       globname = ast_strdupa(res->name);
01670 
01671       while ((token = strsep(&globname, "*"))) {
01672          globfilter = data_filter_alloc(token);
01673          AST_LIST_INSERT_TAIL(&(res->glob_list), globfilter, list);
01674       }
01675    }
01676 
01677    return res;
01678 }

static int data_filter_cmp ( void *  obj,
void *  arg,
int  flags 
) [static]

Definition at line 1619 of file data.c.

References CMP_MATCH, and data_filter::name.

Referenced by data_filter_alloc().

01620 {
01621    struct data_filter *node1 = obj, *node2 = arg;
01622    return strcasecmp(node1->name, node2->name) ? 0 : CMP_MATCH;
01623 }

static void data_filter_destructor ( void *  obj  )  [static]

Definition at line 1630 of file data.c.

References ao2_ref, AST_LIST_REMOVE_HEAD, data_filter::children, filter(), data_filter::glob_list, and data_filter::list.

Referenced by data_filter_alloc().

01631 {
01632    struct data_filter *filter = obj, *globres;
01633 
01634    while ((globres = AST_LIST_REMOVE_HEAD(&(filter->glob_list), list))) {
01635       ao2_ref(globres, -1);
01636    }
01637 
01638    ao2_ref(filter->children, -1);
01639 }

static struct data_filter* data_filter_find ( struct ao2_container parent,
const char *  name 
) [static, read]

Definition at line 1699 of file data.c.

References ao2_find, ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, AST_LIST_EMPTY, AST_LIST_FIRST, AST_LIST_LAST, AST_LIST_TRAVERSE, ast_strlen_zero(), data_filter_alloc(), data_filter::glob_list, data_filter::list, data_filter::name, and OBJ_POINTER.

Referenced by __ast_data_add(), data_filter_add_child(), data_result_generate(), and data_result_generate_node().

01701 {
01702    int i, olend, orend, globfound;
01703    size_t name_len = strlen(name), glob_len;
01704    struct ao2_iterator iter;
01705    struct data_filter *find_node, *found, *globres;
01706 
01707    find_node = data_filter_alloc(name);
01708    if (!find_node) {
01709       return NULL;
01710    }
01711 
01712    found = ao2_find(parent, find_node, OBJ_POINTER);
01713 
01714    /* free the created node used for searching. */
01715    ao2_ref(find_node, -1);
01716 
01717    if (found) {
01718       return found;
01719    }
01720 
01721    iter = ao2_iterator_init(parent, 0);
01722    while ((found = ao2_iterator_next(&iter))) {
01723       if (!AST_LIST_EMPTY(&(found->glob_list))) {
01724          i = 0;
01725          globfound = 1;
01726 
01727          olend = ast_strlen_zero(AST_LIST_FIRST(&(found->glob_list))->name);
01728          orend = ast_strlen_zero(AST_LIST_LAST(&(found->glob_list))->name);
01729 
01730          AST_LIST_TRAVERSE(&(found->glob_list), globres, list) {
01731             if (!*globres->name) {
01732                continue;
01733             }
01734 
01735             glob_len = strlen(globres->name);
01736 
01737             if (!i && !olend) {
01738                if (strncasecmp(name, globres->name, glob_len)) {
01739                   globfound = 0;
01740                   break;
01741                }
01742 
01743                i += glob_len;
01744                continue;
01745             }
01746 
01747             for (globfound = 0; name_len - i >= glob_len; ++i) {
01748                if (!strncasecmp(name + i, globres->name, glob_len)) {
01749                   globfound = 1;
01750                   i += glob_len;
01751                   break;
01752                }
01753             }
01754 
01755             if (!globfound) {
01756                break;
01757             }
01758          }
01759 
01760          if (globfound && (i == name_len || orend)) {
01761             ao2_iterator_destroy(&iter);
01762             return found;
01763          }
01764       }
01765 
01766       ao2_ref(found, -1);
01767    }
01768    ao2_iterator_destroy(&iter);
01769 
01770    return NULL;
01771 }

static struct data_filter* data_filter_generate ( const char *  constfilter  )  [static, read]

Definition at line 1845 of file data.c.

References ao2_ref, ast_strdupa, data_filter::children, data_filter_add_nodes(), data_filter_alloc(), and filter().

Referenced by data_result_generate().

01846 {
01847    struct data_filter *filter = NULL;
01848    char *strfilter, *token, *saveptr;
01849    int node_added = 0;
01850 
01851    if (!constfilter) {
01852       return NULL;
01853    }
01854 
01855    strfilter = ast_strdupa(constfilter);
01856 
01857    filter = data_filter_alloc("/");
01858    if (!filter) {
01859       return NULL;
01860    }
01861 
01862    for (token = strtok_r(strfilter, ",", &saveptr); token;
01863          token = strtok_r(NULL, ",", &saveptr)) {
01864       node_added = data_filter_add_nodes(filter->children, token);
01865    }
01866 
01867    if (!node_added) {
01868       ao2_ref(filter, -1);
01869       return NULL;
01870    }
01871 
01872    return filter;
01873 }

static int data_filter_hash ( const void *  obj,
const int  flags 
) [static]

Definition at line 1609 of file data.c.

References ast_str_hash(), and data_filter::name.

Referenced by data_filter_alloc().

01610 {
01611    const struct data_filter *node = obj;
01612    return ast_str_hash(node->name);
01613 }

static void data_filter_release ( struct data_filter filter  )  [static]

Definition at line 1685 of file data.c.

References ao2_ref.

Referenced by data_result_generate().

01686 {
01687    ao2_ref(filter, -1);
01688 }

static void data_get_xml_add_child ( struct ast_data parent_data,
struct ast_xml_node *  parent_xml 
) [static]

Definition at line 2094 of file data.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, AST_DATA_BOOLEAN, AST_DATA_CHARACTER, AST_DATA_CONTAINER, AST_DATA_DOUBLE, AST_DATA_INTEGER, AST_DATA_IPADDR, AST_DATA_MILLISECONDS, AST_DATA_PASSWORD, AST_DATA_POINTER, AST_DATA_SECONDS, AST_DATA_STRING, AST_DATA_TIMESTAMP, AST_DATA_UNSIGNED_INTEGER, ast_inet_ntoa(), ast_xml_add_child(), ast_xml_new_node(), ast_xml_set_text(), ast_data::boolean, ast_data::character, ast_data::children, ast_data::dbl, ast_data::ipaddr, ast_data::name, ast_data::payload, ast_data::ptr, ast_data::sint, ast_data::str, ast_data::type, and ast_data::uint.

Referenced by ast_data_get_xml().

02096 {
02097    struct ao2_iterator i;
02098    struct ast_data *node;
02099    struct ast_xml_node *child_xml;
02100    char node_content[256];
02101 
02102    i = ao2_iterator_init(parent_data->children, 0);
02103    while ((node = ao2_iterator_next(&i))) {
02104       child_xml = ast_xml_new_node(node->name);
02105       if (!child_xml) {
02106          ao2_ref(node, -1);
02107          continue;
02108       }
02109 
02110       switch (node->type) {
02111       case AST_DATA_CONTAINER:
02112          data_get_xml_add_child(node, child_xml);
02113          break;
02114       case AST_DATA_PASSWORD:
02115          ast_xml_set_text(child_xml, node->payload.str);
02116          break;
02117       case AST_DATA_TIMESTAMP:
02118          snprintf(node_content, sizeof(node_content), "%u",
02119             node->payload.uint);
02120          ast_xml_set_text(child_xml, node_content);
02121          break;
02122       case AST_DATA_SECONDS:
02123          snprintf(node_content, sizeof(node_content), "%u",
02124             node->payload.uint);
02125          ast_xml_set_text(child_xml, node_content);
02126          break;
02127       case AST_DATA_MILLISECONDS:
02128          snprintf(node_content, sizeof(node_content), "%u",
02129             node->payload.uint);
02130          ast_xml_set_text(child_xml, node_content);
02131          break;
02132       case AST_DATA_STRING:
02133          ast_xml_set_text(child_xml, node->payload.str);
02134          break;
02135       case AST_DATA_CHARACTER:
02136          snprintf(node_content, sizeof(node_content), "%c",
02137             node->payload.character);
02138          ast_xml_set_text(child_xml, node_content);
02139          break;
02140       case AST_DATA_INTEGER:
02141          snprintf(node_content, sizeof(node_content), "%d",
02142             node->payload.sint);
02143          ast_xml_set_text(child_xml, node_content);
02144          break;
02145       case AST_DATA_UNSIGNED_INTEGER:
02146          snprintf(node_content, sizeof(node_content), "%u",
02147             node->payload.uint);
02148          ast_xml_set_text(child_xml, node_content);
02149          break;
02150       case AST_DATA_DOUBLE:
02151          snprintf(node_content, sizeof(node_content), "%f",
02152             node->payload.dbl);
02153          ast_xml_set_text(child_xml, node_content);
02154          break;
02155       case AST_DATA_BOOLEAN:
02156          if (node->payload.boolean) {
02157             ast_xml_set_text(child_xml, "true");
02158          } else {
02159             ast_xml_set_text(child_xml, "false");
02160          }
02161          break;
02162       case AST_DATA_POINTER:
02163          snprintf(node_content, sizeof(node_content), "%p",
02164             node->payload.ptr);
02165          ast_xml_set_text(child_xml, node_content);
02166          break;
02167       case AST_DATA_IPADDR:
02168          snprintf(node_content, sizeof(node_content), "%s",
02169             ast_inet_ntoa(node->payload.ipaddr));
02170          ast_xml_set_text(child_xml, node_content);
02171          break;
02172       }
02173       ast_xml_add_child(parent_xml, child_xml);
02174 
02175       ao2_ref(node, -1);
02176    }
02177    ao2_iterator_destroy(&i);
02178 
02179 }

static struct data_provider* data_provider_add_child ( struct ao2_container parent,
const char *  name,
const struct ast_data_handler handler,
const char *  registrar 
) [static, read]

Definition at line 344 of file data.c.

References ao2_link, and data_provider_new().

Referenced by data_provider_create().

00346 {
00347    struct data_provider *child;
00348 
00349    child = data_provider_new(name, handler, registrar);
00350    if (!child) {
00351       return NULL;
00352    }
00353 
00354    ao2_link(parent, child);
00355 
00356    return child;
00357 }

static int data_provider_cmp ( void *  obj1,
void *  obj2,
int  flags 
) [static]

Definition at line 200 of file data.c.

References CMP_MATCH, and data_provider::name.

Referenced by ast_data_init(), and data_provider_new().

00201 {
00202    struct data_provider *node1 = obj1, *node2 = obj2;
00203    return strcasecmp(node1->name, node2->name) ? 0 : CMP_MATCH;
00204 }

static struct data_provider* data_provider_create ( struct ao2_container parent,
const char *  path,
const char *  registrar 
) [static, read]

Definition at line 487 of file data.c.

References ao2_ref, ast_strdupa, data_provider::children, data_provider_add_child(), data_provider_find(), and next_node_name().

Referenced by __ast_data_register().

00489 {
00490    char *rpath, *node_name;
00491    struct data_provider *child, *ret = NULL;
00492 
00493    rpath = ast_strdupa(path);
00494 
00495    node_name = next_node_name(&rpath);
00496    if (!node_name) {
00497       /* no more nodes to create. */
00498       return NULL;
00499    }
00500 
00501    child = data_provider_find(parent, node_name, NULL);
00502 
00503    if (!child) {
00504       /* nodes without handler are non-terminal nodes. */
00505       child = data_provider_add_child(parent, node_name, NULL, registrar);
00506    }
00507 
00508    if (rpath) {
00509       ret = data_provider_create(child->children, rpath, registrar);
00510       if (ret) {
00511          ao2_ref(child, -1);
00512       }
00513    }
00514 
00515    return ret ? ret : child;
00516 }

static void data_provider_destructor ( void *  obj  )  [static]

Definition at line 291 of file data.c.

References ao2_ref, and data_provider::children.

Referenced by data_provider_new().

00292 {
00293    struct data_provider *provider = obj;
00294 
00295    ao2_ref(provider->children, -1);
00296 }

static struct data_provider* data_provider_find ( struct ao2_container parent,
const char *  name,
const char *  registrar 
) [static, read]

Definition at line 369 of file data.c.

References ao2_find, ao2_ref, ast_debug, data_provider_new(), OBJ_POINTER, and data_provider::registrar.

Referenced by data_provider_create(), data_provider_release(), and data_result_generate().

00371 {
00372    struct data_provider *find_node, *found;
00373 
00374    /* XXX avoid allocating a new data node for searching... */
00375    find_node = data_provider_new(name, NULL, NULL);
00376    if (!find_node) {
00377       return NULL;
00378    }
00379 
00380    found = ao2_find(parent, find_node, OBJ_POINTER);
00381 
00382    /* free the created node used for searching. */
00383    ao2_ref(find_node, -1);
00384 
00385    if (found && found->registrar && registrar) {
00386       if (strcmp(found->registrar, registrar)) {
00387          /* if the name doesn't match, do not return this node. */
00388          ast_debug(1, "Registrar doesn't match, node was registered"
00389             " by '%s' and we are searching for '%s'\n",
00390             found->registrar, registrar);
00391          ao2_ref(found, -1);
00392          return NULL;
00393       }
00394    }
00395 
00396    return found;
00397 }

static int data_provider_hash ( const void *  obj,
const int  flags 
) [static]

Definition at line 189 of file data.c.

References ast_str_case_hash(), and data_provider::name.

Referenced by ast_data_init(), and data_provider_new().

00190 {
00191    const struct data_provider *node = obj;
00192    return ast_str_case_hash(node->name);
00193 }

static struct data_provider* data_provider_new ( const char *  name,
const struct ast_data_handler handler,
const char *  registrar 
) [static, read]

Definition at line 307 of file data.c.

References ao2_alloc, ao2_container_alloc, ao2_ref, data_provider::children, data_provider_cmp(), data_provider_destructor(), data_provider_hash(), data_provider::handler, data_provider::name, NUM_DATA_NODE_BUCKETS, and data_provider::registrar.

Referenced by data_provider_add_child(), and data_provider_find().

00309 {
00310    struct data_provider *node;
00311    size_t namelen;
00312 
00313    namelen = strlen(name) + 1;
00314 
00315    node = ao2_alloc(sizeof(*node) + namelen, data_provider_destructor);
00316    if (!node) {
00317       return NULL;
00318    }
00319 
00320    node->handler = handler;
00321    node->registrar = registrar;
00322    strcpy(node->name, name);
00323 
00324    /* initialize the childrens container. */
00325    if (!(node->children = ao2_container_alloc(NUM_DATA_NODE_BUCKETS,
00326          data_provider_hash, data_provider_cmp))) {
00327       ao2_ref(node, -1);
00328       return NULL;
00329    }
00330 
00331    return node;
00332 }

static void data_provider_print_cli ( int  fd,
const char *  name,
struct ao2_container container,
struct ast_str path 
) [static]

Definition at line 2920 of file data.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_cli(), ast_free, ast_str_buffer(), ast_str_create(), ast_str_reset(), ast_str_set(), data_provider::children, ast_data_handler::get, data_provider::handler, data_provider::name, and data_provider::registrar.

Referenced by handle_cli_data_show_providers().

02922 {
02923    struct ao2_iterator i;
02924    struct ast_str *current_path;
02925    struct data_provider *provider;
02926 
02927    current_path = ast_str_create(60);
02928    if (!current_path) {
02929       return;
02930    }
02931 
02932    ast_str_reset(current_path);
02933    if (path) {
02934       ast_str_set(&current_path, 0, "%s/%s", ast_str_buffer(path), name);
02935    } else {
02936       ast_str_set(&current_path, 0, "%s", name);
02937    }
02938 
02939    i = ao2_iterator_init(container, 0);
02940    while ((provider = ao2_iterator_next(&i))) {
02941       if (provider->handler) {
02942          /* terminal node, print it. */
02943          ast_cli(fd, "%s/%s (", ast_str_buffer(current_path),
02944             provider->name);
02945          if (provider->handler->get) {
02946             ast_cli(fd, "get");
02947          }
02948          ast_cli(fd, ") [%s]\n", provider->registrar);
02949       }
02950       data_provider_print_cli(fd, provider->name, provider->children,
02951          current_path);
02952       ao2_ref(provider, -1);
02953    }
02954    ao2_iterator_destroy(&i);
02955 
02956    ast_free(current_path);
02957 }

static int data_provider_release ( struct ao2_container parent,
const char *  path,
const char *  registrar 
) [static]

Definition at line 409 of file data.c.

References ao2_container_count(), ao2_ref, ao2_unlink, ast_strdupa, data_provider::children, data_provider_find(), data_provider::handler, and next_node_name().

Referenced by __ast_data_unregister().

00411 {
00412    char *node_name, *rpath;
00413    struct data_provider *child;
00414    int ret = 0;
00415 
00416    rpath = ast_strdupa(path);
00417 
00418    node_name = next_node_name(&rpath);
00419    if (!node_name) {
00420       return -1;
00421    }
00422 
00423    child = data_provider_find(parent, node_name, registrar);
00424    if (!child) {
00425       return -1;
00426    }
00427 
00428    /* if this is not a terminal node. */
00429    if (!child->handler && rpath) {
00430       ret = data_provider_release(child->children, rpath, registrar);
00431    }
00432 
00433    /* if this node is empty, unlink it. */
00434    if (!ret && !ao2_container_count(child->children)) {
00435       ao2_unlink(parent, child);
00436    }
00437 
00438    ao2_ref(child, -1);
00439 
00440    return ret;
00441 }

static void data_provider_release_all ( struct ao2_container parent,
const char *  registrar 
) [static]

Definition at line 450 of file data.c.

References ao2_container_count(), ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ao2_unlink, data_provider::children, data_provider::handler, and data_provider::registrar.

Referenced by __ast_data_unregister().

00452 {
00453    struct ao2_iterator i;
00454    struct data_provider *node;
00455 
00456    i = ao2_iterator_init(parent, 0);
00457    while ((node = ao2_iterator_next(&i))) {
00458       if (!node->handler) {
00459          /* this is a non-terminal node, go inside it. */
00460          data_provider_release_all(node->children, registrar);
00461          if (!ao2_container_count(node->children)) {
00462             /* if this node was left empty, unlink it. */
00463             ao2_unlink(parent, node);
00464          }
00465       } else {
00466          if (!strcmp(node->registrar, registrar)) {
00467             /* if the registrars match, release it! */
00468             ao2_unlink(parent, node);
00469          }
00470       }
00471       ao2_ref(node, -1);
00472    }
00473    ao2_iterator_destroy(&i);
00474 
00475 }

static void data_result_add_child ( struct ast_data root,
struct ast_data child 
) [static]

Definition at line 1600 of file data.c.

References ao2_link, and ast_data::children.

Referenced by __ast_data_add(), and data_result_generate_node().

01601 {
01602    ao2_link(root->children, child);
01603 }

static int data_result_cmp ( void *  obj,
void *  arg,
int  flags 
) [static]

Definition at line 220 of file data.c.

References CMP_MATCH, and ast_data::name.

Referenced by data_result_create().

00221 {
00222    struct ast_data *node1 = obj, *node2 = arg;
00223    return strcasecmp(node1->name, node2->name) ? 0 : CMP_MATCH;
00224 }

static struct ast_data* data_result_create ( const char *  name  )  [static, read]

Definition at line 1405 of file data.c.

References ao2_alloc, ao2_container_alloc, ao2_ref, AST_DATA_CONTAINER, ast_strlen_zero(), ast_data::children, data_result_cmp(), data_result_destructor(), data_result_hash(), ast_data::name, NUM_DATA_RESULT_BUCKETS, and ast_data::type.

Referenced by __ast_data_add(), data_result_find_child(), and data_result_generate_node().

01406 {
01407    struct ast_data *res;
01408    size_t namelen;
01409 
01410    namelen = ast_strlen_zero(name) ? 1 : strlen(name) + 1;
01411 
01412    res = ao2_alloc(sizeof(*res) + namelen, data_result_destructor);
01413    if (!res) {
01414       return NULL;
01415    }
01416 
01417    strcpy(res->name, namelen ? name : "");
01418 
01419    /* initialize the children container */
01420    res->children = ao2_container_alloc(NUM_DATA_RESULT_BUCKETS, data_result_hash,
01421       data_result_cmp);
01422    if (!res->children) {
01423       ao2_ref(res, -1);
01424       return NULL;
01425    }
01426 
01427    /* set this node as a container. */
01428    res->type = AST_DATA_CONTAINER;
01429 
01430    return res;
01431 }

static void data_result_destructor ( void *  obj  )  [static]

Definition at line 1379 of file data.c.

References ao2_ref, AST_DATA_BOOLEAN, AST_DATA_CHARACTER, AST_DATA_CONTAINER, AST_DATA_DOUBLE, AST_DATA_INTEGER, AST_DATA_IPADDR, AST_DATA_MILLISECONDS, AST_DATA_PASSWORD, AST_DATA_POINTER, AST_DATA_SECONDS, AST_DATA_STRING, AST_DATA_TIMESTAMP, AST_DATA_UNSIGNED_INTEGER, ast_free, ast_data::children, ast_data::payload, ast_data::str, and ast_data::type.

Referenced by data_result_create().

01380 {
01381    struct ast_data *root = obj;
01382 
01383    switch (root->type) {
01384    case AST_DATA_PASSWORD:
01385    case AST_DATA_STRING:
01386       ast_free(root->payload.str);
01387       ao2_ref(root->children, -1);
01388       break;
01389    case AST_DATA_POINTER:
01390    case AST_DATA_CHARACTER:
01391    case AST_DATA_CONTAINER:
01392    case AST_DATA_INTEGER:
01393    case AST_DATA_TIMESTAMP:
01394    case AST_DATA_SECONDS:
01395    case AST_DATA_MILLISECONDS:
01396    case AST_DATA_UNSIGNED_INTEGER:
01397    case AST_DATA_DOUBLE:
01398    case AST_DATA_BOOLEAN:
01399    case AST_DATA_IPADDR:
01400       ao2_ref(root->children, -1);
01401       break;
01402    }
01403 }

static struct ast_data* data_result_find_child ( struct ast_data root,
const char *  name 
) [static, read]

Definition at line 1441 of file data.c.

References ao2_find, ao2_ref, ast_data::children, data_result_create(), and OBJ_POINTER.

Referenced by ast_data_search_match(), and data_result_get_node().

01442 {
01443    struct ast_data *found, *find_node;
01444 
01445    find_node = data_result_create(name);
01446    if (!find_node) {
01447       return NULL;
01448    }
01449 
01450    found = ao2_find(root->children, find_node, OBJ_POINTER);
01451 
01452    /* release the temporary created node used for searching. */
01453    ao2_ref(find_node, -1);
01454 
01455    return found;
01456 }

static struct ast_data* data_result_generate ( const struct ast_data_query query,
const char *  search_path 
) [static, read]

Definition at line 1973 of file data.c.

References ao2_ref, ast_log(), ast_strdupa, data_filter::children, ast_data_search::children, data_provider::children, data_filter_find(), data_filter_generate(), data_filter_release(), data_provider_find(), data_result_generate_node(), data_search_find(), data_search_generate(), data_search_release(), ast_data_query::filter, filter(), LOG_ERROR, data_provider::name, next_node_name(), root_data, and ast_data_query::search.

Referenced by ast_data_get().

01975 {
01976    char *node_name, *tmp_path;
01977    struct data_provider *provider_child, *tmp_provider_child;
01978    struct ast_data *result, *result_filtered;
01979    struct ast_data_search *search = NULL, *search_child = NULL;
01980    struct data_filter *filter = NULL, *filter_child = NULL;
01981 
01982    if (!search_path) {
01983       /* generate all the trees?. */
01984       return NULL;
01985    }
01986 
01987    tmp_path = ast_strdupa(search_path);
01988 
01989    /* start searching the root node name */
01990    node_name = next_node_name(&tmp_path);
01991    if (!node_name) {
01992       return NULL;
01993    }
01994    provider_child = data_provider_find(root_data.container, node_name, NULL);
01995 
01996    /* continue with the rest of the path. */
01997    while (provider_child) {
01998       node_name = next_node_name(&tmp_path);
01999       if (!node_name) {
02000          break;
02001       }
02002 
02003       tmp_provider_child = data_provider_find(provider_child->children,
02004             node_name, NULL);
02005 
02006       /* release the reference from this child */
02007       ao2_ref(provider_child, -1);
02008 
02009       provider_child = tmp_provider_child;
02010    }
02011 
02012    if (!provider_child) {
02013       ast_log(LOG_ERROR, "Invalid path '%s', '%s' not found.\n",
02014             tmp_path, node_name);
02015       return NULL;
02016    }
02017 
02018    /* generate the search tree. */
02019    if (query->search) {
02020       search = data_search_generate(query->search);
02021       if (search) {
02022          search_child = data_search_find(search->children,
02023             provider_child->name);
02024       }
02025    }
02026 
02027    /* generate the filter tree. */
02028    if (query->filter) {
02029       filter = data_filter_generate(query->filter);
02030       if (filter) {
02031          filter_child = data_filter_find(filter->children,
02032             provider_child->name);
02033       }
02034    }
02035 
02036    result = data_result_generate_node(query, provider_child, provider_child->name,
02037          search_child, filter_child);
02038 
02039    /* release the requested provider. */
02040    ao2_ref(provider_child, -1);
02041 
02042    /* release the generated search tree. */
02043    if (search_child) {
02044       ao2_ref(search_child, -1);
02045    }
02046 
02047    if (filter_child) {
02048       ao2_ref(filter_child, -1);
02049    }
02050 
02051    if (search) {
02052       data_search_release(search);
02053    }
02054 
02055    result_filtered = result;
02056 
02057    /* release the generated filter tree. */
02058    if (filter) {
02059       data_filter_release(filter);
02060    }
02061 
02062    return result_filtered;
02063 }

static struct ast_data* data_result_generate_node ( const struct ast_data_query query,
const struct data_provider root_provider,
const char *  parent_node_name,
const struct ast_data_search search,
const struct data_filter filter 
) [static, read]

Definition at line 1884 of file data.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, ast_log(), ast_module_ref(), ast_module_unref(), data_filter::children, ast_data_search::children, data_provider::children, data_filter_find(), data_result_add_child(), data_result_create(), data_search_find(), ast_data::filter, ast_data_handler::get, data_provider::handler, LOG_ERROR, data_provider::module, and data_provider::name.

Referenced by data_result_generate().

01889 {
01890    struct ast_data *generated, *node;
01891    struct ao2_iterator i;
01892    struct data_provider *provider;
01893    struct ast_data_search *search_child = NULL;
01894    struct data_filter *filter_child;
01895 
01896    node = data_result_create(parent_node_name);
01897    if (!node) {
01898       ast_log(LOG_ERROR, "Unable to allocate '%s' node\n", parent_node_name);
01899       return NULL;
01900    }
01901 
01902    if (root_provider->module) {
01903       ast_module_ref(root_provider->module);
01904    }
01905 
01906    /* if this is a terminal node, just run the callback function. */
01907    if (root_provider->handler && root_provider->handler->get) {
01908       node->filter = filter;
01909       root_provider->handler->get(search, node);
01910       if (root_provider->module) {
01911          ast_module_unref(root_provider->module);
01912       }
01913       return node;
01914    }
01915 
01916    if (root_provider->module) {
01917       ast_module_unref(root_provider->module);
01918    }
01919 
01920    /* if this is not a terminal node, generate every child node. */
01921    i = ao2_iterator_init(root_provider->children, 0);
01922    while ((provider = ao2_iterator_next(&i))) {
01923       filter_child = NULL;
01924       generated = NULL;
01925 
01926       /* get the internal search node. */
01927       if (search) {
01928          search_child = data_search_find(search->children, provider->name);
01929       }
01930       /* get the internal filter node. */
01931       if (filter) {
01932          filter_child = data_filter_find(filter->children, provider->name);
01933       }
01934 
01935       if (!filter || filter_child) {
01936          /* only generate the internal node, if we have something to
01937           * generate based on the filtering string. */
01938          generated = data_result_generate_node(query, provider,
01939             provider->name,
01940             search_child, filter_child);
01941       }
01942 
01943       /* decrement the refcount of the internal search node. */
01944       if (search_child) {
01945          ao2_ref(search_child, -1);
01946       }
01947 
01948       /* decrement the refcount of the internal filter node. */
01949       if (filter_child) {
01950          ao2_ref(filter_child, -1);
01951       }
01952 
01953       if (generated) {
01954          data_result_add_child(node, generated);
01955          ao2_ref(generated, -1);
01956       }
01957 
01958       ao2_ref(provider, -1);
01959    }
01960    ao2_iterator_destroy(&i);
01961 
01962    return node;
01963 }

static int data_result_get_color ( enum ast_data_type  type  )  [static]

Definition at line 2687 of file data.c.

References ARRAY_LEN, COLOR_BLUE, and data_result_color.

Referenced by data_result_print_cli(), and data_result_print_cli_node().

02688 {
02689    int i;
02690    for (i = 0; i < ARRAY_LEN(data_result_color); i++) {
02691       if (data_result_color[i].type == type) {
02692          return data_result_color[i].color;
02693       }
02694    }
02695 
02696    return COLOR_BLUE;
02697 }

static struct ast_data* data_result_get_node ( struct ast_data node,
const char *  path 
) [static, read]

Definition at line 1565 of file data.c.

References ao2_ref, ast_strdupa, data_result_find_child(), and next_node_name().

Referenced by ast_data_iterator_init(), ast_data_retrieve(), and ast_data_retrieve_type().

01567 {
01568    char *savepath, *node_name;
01569    struct ast_data *child, *current = node;
01570 
01571    savepath = ast_strdupa(path);
01572    node_name = next_node_name(&savepath);
01573 
01574    while (node_name) {
01575       child = data_result_find_child(current, node_name);
01576       if (current != node) {
01577          ao2_ref(current, -1);
01578       }
01579       if (!child) {
01580          return NULL;
01581       }
01582       current = child;
01583       node_name = next_node_name(&savepath);
01584    }
01585 
01586    /* do not increment the refcount of the returned object. */
01587    if (current != node) {
01588       ao2_ref(current, -1);
01589    }
01590 
01591    return current;
01592 }

static int data_result_hash ( const void *  obj,
const int  flags 
) [static]

Definition at line 210 of file data.c.

References ast_str_hash(), and ast_data::name.

Referenced by data_result_create().

00211 {
00212    const struct ast_data *node = obj;
00213    return ast_str_hash(node->name);
00214 }

static void data_result_manager_output ( struct mansession s,
const char *  name,
struct ao2_container container,
struct ast_str path,
int  id 
) [static]

Definition at line 3001 of file data.c.

References ao2_iterator_destroy(), ao2_iterator_init(), ao2_iterator_next, ao2_ref, AST_DATA_BOOLEAN, AST_DATA_CHARACTER, AST_DATA_CONTAINER, AST_DATA_DOUBLE, AST_DATA_INTEGER, AST_DATA_IPADDR, AST_DATA_MILLISECONDS, AST_DATA_PASSWORD, AST_DATA_POINTER, AST_DATA_SECONDS, AST_DATA_STRING, AST_DATA_TIMESTAMP, AST_DATA_UNSIGNED_INTEGER, ast_free, ast_inet_ntoa(), ast_str_buffer(), ast_str_create(), ast_str_reset(), ast_str_set(), astman_append(), ast_data::boolean, ast_data::character, ast_data::children, ast_data::dbl, ast_data::ipaddr, ast_data::name, ast_data::payload, ast_data::sint, ast_data::str, ast_data::type, and ast_data::uint.

Referenced by manager_data_get().

03003 {
03004    struct ao2_iterator i;
03005    struct ast_str *current_path;
03006    struct ast_data *node;
03007    int current_id = id;
03008 
03009    current_path = ast_str_create(60);
03010    if (!current_path) {
03011       return;
03012    }
03013 
03014    ast_str_reset(current_path);
03015    if (path) {
03016       ast_str_set(&current_path, 0, "%s.%s", ast_str_buffer(path), name);
03017    } else {
03018       ast_str_set(&current_path, 0, "%s", name);
03019    }
03020 
03021    i = ao2_iterator_init(container, 0);
03022    while ((node = ao2_iterator_next(&i))) {
03023       /* terminal node, print it. */
03024       if (node->type != AST_DATA_CONTAINER) {
03025          astman_append(s, "%d-%s.%s", id, ast_str_buffer(current_path),
03026                node->name);
03027       }
03028       switch (node->type) {
03029       case AST_DATA_CONTAINER:
03030          data_result_manager_output(s, node->name, node->children, current_path, ++current_id);
03031          break;
03032       case AST_DATA_INTEGER:
03033          astman_append(s, ": %d\r\n", node->payload.sint);
03034          break;
03035       case AST_DATA_TIMESTAMP:
03036       case AST_DATA_SECONDS:
03037       case AST_DATA_MILLISECONDS:
03038       case AST_DATA_UNSIGNED_INTEGER:
03039          astman_append(s, ": %u\r\n", node->payload.uint);
03040          break;
03041       case AST_DATA_PASSWORD:
03042          astman_append(s, ": %s\r\n", node->payload.str);
03043          break;
03044       case AST_DATA_STRING:
03045          astman_append(s, ": %s\r\n", node->payload.str);
03046          break;
03047       case AST_DATA_CHARACTER:
03048          astman_append(s, ": %c\r\n", node->payload.character);
03049          break;
03050       case AST_DATA_IPADDR:
03051          astman_append(s, ": %s\r\n", ast_inet_ntoa(node->payload.ipaddr));
03052          break;
03053       case AST_DATA_POINTER:
03054          break;
03055       case AST_DATA_DOUBLE:
03056          astman_append(s, ": %f\r\n", node->payload.dbl);
03057          break;
03058       case AST_DATA_BOOLEAN:
03059          astman_append(s, ": %s\r\n",
03060             (node->payload.boolean ? "True" : "False"));
03061          break;
03062       }
03063 
03064       ao2_ref(node, -1);
03065    }
03066    ao2_iterator_destroy(&i);
03067 
03068    ast_free(current_path);
03069 }

static void data_result_print_cli ( int  fd,
const struct ast_data root 
) [static]

Definition at line 2842 of file data.c.

References __data_result_print_cli(), ast_cli(), ast_free, ast_str_append(), ast_str_buffer(), ast_str_create(), ast_term_color_code(), COLOR_WHITE, data_result_get_color(), ast_data::name, and ast_data::type.

Referenced by handle_cli_data_get().

02843 {
02844    struct ast_str *output;
02845 
02846    /* print the initial node. */
02847    output = ast_str_create(30);
02848    if (!output) {
02849       return;
02850    }
02851 
02852    ast_term_color_code(&output, data_result_get_color(root->type), 0);
02853    ast_str_append(&output, 0, "%s\n", root->name);
02854    ast_term_color_code(&output, COLOR_WHITE, 0);
02855    ast_cli(fd, "%s", ast_str_buffer(output));
02856    ast_free(output);
02857 
02858    __data_result_print_cli(fd, root, 0);
02859 
02860    ast_cli(fd, "\n");
02861 }

static void data_result_print_cli_node ( int  fd,
const struct ast_data node,
uint32_t  depth 
) [static]

Definition at line 2706 of file data.c.

References __data_result_print_cli(), ast_cli(), AST_DATA_BOOLEAN, AST_DATA_CHARACTER, AST_DATA_CONTAINER, AST_DATA_DOUBLE, AST_DATA_INTEGER, AST_DATA_IPADDR, AST_DATA_MILLISECONDS, AST_DATA_PASSWORD, AST_DATA_POINTER, AST_DATA_SECONDS, AST_DATA_STRING, AST_DATA_TIMESTAMP, AST_DATA_UNSIGNED_INTEGER, ast_free, ast_inet_ntoa(), ast_str_append(), ast_str_buffer(), ast_str_create(), ast_str_reset(), ast_term_color_code(), ast_data::boolean, ast_data::character, COLOR_WHITE, data_result_get_color(), ast_data::dbl, ast_data::ipaddr, ast_data::name, ast_data::payload, ast_data::ptr, ast_data::sint, ast_data::str, ast_data::type, and ast_data::uint.

Referenced by __data_result_print_cli().

02707 {
02708    int i;
02709    struct ast_str *tabs, *output;
02710 
02711    tabs = ast_str_create(depth * 10 + 1);
02712    if (!tabs) {
02713       return;
02714    }
02715    ast_str_reset(tabs);
02716    for (i = 0; i < depth; i++) {
02717       ast_str_append(&tabs, 0, "  ");
02718    }
02719 
02720    output = ast_str_create(20);
02721    if (!output) {
02722       ast_free(tabs);
02723       return;
02724    }
02725 
02726    ast_str_reset(output);
02727    ast_term_color_code(&output, data_result_get_color(node->type), 0);
02728 
02729    switch (node->type) {
02730    case AST_DATA_POINTER:
02731       ast_str_append(&output, 0, "%s%s: %p\n", ast_str_buffer(tabs),
02732             node->name, node->payload.ptr);
02733       break;
02734    case AST_DATA_PASSWORD:
02735       ast_str_append(&output, 0, "%s%s: \"%s\"\n",
02736             ast_str_buffer(tabs),
02737             node->name,
02738             node->payload.str);
02739       break;
02740    case AST_DATA_STRING:
02741       ast_str_append(&output, 0, "%s%s: \"%s\"\n",
02742             ast_str_buffer(tabs),
02743             node->name,
02744             node->payload.str);
02745       break;
02746    case AST_DATA_CHARACTER:
02747       ast_str_append(&output, 0, "%s%s: \'%c\'\n",
02748             ast_str_buffer(tabs),
02749             node->name,
02750             node->payload.character);
02751       break;
02752    case AST_DATA_CONTAINER:
02753       ast_str_append(&output, 0, "%s%s\n", ast_str_buffer(tabs),
02754             node->name);
02755       break;
02756    case AST_DATA_TIMESTAMP:
02757       ast_str_append(&output, 0, "%s%s: %u\n", ast_str_buffer(tabs),
02758             node->name,
02759             node->payload.uint);
02760       break;
02761    case AST_DATA_SECONDS:
02762       ast_str_append(&output, 0, "%s%s: %u\n", ast_str_buffer(tabs),
02763             node->name,
02764             node->payload.uint);
02765       break;
02766    case AST_DATA_MILLISECONDS:
02767       ast_str_append(&output, 0, "%s%s: %u\n", ast_str_buffer(tabs),
02768             node->name,
02769             node->payload.uint);
02770       break;
02771    case AST_DATA_INTEGER:
02772       ast_str_append(&output, 0, "%s%s: %d\n", ast_str_buffer(tabs),
02773             node->name,
02774             node->payload.sint);
02775       break;
02776    case AST_DATA_UNSIGNED_INTEGER:
02777       ast_str_append(&output, 0, "%s%s: %u\n", ast_str_buffer(tabs),
02778             node->name,
02779             node->payload.uint);
02780       break;
02781    case AST_DATA_DOUBLE:
02782       ast_str_append(&output, 0, "%s%s: %lf\n", ast_str_buffer(tabs),
02783             node->name,
02784             node->payload.dbl);
02785       break;
02786    case AST_DATA_BOOLEAN:
02787       ast_str_append(&output, 0, "%s%s: %s\n", ast_str_buffer(tabs),
02788             node->name,
02789             ((node->payload.boolean) ? "True" : "False"));
02790       break;
02791    case AST_DATA_IPADDR:
02792       ast_str_append(&output, 0, "%s%s: %s\n", ast_str_buffer(tabs),
02793             node->name,
02794             ast_inet_ntoa(node->payload.ipaddr));
02795       break;
02796    }
02797 
02798    ast_free(tabs);
02799 
02800    ast_term_color_code(&output, COLOR_WHITE, 0);
02801 
02802    ast_cli(fd, "%s", ast_str_buffer(output));
02803 
02804    ast_free(output);
02805 
02806    if (node->type == AST_DATA_CONTAINER) {
02807       __data_result_print_cli(fd, node, depth + 1);
02808    }
02809 }

static struct ast_data_search* data_search_add_child ( struct ao2_container parent,
const char *  name 
) [static, read]

Definition at line 748 of file data.c.

References ao2_link, and data_search_alloc().

Referenced by data_search_create().

00750 {
00751    struct ast_data_search *child;
00752 
00753    child = data_search_alloc(name);
00754    if (!child) {
00755       return NULL;
00756    }
00757 
00758    ao2_link(parent, child);
00759 
00760    return child;
00761 }

static struct ast_data_search* data_search_alloc ( const char *  name  )  [static, read]

Definition at line 690 of file data.c.

References ao2_alloc, ao2_container_alloc, ao2_ref, ast_data_search::children, data_search_cmp(), data_search_destructor(), data_search_hash(), ast_data_search::name, and NUM_DATA_SEARCH_BUCKETS.

Referenced by data_search_add_child(), data_search_find(), and data_search_generate().

00691 {
00692    struct ast_data_search *res;
00693    size_t name_len = strlen(name) + 1;
00694 
00695    res = ao2_alloc(sizeof(*res) + name_len, data_search_destructor);
00696    if (!res) {
00697       return NULL;
00698    }
00699 
00700    res->children = ao2_container_alloc(NUM_DATA_SEARCH_BUCKETS, data_search_hash,
00701       data_search_cmp);
00702 
00703    if (!res) {
00704       ao2_ref(res, -1);
00705       return NULL;
00706    }
00707 
00708    strcpy(res->name, name);
00709 
00710    return res;
00711 }

static int data_search_cmp ( void *  obj,
void *  arg,
int  flags 
) [static]

Definition at line 663 of file data.c.

References CMP_MATCH, and ast_data_search::name.

Referenced by data_search_alloc().

00664 {
00665    struct ast_data_search *node1 = obj, *node2 = arg;
00666    return strcasecmp(node1->name, node2->name) ? 0 : CMP_MATCH;
00667 }

static int data_search_cmp_bool ( const struct ast_data_search root,
const char *  name,
unsigned int  value 
) [static]

Definition at line 1102 of file data.c.

References ao2_ref, ast_true(), ast_data_search::cmp_type, data_search_comparison_result(), data_search_get_node(), and ast_data_search::value.

Referenced by __ast_data_search_cmp_structure(), and ast_data_search_match().

01104 {
01105    struct ast_data_search *child;
01106    unsigned int node_value;
01107    enum data_search_comparison cmp_type;
01108 
01109    child = data_search_get_node(root, name);
01110    if (!child) {
01111       return 0;
01112    }
01113 
01114    node_value = abs(ast_true(child->value));
01115    cmp_type = child->cmp_type;
01116 
01117    ao2_ref(child, -1);
01118 
01119    return data_search_comparison_result(value - node_value, cmp_type);
01120 }

static int data_search_cmp_char ( const struct ast_data_search root,
const char *  name,
char  value 
) [static]

Definition at line 1230 of file data.c.

References ao2_ref, ast_data_search::cmp_type, data_search_comparison_result(), data_search_get_node(), and ast_data_search::value.

Referenced by __ast_data_search_cmp_structure(), and ast_data_search_match().

01232 {
01233    struct ast_data_search *child;
01234    char node_value;
01235    enum data_search_comparison cmp_type;
01236 
01237    child = data_search_get_node(root, name);
01238    if (!child) {
01239       return 0;
01240    }
01241 
01242    node_value = *(child->value);
01243    cmp_type = child->cmp_type;
01244 
01245    ao2_ref(child, -1);
01246 
01247    return data_search_comparison_result(value - node_value, cmp_type);
01248 }

static int data_search_cmp_dbl ( const struct ast_data_search root,
const char *  name,
double  value 
) [static]

Definition at line 1134 of file data.c.

References ao2_ref, ast_data_search::cmp_type, data_search_comparison_result(), data_search_get_node(), and ast_data_search::value.

Referenced by __ast_data_search_cmp_structure().

01136 {
01137    struct ast_data_search *child;
01138    double node_value;
01139    enum data_search_comparison cmp_type;
01140 
01141    child = data_search_get_node(root, name);
01142    if (!child) {
01143       return 0;
01144    }
01145 
01146    node_value = strtod(child->value, NULL);
01147    cmp_type = child->cmp_type;
01148 
01149    ao2_ref(child, -1);
01150 
01151    return data_search_comparison_result(value - node_value, cmp_type);
01152 }

static int data_search_cmp_int ( const struct ast_data_search root,
const char *  name,
int  value 
) [static]

Definition at line 1198 of file data.c.

References ao2_ref, ast_data_search::cmp_type, data_search_comparison_result(), data_search_get_node(), and ast_data_search::value.

Referenced by __ast_data_search_cmp_structure(), and ast_data_search_match().

01200 {
01201    struct ast_data_search *child;
01202    int node_value;
01203    enum data_search_comparison cmp_type;
01204 
01205    child = data_search_get_node(root, name);
01206    if (!child) {
01207       return 0;
01208    }
01209 
01210    node_value = atoi(child->value);
01211    cmp_type = child->cmp_type;
01212 
01213    ao2_ref(child, -1);
01214 
01215    return data_search_comparison_result(value - node_value, cmp_type);
01216 }

static int data_search_cmp_ipaddr ( const struct ast_data_search root,
const char *  name,
struct in_addr  addr 
) [static]

Definition at line 1070 of file data.c.

References ao2_ref, ast_data_search::cmp_type, data_search_comparison_result(), and data_search_get_node().

Referenced by __ast_data_search_cmp_structure(), and ast_data_search_match().

01072 {
01073    struct ast_data_search *child;
01074    enum data_search_comparison cmp_type;
01075    struct in_addr node_addr;
01076 
01077    child = data_search_get_node(root, name);
01078    if (!child) {
01079       return 0;
01080    }
01081    cmp_type = child->cmp_type;
01082 
01083    inet_aton(child->value, &node_addr);
01084 
01085    ao2_ref(child, -1);
01086 
01087    return data_search_comparison_result((node_addr.s_addr - addr.s_addr), cmp_type);
01088 }

static int data_search_cmp_ptr ( const struct ast_data_search root,
const char *  name,
void *  ptr 
) [static]

Definition at line 1034 of file data.c.

References ao2_ref, ast_data_search::cmp_type, data_search_comparison_result(), data_search_get_node(), and ast_data_search::value.

Referenced by __ast_data_search_cmp_structure(), and ast_data_search_match().

01036 {
01037    struct ast_data_search *child;
01038    enum data_search_comparison cmp_type;
01039    void *node_ptr;
01040 
01041    child = data_search_get_node(root, name);
01042    if (!child) {
01043       return 0;
01044    }
01045 
01046    cmp_type = child->cmp_type;
01047 
01048    if (sscanf(child->value, "%p", &node_ptr) <= 0) {
01049       ao2_ref(child, -1);
01050       return 1;
01051    }
01052 
01053    ao2_ref(child, -1);
01054 
01055    return data_search_comparison_result((node_ptr - ptr), cmp_type);
01056 }

static int data_search_cmp_string ( const struct ast_data_search root,
const char *  name,
char *  value 
) [static]

Definition at line 1002 of file data.c.

References ao2_ref, ast_data_search::cmp_type, data_search_comparison_result(), data_search_get_node(), and ast_data_search::value.

Referenced by __ast_data_search_cmp_structure(), and ast_data_search_match().

01004 {
01005    struct ast_data_search *child;
01006    enum data_search_comparison cmp_type;
01007    int ret;
01008 
01009    child = data_search_get_node(root, name);
01010    if (!child) {
01011       return 0;
01012    }
01013 
01014    ret = strcmp(value, child->value);
01015    cmp_type = child->cmp_type;
01016 
01017    ao2_ref(child, -1);
01018 
01019    return data_search_comparison_result(ret, cmp_type);
01020 }

static int data_search_cmp_uint ( const struct ast_data_search root,
const char *  name,
unsigned int  value 
) [static]

Definition at line 1166 of file data.c.

References ao2_ref, ast_data_search::cmp_type, data_search_comparison_result(), data_search_get_node(), and ast_data_search::value.

Referenced by __ast_data_search_cmp_structure(), and ast_data_search_match().

01168 {
01169    struct ast_data_search *child;
01170    unsigned int node_value;
01171    enum data_search_comparison cmp_type;
01172 
01173    child = data_search_get_node(root, name);
01174    if (!child) {
01175       return 0;
01176    }
01177 
01178    node_value = atoi(child->value);
01179    cmp_type = child->cmp_type;
01180 
01181    ao2_ref(child, -1);
01182 
01183    return data_search_comparison_result(value - node_value, cmp_type);
01184 }

static int data_search_comparison_char ( char  a  )  [static]

Definition at line 613 of file data.c.

Referenced by data_search_generate().

00614 {
00615    switch (a) {
00616    case '!':
00617    case '=':
00618    case '<':
00619    case '>':
00620       return 1;
00621    }
00622 
00623    return 0;
00624 }

static int data_search_comparison_result ( int  cmpval,
enum data_search_comparison  comparison_type 
) [inline, static]

Definition at line 914 of file data.c.

References DATA_CMP_EQ, DATA_CMP_GE, DATA_CMP_GT, DATA_CMP_LE, DATA_CMP_LT, DATA_CMP_NEQ, and DATA_CMP_UNKNOWN.

Referenced by data_search_cmp_bool(), data_search_cmp_char(), data_search_cmp_dbl(), data_search_cmp_int(), data_search_cmp_ipaddr(), data_search_cmp_ptr(), data_search_cmp_string(), and data_search_cmp_uint().

00916 {
00917    switch (comparison_type) {
00918    case DATA_CMP_GE:
00919       if (cmpval >= 0) {
00920          return 0;
00921       }
00922       break;
00923    case DATA_CMP_LE:
00924       if (cmpval <= 0) {
00925          return 0;
00926       }
00927       break;
00928    case DATA_CMP_EQ:
00929       if (cmpval == 0) {
00930          return 0;
00931       }
00932       break;
00933    case DATA_CMP_NEQ:
00934       if (cmpval != 0) {
00935          return 0;
00936       }
00937       break;
00938    case DATA_CMP_LT:
00939       if (cmpval < 0) {
00940          return 0;
00941       }
00942       break;
00943    case DATA_CMP_GT:
00944       if (cmpval > 0) {
00945          return 0;
00946       }
00947       break;
00948    case DATA_CMP_UNKNOWN:
00949       break;
00950    }
00951    return 1;
00952 }

static enum data_search_comparison data_search_comparison_type ( const char *  comparison  )  [static]

Definition at line 630 of file data.c.

References DATA_CMP_EQ, DATA_CMP_GE, DATA_CMP_GT, DATA_CMP_LE, DATA_CMP_LT, DATA_CMP_NEQ, and DATA_CMP_UNKNOWN.

Referenced by data_search_generate().

00631 {
00632    if (!strcmp(comparison, "=")) {
00633       return DATA_CMP_EQ;
00634    } else if (!strcmp(comparison, "!=")) {
00635       return DATA_CMP_NEQ;
00636    } else if (!strcmp(comparison, "<")) {
00637       return DATA_CMP_LT;
00638    } else if (!strcmp(comparison, ">")) {
00639       return DATA_CMP_GT;
00640    } else if (!strcmp(comparison, "<=")) {
00641       return DATA_CMP_LE;
00642    } else if (!strcmp(comparison, ">=")) {
00643       return DATA_CMP_GE;
00644    }
00645 
00646    return DATA_CMP_UNKNOWN;
00647 }

static struct ast_data_search* data_search_create ( struct ao2_container parent,
const char *  path 
) [static, read]

Definition at line 771 of file data.c.

References ao2_ref, ast_strdupa, ast_data_search::children, data_search_add_child(), data_search_find(), and next_node_name().

Referenced by data_search_generate().

00773 {
00774    char *rpath, *node_name;
00775    struct ast_data_search *child = NULL;
00776    struct ao2_container *current = parent;
00777 
00778    rpath = ast_strdupa(path);
00779 
00780    node_name = next_node_name(&rpath);
00781    while (node_name) {
00782       child = data_search_find(current, node_name);
00783       if (!child) {
00784          child = data_search_add_child(current, node_name);
00785       }
00786       ao2_ref(child, -1);
00787       current = child->children;
00788       node_name = next_node_name(&rpath);
00789    }
00790 
00791    return child;
00792 }

static void data_search_destructor ( void *  obj  )  [static]

Definition at line 673 of file data.c.

References ao2_ref, ast_free, ast_data_search::children, and ast_data_search::value.

Referenced by data_search_alloc().

00674 {
00675    struct ast_data_search *node = obj;
00676 
00677    if (node->value) {
00678       ast_free(node->value);
00679    }
00680 
00681    ao2_ref(node->children, -1);
00682 }

static struct ast_data_search* data_search_find ( struct ao2_container parent,
const char *  name 
) [static, read]

Definition at line 722 of file data.c.

References ao2_find, ao2_ref, data_search_alloc(), and OBJ_POINTER.

Referenced by ast_data_search_match(), data_result_generate(), data_result_generate_node(), data_search_create(), and data_search_get_node().

00724 {
00725    struct ast_data_search *find_node, *found;
00726 
00727    find_node = data_search_alloc(name);
00728    if (!find_node) {
00729       return NULL;
00730    }
00731 
00732    found = ao2_find(parent, find_node, OBJ_POINTER);
00733 
00734    /* free the created node used for searching. */
00735    ao2_ref(find_node, -1);
00736 
00737    return found;
00738 }

static struct ast_data_search* data_search_generate ( const char *  search_string  )  [static, read]

Definition at line 801 of file data.c.

References ast_free, ast_log(), ast_str_append(), ast_str_buffer(), ast_str_create(), ast_str_reset(), ast_strdup, ast_strdupa, ast_data_search::children, ast_data_search::cmp_type, DATA_CMP_UNKNOWN, data_search_alloc(), data_search_comparison_char(), data_search_comparison_type(), data_search_create(), LOG_ERROR, data_filter::name, ast_data_search::value, and value.

Referenced by data_result_generate().

00802 {
00803    struct ast_str *name, *value, *comparison;
00804    char *elements, *search_string_dup, *saveptr;
00805    int i;
00806    struct ast_data_search *root, *child;
00807    enum data_search_comparison cmp_type;
00808    size_t search_string_len;
00809 
00810    if (!search_string) {
00811       ast_log(LOG_ERROR, "You must pass a valid search string.\n");
00812       return NULL;
00813    }
00814 
00815    search_string_len = strlen(search_string);
00816 
00817    name = ast_str_create(search_string_len);
00818    if (!name) {
00819       return NULL;
00820    }
00821    value = ast_str_create(search_string_len);
00822    if (!value) {
00823       ast_free(name);
00824       return NULL;
00825    }
00826    comparison = ast_str_create(search_string_len);
00827    if (!comparison) {
00828       ast_free(name);
00829       ast_free(value);
00830       return NULL;
00831    }
00832 
00833    search_string_dup = ast_strdupa(search_string);
00834 
00835    /* Create the root node (just used as a container) */
00836    root = data_search_alloc("/");
00837    if (!root) {
00838       ast_free(name);
00839       ast_free(value);
00840       ast_free(comparison);
00841       return NULL;
00842    }
00843 
00844    for (elements = strtok_r(search_string_dup, ",", &saveptr); elements;
00845       elements = strtok_r(NULL, ",", &saveptr)) {
00846       /* Parse the name */
00847       ast_str_reset(name);
00848       for (i = 0; !data_search_comparison_char(elements[i]) &&
00849          elements[i]; i++) {
00850          ast_str_append(&name, 0, "%c", elements[i]);
00851       }
00852 
00853       /* check if the syntax is ok. */
00854       if (!data_search_comparison_char(elements[i])) {
00855          /* if this is the end of the string, then this is
00856           * an error! */
00857          ast_log(LOG_ERROR, "Invalid search string!\n");
00858          continue;
00859       }
00860 
00861       /* parse the comparison string. */
00862       ast_str_reset(comparison);
00863       for (; data_search_comparison_char(elements[i]) && elements[i]; i++) {
00864          ast_str_append(&comparison, 0, "%c", elements[i]);
00865       }
00866 
00867       /* parse the value string. */
00868       ast_str_reset(value);
00869       for (; elements[i]; i++) {
00870          ast_str_append(&value, 0, "%c", elements[i]);
00871       }
00872 
00873       cmp_type = data_search_comparison_type(ast_str_buffer(comparison));
00874       if (cmp_type == DATA_CMP_UNKNOWN) {
00875          ast_log(LOG_ERROR, "Invalid comparison '%s'\n",
00876             ast_str_buffer(comparison));
00877          continue;
00878       }
00879 
00880       /* add this node to the tree. */
00881       child = data_search_create(root->children, ast_str_buffer(name));
00882       if (child) {
00883          child->cmp_type = cmp_type;
00884          child->value = ast_strdup(ast_str_buffer(value));
00885       }
00886    }
00887 
00888    ast_free(name);
00889    ast_free(value);
00890    ast_free(comparison);
00891 
00892    return root;
00893 }

static struct ast_data_search* data_search_get_node ( const struct ast_data_search node,
const char *  path 
) [static, read]

Definition at line 962 of file data.c.

References ao2_ref, ast_strdupa, ast_data_search::children, data_search_find(), and next_node_name().

Referenced by __ast_data_search_cmp_structure(), data_search_cmp_bool(), data_search_cmp_char(), data_search_cmp_dbl(), data_search_cmp_int(), data_search_cmp_ipaddr(), data_search_cmp_ptr(), data_search_cmp_string(), and data_search_cmp_uint().

00964 {
00965    char *savepath, *node_name;
00966    struct ast_data_search *child, *current = (struct ast_data_search *) node;
00967 
00968    if (!node) {
00969       return NULL;
00970    }
00971 
00972    savepath = ast_strdupa(path);
00973    node_name = next_node_name(&savepath);
00974 
00975    while (node_name) {
00976       child = data_search_find(current->children, node_name);
00977       if (current != node) {
00978          ao2_ref(current, -1);
00979       }
00980       if (!child) {
00981          return NULL;
00982       };
00983       current = child;
00984       node_name = next_node_name(&savepath);
00985    }
00986 
00987    return current;
00988 }

static int data_search_hash ( const void *  obj,
const int  flags 
) [static]

Definition at line 653 of file data.c.

References ast_str_hash(), and ast_data_search::name.

Referenced by data_search_alloc().

00654 {
00655    const struct ast_data_search *node = obj;
00656    return ast_str_hash(node->name);
00657 }

static int data_search_mapping_find ( const struct ast_data_mapping_structure map,
size_t  mapping_len,
const char *  member_name 
) [inline, static]

Definition at line 1257 of file data.c.

References data_filter::name.

Referenced by __ast_data_search_cmp_structure().

01260 {
01261    int i;
01262 
01263    for (i = 0; i < mapping_len; i++) {
01264       if (!strcmp(map[i].name, member_name)) {
01265          return i;
01266       }
01267    }
01268 
01269    return -1;
01270 }

static void data_search_release ( struct ast_data_search search  )  [static]

Definition at line 900 of file data.c.

References ao2_ref.

Referenced by data_result_generate().

00901 {
00902    ao2_ref(search, -1);
00903 }

static void data_shutdown ( void   )  [static]

Definition at line 3287 of file data.c.

References ao2_t_ref, ARRAY_LEN, ast_cli_unregister_multiple(), ast_manager_unregister(), ast_rwlock_destroy, AST_TEST_UNREGISTER, cli_data, and root_data.

Referenced by ast_data_init().

03288 {
03289    ast_manager_unregister("DataGet");
03290    ast_cli_unregister_multiple(cli_data, ARRAY_LEN(cli_data));
03291    ao2_t_ref(root_data.container, -1, "Unref root_data.container in data_shutdown");
03292    root_data.container = NULL;
03293    ast_rwlock_destroy(&root_data.lock);
03294    AST_TEST_UNREGISTER(test_data_get);
03295 }

static int data_structure_compatible ( int  structure_version,
uint32_t  latest_compatible,
uint32_t  current 
) [static]

Definition at line 255 of file data.c.

References ast_log(), and LOG_ERROR.

Referenced by __ast_data_register(), and ast_data_get().

00257 {
00258    if (structure_version >= latest_compatible && structure_version <= current) {
00259       return 1;
00260    }
00261 
00262    ast_log(LOG_ERROR, "A module is not compatible with the"
00263       "current data api version\n");
00264 
00265    return 0;
00266 }

static char* handle_cli_data_get ( struct ast_cli_entry e,
int  cmd,
struct ast_cli_args a 
) [static]

Definition at line 2867 of file data.c.

References ast_cli_args::argc, ast_cli_entry::args, ast_cli_args::argv, ast_data_free(), ast_data_get(), AST_DATA_QUERY_VERSION, CLI_FAILURE, CLI_GENERATE, CLI_INIT, CLI_SHOWUSAGE, CLI_SUCCESS, ast_cli_entry::command, data_result_print_cli(), ast_cli_args::fd, ast_data_query::filter, ast_data_query::path, ast_data_query::search, ast_cli_entry::usage, and ast_data_query::version.

02869 {
02870    struct ast_data_query query = {
02871       .version = AST_DATA_QUERY_VERSION
02872    };
02873    struct ast_data *tree;
02874 
02875    switch (cmd) {
02876    case CLI_INIT:
02877       e->command = "data get";
02878       e->usage = ""
02879          "Usage: data get <path> [<search> [<filter>]]\n"
02880          "       Get the tree based on a path.\n";
02881       return NULL;
02882    case CLI_GENERATE:
02883       return NULL;
02884    }
02885 
02886    if (a->argc < e->args + 1) {
02887       return CLI_SHOWUSAGE;
02888    }
02889 
02890    query.path = (char *) a->argv[e->args];
02891 
02892    if (a->argc > e->args + 1) {
02893       query.search = (char *) a->argv[e->args + 1];
02894    }
02895 
02896    if (a->argc > e->args + 2) {
02897       query.filter = (char *) a->argv[e->args + 2];
02898    }
02899 
02900    tree = ast_data_get(&query);
02901    if (!tree) {
02902       return CLI_FAILURE;
02903    }
02904 
02905    data_result_print_cli(a->fd, tree);
02906 
02907    ast_data_free(tree);
02908 
02909    return CLI_SUCCESS;
02910 }

static char* handle_cli_data_show_providers ( struct ast_cli_entry e,
int  cmd,
struct ast_cli_args a 
) [static]

Definition at line 2963 of file data.c.

References CLI_GENERATE, CLI_INIT, CLI_SUCCESS, ast_cli_entry::command, data_provider_print_cli(), data_read_lock, data_unlock, ast_cli_args::fd, root_data, and ast_cli_entry::usage.

02965 {
02966    switch (cmd) {
02967    case CLI_INIT:
02968       e->command = "data show providers";
02969       e->usage = ""
02970          "Usage: data show providers\n"
02971          "       Show the list of registered providers\n";
02972       return NULL;
02973    case CLI_GENERATE:
02974       return NULL;
02975    }
02976 
02977    data_read_lock();
02978    data_provider_print_cli(a->fd, "", root_data.container, NULL);
02979    data_unlock();
02980 
02981    return CLI_SUCCESS;
02982 }

static int manager_data_get ( struct mansession s,
const struct message m 
) [static]

Definition at line 3075 of file data.c.

References ast_data_free(), ast_data_get(), AST_DATA_QUERY_VERSION, ast_strlen_zero(), astman_append(), astman_get_header(), astman_send_error(), ast_data::children, data_result_manager_output(), filter(), ast_data::name, RESULT_SUCCESS, and ast_data_query::version.

Referenced by ast_data_init().

03076 {
03077    const char *path = astman_get_header(m, "Path");
03078    const char *search = astman_get_header(m, "Search");
03079    const char *filter = astman_get_header(m, "Filter");
03080    const char *id = astman_get_header(m, "ActionID");
03081    struct ast_data *res;
03082    struct ast_data_query query = {
03083       .version = AST_DATA_QUERY_VERSION,
03084       .path = (char *) path,
03085       .search = (char *) search,
03086       .filter = (char *) filter,
03087    };
03088 
03089    if (ast_strlen_zero(path)) {
03090       astman_send_error(s, m, "'Path' parameter not specified");
03091       return 0;
03092    }
03093 
03094    res = ast_data_get(&query);
03095    if (!res) {
03096       astman_send_error(s, m, "No data returned");
03097       return 0;
03098    }
03099 
03100    astman_append(s, "Event: DataGet Tree\r\n");
03101    if (!ast_strlen_zero(id)) {
03102       astman_append(s, "ActionID: %s\r\n", id);
03103    }
03104    data_result_manager_output(s, res->name, res->children, NULL, 0);
03105    astman_append(s, "\r\n");
03106 
03107    ast_data_free(res);
03108 
03109    return RESULT_SUCCESS;
03110 }

static char* next_node_name ( char **  path  )  [static]

Definition at line 276 of file data.c.

References ast_strlen_zero().

Referenced by data_filter_add_nodes(), data_provider_create(), data_provider_release(), data_result_generate(), data_result_get_node(), data_search_create(), and data_search_get_node().

00277 {
00278    char *res;
00279 
00280    do {
00281       res = strsep(path, "/");
00282    } while (res && ast_strlen_zero(res));
00283 
00284    return res;
00285 }


Variable Documentation

struct ast_cli_entry cli_data[] [static]
Initial value:

Definition at line 2988 of file data.c.

Referenced by ast_data_init(), and data_shutdown().

int color

Definition at line 2664 of file data.c.

The asterisk data main content structure.

Definition at line 177 of file data.c.

Referenced by ast_event_get_cached(), ast_event_init(), ast_event_queue_and_cache(), event_dump_cache(), and event_shutdown().

const uint32_t current_handler_version = AST_DATA_HANDLER_VERSION [static]

Current handler structure version.

Definition at line 78 of file data.c.

const uint32_t current_query_version = AST_DATA_QUERY_VERSION [static]

Current query structure version.

Definition at line 81 of file data.c.

struct { ... } data_result_color[] [static]

Referenced by data_result_get_color().

const uint32_t latest_handler_compatible_version = 0 [static]

The last compatible version.

Definition at line 72 of file data.c.

const uint32_t latest_query_compatible_version = 0 [static]

The last compatible version.

Definition at line 75 of file data.c.

asterisk data locking mechanism.

Definition at line 179 of file data.c.

struct { ... } root_data
enum ast_data_type type

Definition at line 2663 of file data.c.


Generated on 31 Aug 2015 for Asterisk - The Open Source Telephony Project by  doxygen 1.6.1