mirror of
				https://git.proxmox.com/git/mirror_frr
				synced 2025-11-04 13:43:22 +00:00 
			
		
		
		
	Compile with v2.0.0 tag of `libyang2` branch of: https://github.com/CESNET/libyang staticd init load time of 10k routes now 6s vs ly1 time of 150s Signed-off-by: Christian Hopps <chopps@labn.net>
		
			
				
	
	
		
			915 lines
		
	
	
		
			20 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
			
		
		
	
	
			915 lines
		
	
	
		
			20 KiB
		
	
	
	
		
			C
		
	
	
	
	
	
/*
 | 
						|
 * Copyright (C) 2018  NetDEF, Inc.
 | 
						|
 *                     Renato Westphal
 | 
						|
 *
 | 
						|
 * This program is free software; you can redistribute it and/or modify it
 | 
						|
 * under the terms of the GNU General Public License as published by the Free
 | 
						|
 * Software Foundation; either version 2 of the License, or (at your option)
 | 
						|
 * any later version.
 | 
						|
 *
 | 
						|
 * This program is distributed in the hope that it will be useful, but WITHOUT
 | 
						|
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 | 
						|
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License for
 | 
						|
 * more details.
 | 
						|
 *
 | 
						|
 * You should have received a copy of the GNU General Public License along
 | 
						|
 * with this program; see the file COPYING; if not, write to the Free Software
 | 
						|
 * Foundation, Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA
 | 
						|
 */
 | 
						|
 | 
						|
#include <zebra.h>
 | 
						|
 | 
						|
#include "log.h"
 | 
						|
#include "lib_errors.h"
 | 
						|
#include "yang.h"
 | 
						|
#include "yang_translator.h"
 | 
						|
#include "northbound.h"
 | 
						|
 | 
						|
DEFINE_MTYPE_STATIC(LIB, YANG_MODULE, "YANG module");
 | 
						|
DEFINE_MTYPE_STATIC(LIB, YANG_DATA, "YANG data structure");
 | 
						|
 | 
						|
/* libyang container. */
 | 
						|
struct ly_ctx *ly_native_ctx;
 | 
						|
 | 
						|
static struct yang_module_embed *embeds, **embedupd = &embeds;
 | 
						|
 | 
						|
void yang_module_embed(struct yang_module_embed *embed)
 | 
						|
{
 | 
						|
	embed->next = NULL;
 | 
						|
	*embedupd = embed;
 | 
						|
	embedupd = &embed->next;
 | 
						|
}
 | 
						|
 | 
						|
static LY_ERR yang_module_imp_clb(const char *mod_name, const char *mod_rev,
 | 
						|
				  const char *submod_name,
 | 
						|
				  const char *submod_rev, void *user_data,
 | 
						|
				  LYS_INFORMAT *format,
 | 
						|
				  const char **module_data,
 | 
						|
				  void (**free_module_data)(void *, void *))
 | 
						|
{
 | 
						|
	struct yang_module_embed *e;
 | 
						|
 | 
						|
	for (e = embeds; e; e = e->next) {
 | 
						|
		if (e->sub_mod_name && submod_name) {
 | 
						|
			if (strcmp(e->sub_mod_name, submod_name))
 | 
						|
				continue;
 | 
						|
 | 
						|
			if (submod_rev && strcmp(e->sub_mod_rev, submod_rev))
 | 
						|
				continue;
 | 
						|
		} else {
 | 
						|
			if (strcmp(e->mod_name, mod_name))
 | 
						|
				continue;
 | 
						|
 | 
						|
			if (mod_rev && strcmp(e->mod_rev, mod_rev))
 | 
						|
				continue;
 | 
						|
		}
 | 
						|
 | 
						|
		*format = e->format;
 | 
						|
		*module_data = e->data;
 | 
						|
		return LY_SUCCESS;
 | 
						|
	}
 | 
						|
 | 
						|
	/* We get here for indirect modules like ietf-inet-types */
 | 
						|
	zlog_debug(
 | 
						|
		"YANG model \"%s@%s\" \"%s@%s\"not embedded, trying external file",
 | 
						|
		mod_name, mod_rev ? mod_rev : "*",
 | 
						|
		submod_name ? submod_name : "*", submod_rev ? submod_rev : "*");
 | 
						|
 | 
						|
	return LY_ENOTFOUND;
 | 
						|
}
 | 
						|
 | 
						|
/* clang-format off */
 | 
						|
static const char *const frr_native_modules[] = {
 | 
						|
	"frr-interface",
 | 
						|
	"frr-vrf",
 | 
						|
	"frr-routing",
 | 
						|
	"frr-route-map",
 | 
						|
	"frr-nexthop",
 | 
						|
	"frr-ripd",
 | 
						|
	"frr-ripngd",
 | 
						|
	"frr-isisd",
 | 
						|
	"frr-vrrpd",
 | 
						|
	"frr-zebra",
 | 
						|
	"frr-pathd",
 | 
						|
};
 | 
						|
/* clang-format on */
 | 
						|
 | 
						|
/* Generate the yang_modules tree. */
 | 
						|
static inline int yang_module_compare(const struct yang_module *a,
 | 
						|
				      const struct yang_module *b)
 | 
						|
{
 | 
						|
	return strcmp(a->name, b->name);
 | 
						|
}
 | 
						|
RB_GENERATE(yang_modules, yang_module, entry, yang_module_compare)
 | 
						|
 | 
						|
struct yang_modules yang_modules = RB_INITIALIZER(&yang_modules);
 | 
						|
 | 
						|
struct yang_module *yang_module_load(const char *module_name)
 | 
						|
{
 | 
						|
	struct yang_module *module;
 | 
						|
	const struct lys_module *module_info;
 | 
						|
 | 
						|
	module_info =
 | 
						|
		ly_ctx_load_module(ly_native_ctx, module_name, NULL, NULL);
 | 
						|
	if (!module_info) {
 | 
						|
		flog_err(EC_LIB_YANG_MODULE_LOAD,
 | 
						|
			 "%s: failed to load data model: %s", __func__,
 | 
						|
			 module_name);
 | 
						|
		exit(1);
 | 
						|
	}
 | 
						|
 | 
						|
	module = XCALLOC(MTYPE_YANG_MODULE, sizeof(*module));
 | 
						|
	module->name = module_name;
 | 
						|
	module->info = module_info;
 | 
						|
 | 
						|
	if (RB_INSERT(yang_modules, &yang_modules, module) != NULL) {
 | 
						|
		flog_err(EC_LIB_YANG_MODULE_LOADED_ALREADY,
 | 
						|
			 "%s: YANG module is loaded already: %s", __func__,
 | 
						|
			 module_name);
 | 
						|
		exit(1);
 | 
						|
	}
 | 
						|
 | 
						|
	return module;
 | 
						|
}
 | 
						|
 | 
						|
void yang_module_load_all(void)
 | 
						|
{
 | 
						|
	for (size_t i = 0; i < array_size(frr_native_modules); i++)
 | 
						|
		yang_module_load(frr_native_modules[i]);
 | 
						|
}
 | 
						|
 | 
						|
struct yang_module *yang_module_find(const char *module_name)
 | 
						|
{
 | 
						|
	struct yang_module s;
 | 
						|
 | 
						|
	s.name = module_name;
 | 
						|
	return RB_FIND(yang_modules, &yang_modules, &s);
 | 
						|
}
 | 
						|
 | 
						|
int yang_snodes_iterate_subtree(const struct lysc_node *snode,
 | 
						|
				const struct lys_module *module,
 | 
						|
				yang_iterate_cb cb, uint16_t flags, void *arg)
 | 
						|
{
 | 
						|
	const struct lysc_node *child;
 | 
						|
	int ret = YANG_ITER_CONTINUE;
 | 
						|
 | 
						|
	if (module && snode->module != module)
 | 
						|
		goto next;
 | 
						|
 | 
						|
	switch (snode->nodetype) {
 | 
						|
	case LYS_CONTAINER:
 | 
						|
		if (CHECK_FLAG(flags, YANG_ITER_FILTER_NPCONTAINERS)) {
 | 
						|
			if (!CHECK_FLAG(snode->flags, LYS_PRESENCE))
 | 
						|
				goto next;
 | 
						|
		}
 | 
						|
		break;
 | 
						|
	case LYS_LEAF:
 | 
						|
		if (CHECK_FLAG(flags, YANG_ITER_FILTER_LIST_KEYS)) {
 | 
						|
			/* Ignore list keys. */
 | 
						|
			if (lysc_is_key(snode))
 | 
						|
				goto next;
 | 
						|
		}
 | 
						|
		break;
 | 
						|
	case LYS_INPUT:
 | 
						|
	case LYS_OUTPUT:
 | 
						|
		if (CHECK_FLAG(flags, YANG_ITER_FILTER_INPUT_OUTPUT))
 | 
						|
			goto next;
 | 
						|
		break;
 | 
						|
	default:
 | 
						|
		assert(snode->nodetype != LYS_AUGMENT
 | 
						|
		       && snode->nodetype != LYS_GROUPING
 | 
						|
		       && snode->nodetype != LYS_USES);
 | 
						|
		break;
 | 
						|
	}
 | 
						|
 | 
						|
	ret = (*cb)(snode, arg);
 | 
						|
	if (ret == YANG_ITER_STOP)
 | 
						|
		return ret;
 | 
						|
 | 
						|
next:
 | 
						|
	/*
 | 
						|
	 * YANG leafs and leaf-lists can't have child nodes.
 | 
						|
	 */
 | 
						|
	if (CHECK_FLAG(snode->nodetype, LYS_LEAF | LYS_LEAFLIST))
 | 
						|
		return YANG_ITER_CONTINUE;
 | 
						|
 | 
						|
	LY_LIST_FOR (lysc_node_child(snode), child) {
 | 
						|
		ret = yang_snodes_iterate_subtree(child, module, cb, flags,
 | 
						|
						  arg);
 | 
						|
		if (ret == YANG_ITER_STOP)
 | 
						|
			return ret;
 | 
						|
	}
 | 
						|
	return ret;
 | 
						|
}
 | 
						|
 | 
						|
int yang_snodes_iterate(const struct lys_module *module, yang_iterate_cb cb,
 | 
						|
			uint16_t flags, void *arg)
 | 
						|
{
 | 
						|
	const struct lys_module *module_iter;
 | 
						|
	uint32_t idx = 0;
 | 
						|
	int ret = YANG_ITER_CONTINUE;
 | 
						|
 | 
						|
	idx = ly_ctx_internal_modules_count(ly_native_ctx);
 | 
						|
	while ((module_iter = ly_ctx_get_module_iter(ly_native_ctx, &idx))) {
 | 
						|
		struct lysc_node *snode;
 | 
						|
 | 
						|
		if (!module_iter->implemented)
 | 
						|
			continue;
 | 
						|
 | 
						|
		LY_LIST_FOR (module_iter->compiled->data, snode) {
 | 
						|
			ret = yang_snodes_iterate_subtree(snode, module, cb,
 | 
						|
							  flags, arg);
 | 
						|
			if (ret == YANG_ITER_STOP)
 | 
						|
				return ret;
 | 
						|
		}
 | 
						|
		LY_LIST_FOR (&module_iter->compiled->rpcs->node, snode) {
 | 
						|
			ret = yang_snodes_iterate_subtree(snode, module, cb,
 | 
						|
							  flags, arg);
 | 
						|
			if (ret == YANG_ITER_STOP)
 | 
						|
				return ret;
 | 
						|
		}
 | 
						|
		LY_LIST_FOR (&module_iter->compiled->notifs->node, snode) {
 | 
						|
			ret = yang_snodes_iterate_subtree(snode, module, cb,
 | 
						|
							  flags, arg);
 | 
						|
			if (ret == YANG_ITER_STOP)
 | 
						|
				return ret;
 | 
						|
		}
 | 
						|
	}
 | 
						|
 | 
						|
	return ret;
 | 
						|
}
 | 
						|
 | 
						|
void yang_snode_get_path(const struct lysc_node *snode,
 | 
						|
			 enum yang_path_type type, char *xpath,
 | 
						|
			 size_t xpath_len)
 | 
						|
{
 | 
						|
	switch (type) {
 | 
						|
	case YANG_PATH_SCHEMA:
 | 
						|
		(void)lysc_path(snode, LYSC_PATH_LOG, xpath, xpath_len);
 | 
						|
		break;
 | 
						|
	case YANG_PATH_DATA:
 | 
						|
		(void)lysc_path(snode, LYSC_PATH_DATA, xpath, xpath_len);
 | 
						|
		break;
 | 
						|
	default:
 | 
						|
		flog_err(EC_LIB_DEVELOPMENT, "%s: unknown yang path type: %u",
 | 
						|
			 __func__, type);
 | 
						|
		exit(1);
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
struct lysc_node *yang_snode_real_parent(const struct lysc_node *snode)
 | 
						|
{
 | 
						|
	struct lysc_node *parent = snode->parent;
 | 
						|
 | 
						|
	while (parent) {
 | 
						|
		switch (parent->nodetype) {
 | 
						|
		case LYS_CONTAINER:
 | 
						|
			if (CHECK_FLAG(parent->flags, LYS_PRESENCE))
 | 
						|
				return parent;
 | 
						|
			break;
 | 
						|
		case LYS_LIST:
 | 
						|
			return parent;
 | 
						|
		default:
 | 
						|
			break;
 | 
						|
		}
 | 
						|
		parent = parent->parent;
 | 
						|
	}
 | 
						|
 | 
						|
	return NULL;
 | 
						|
}
 | 
						|
 | 
						|
struct lysc_node *yang_snode_parent_list(const struct lysc_node *snode)
 | 
						|
{
 | 
						|
	struct lysc_node *parent = snode->parent;
 | 
						|
 | 
						|
	while (parent) {
 | 
						|
		switch (parent->nodetype) {
 | 
						|
		case LYS_LIST:
 | 
						|
			return parent;
 | 
						|
		default:
 | 
						|
			break;
 | 
						|
		}
 | 
						|
		parent = parent->parent;
 | 
						|
	}
 | 
						|
 | 
						|
	return NULL;
 | 
						|
}
 | 
						|
 | 
						|
bool yang_snode_is_typeless_data(const struct lysc_node *snode)
 | 
						|
{
 | 
						|
	const struct lysc_node_leaf *sleaf;
 | 
						|
 | 
						|
	switch (snode->nodetype) {
 | 
						|
	case LYS_LEAF:
 | 
						|
		sleaf = (struct lysc_node_leaf *)snode;
 | 
						|
		if (sleaf->type->basetype == LY_TYPE_EMPTY)
 | 
						|
			return true;
 | 
						|
		return false;
 | 
						|
	case LYS_LEAFLIST:
 | 
						|
		return false;
 | 
						|
	default:
 | 
						|
		return true;
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
const char *yang_snode_get_default(const struct lysc_node *snode)
 | 
						|
{
 | 
						|
	const struct lysc_node_leaf *sleaf;
 | 
						|
 | 
						|
	switch (snode->nodetype) {
 | 
						|
	case LYS_LEAF:
 | 
						|
		sleaf = (const struct lysc_node_leaf *)snode;
 | 
						|
		return sleaf->dflt ? lyd_value_get_canonical(sleaf->module->ctx,
 | 
						|
							     sleaf->dflt)
 | 
						|
				   : NULL;
 | 
						|
	case LYS_LEAFLIST:
 | 
						|
		/* TODO: check leaf-list default values */
 | 
						|
		return NULL;
 | 
						|
	default:
 | 
						|
		return NULL;
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
const struct lysc_type *yang_snode_get_type(const struct lysc_node *snode)
 | 
						|
{
 | 
						|
	struct lysc_node_leaf *sleaf = (struct lysc_node_leaf *)snode;
 | 
						|
	struct lysc_type *type;
 | 
						|
 | 
						|
	if (!CHECK_FLAG(sleaf->nodetype, LYS_LEAF | LYS_LEAFLIST))
 | 
						|
		return NULL;
 | 
						|
 | 
						|
	type = sleaf->type;
 | 
						|
	while (type->basetype == LY_TYPE_LEAFREF)
 | 
						|
		type = ((struct lysc_type_leafref *)type)->realtype;
 | 
						|
 | 
						|
	return type;
 | 
						|
}
 | 
						|
 | 
						|
unsigned int yang_snode_num_keys(const struct lysc_node *snode)
 | 
						|
{
 | 
						|
	const struct lysc_node_leaf *skey;
 | 
						|
	uint count = 0;
 | 
						|
 | 
						|
	if (!CHECK_FLAG(snode->nodetype, LYS_LIST))
 | 
						|
		return 0;
 | 
						|
 | 
						|
	/* Walk list of children */
 | 
						|
	LY_FOR_KEYS (snode, skey) {
 | 
						|
		count++;
 | 
						|
	}
 | 
						|
	return count;
 | 
						|
}
 | 
						|
 | 
						|
void yang_dnode_get_path(const struct lyd_node *dnode, char *xpath,
 | 
						|
			 size_t xpath_len)
 | 
						|
{
 | 
						|
	lyd_path(dnode, LYD_PATH_STD, xpath, xpath_len);
 | 
						|
}
 | 
						|
 | 
						|
const char *yang_dnode_get_schema_name(const struct lyd_node *dnode,
 | 
						|
				       const char *xpath_fmt, ...)
 | 
						|
{
 | 
						|
	if (xpath_fmt) {
 | 
						|
		va_list ap;
 | 
						|
		char xpath[XPATH_MAXLEN];
 | 
						|
 | 
						|
		va_start(ap, xpath_fmt);
 | 
						|
		vsnprintf(xpath, sizeof(xpath), xpath_fmt, ap);
 | 
						|
		va_end(ap);
 | 
						|
 | 
						|
		dnode = yang_dnode_get(dnode, xpath);
 | 
						|
		if (!dnode) {
 | 
						|
			flog_err(EC_LIB_YANG_DNODE_NOT_FOUND,
 | 
						|
				 "%s: couldn't find %s", __func__, xpath);
 | 
						|
			zlog_backtrace(LOG_ERR);
 | 
						|
			abort();
 | 
						|
		}
 | 
						|
	}
 | 
						|
 | 
						|
	return dnode->schema->name;
 | 
						|
}
 | 
						|
 | 
						|
struct lyd_node *yang_dnode_get(const struct lyd_node *dnode, const char *xpath)
 | 
						|
{
 | 
						|
	struct ly_set *set = NULL;
 | 
						|
	struct lyd_node *dnode_ret = NULL;
 | 
						|
 | 
						|
	/*
 | 
						|
	 * XXX a lot of the code uses this for style I guess. It shouldn't, as
 | 
						|
	 * it adds to the xpath parsing complexity in libyang.
 | 
						|
	 */
 | 
						|
	if (xpath[0] == '.' && xpath[1] == '/')
 | 
						|
		xpath += 2;
 | 
						|
 | 
						|
	if (lyd_find_xpath(dnode, xpath, &set)) {
 | 
						|
		assert(0); /* XXX replicates old libyang1 base code */
 | 
						|
		goto exit;
 | 
						|
	}
 | 
						|
	if (set->count == 0)
 | 
						|
		goto exit;
 | 
						|
 | 
						|
	if (set->count > 1) {
 | 
						|
		flog_warn(EC_LIB_YANG_DNODE_NOT_FOUND,
 | 
						|
			  "%s: found %u elements (expected 0 or 1) [xpath %s]",
 | 
						|
			  __func__, set->count, xpath);
 | 
						|
		goto exit;
 | 
						|
	}
 | 
						|
 | 
						|
	dnode_ret = set->dnodes[0];
 | 
						|
 | 
						|
exit:
 | 
						|
	ly_set_free(set, NULL);
 | 
						|
 | 
						|
	return dnode_ret;
 | 
						|
}
 | 
						|
 | 
						|
struct lyd_node *yang_dnode_getf(const struct lyd_node *dnode,
 | 
						|
				 const char *xpath_fmt, ...)
 | 
						|
{
 | 
						|
	va_list ap;
 | 
						|
	char xpath[XPATH_MAXLEN];
 | 
						|
 | 
						|
	va_start(ap, xpath_fmt);
 | 
						|
	vsnprintf(xpath, sizeof(xpath), xpath_fmt, ap);
 | 
						|
	va_end(ap);
 | 
						|
 | 
						|
	return yang_dnode_get(dnode, xpath);
 | 
						|
}
 | 
						|
 | 
						|
bool yang_dnode_exists(const struct lyd_node *dnode, const char *xpath)
 | 
						|
{
 | 
						|
	struct ly_set *set = NULL;
 | 
						|
	bool exists = false;
 | 
						|
 | 
						|
	if (xpath[0] == '.' && xpath[1] == '/')
 | 
						|
		xpath += 2;
 | 
						|
	if (lyd_find_xpath(dnode, xpath, &set))
 | 
						|
		return false;
 | 
						|
	exists = set->count > 0;
 | 
						|
	ly_set_free(set, NULL);
 | 
						|
	return exists;
 | 
						|
}
 | 
						|
 | 
						|
bool yang_dnode_existsf(const struct lyd_node *dnode, const char *xpath_fmt,
 | 
						|
			...)
 | 
						|
{
 | 
						|
	va_list ap;
 | 
						|
	char xpath[XPATH_MAXLEN];
 | 
						|
 | 
						|
	va_start(ap, xpath_fmt);
 | 
						|
	vsnprintf(xpath, sizeof(xpath), xpath_fmt, ap);
 | 
						|
	va_end(ap);
 | 
						|
 | 
						|
	return yang_dnode_exists(dnode, xpath);
 | 
						|
}
 | 
						|
 | 
						|
void yang_dnode_iterate(yang_dnode_iter_cb cb, void *arg,
 | 
						|
			const struct lyd_node *dnode, const char *xpath_fmt,
 | 
						|
			...)
 | 
						|
{
 | 
						|
	va_list ap;
 | 
						|
	char xpath[XPATH_MAXLEN];
 | 
						|
	struct ly_set *set;
 | 
						|
 | 
						|
	va_start(ap, xpath_fmt);
 | 
						|
	vsnprintf(xpath, sizeof(xpath), xpath_fmt, ap);
 | 
						|
	va_end(ap);
 | 
						|
 | 
						|
	if (lyd_find_xpath(dnode, xpath, &set)) {
 | 
						|
		assert(0); /* XXX libyang2: ly1 code asserted success */
 | 
						|
		return;
 | 
						|
	}
 | 
						|
	for (unsigned int i = 0; i < set->count; i++) {
 | 
						|
		int ret;
 | 
						|
 | 
						|
		ret = (*cb)(set->dnodes[i], arg);
 | 
						|
		if (ret == YANG_ITER_STOP)
 | 
						|
			break;
 | 
						|
	}
 | 
						|
 | 
						|
	ly_set_free(set, NULL);
 | 
						|
}
 | 
						|
 | 
						|
bool yang_dnode_is_default(const struct lyd_node *dnode, const char *xpath)
 | 
						|
{
 | 
						|
	const struct lysc_node *snode;
 | 
						|
	struct lysc_node_leaf *sleaf;
 | 
						|
 | 
						|
	if (xpath)
 | 
						|
		dnode = yang_dnode_get(dnode, xpath);
 | 
						|
 | 
						|
	assert(dnode);
 | 
						|
	snode = dnode->schema;
 | 
						|
	switch (snode->nodetype) {
 | 
						|
	case LYS_LEAF:
 | 
						|
		sleaf = (struct lysc_node_leaf *)snode;
 | 
						|
		if (sleaf->type->basetype == LY_TYPE_EMPTY)
 | 
						|
			return false;
 | 
						|
		return lyd_is_default(dnode);
 | 
						|
	case LYS_LEAFLIST:
 | 
						|
		/* TODO: check leaf-list default values */
 | 
						|
		return false;
 | 
						|
	case LYS_CONTAINER:
 | 
						|
		if (CHECK_FLAG(snode->flags, LYS_PRESENCE))
 | 
						|
			return false;
 | 
						|
		return true;
 | 
						|
	default:
 | 
						|
		return false;
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
bool yang_dnode_is_defaultf(const struct lyd_node *dnode, const char *xpath_fmt,
 | 
						|
			    ...)
 | 
						|
{
 | 
						|
	if (!xpath_fmt)
 | 
						|
		return yang_dnode_is_default(dnode, NULL);
 | 
						|
	else {
 | 
						|
		va_list ap;
 | 
						|
		char xpath[XPATH_MAXLEN];
 | 
						|
 | 
						|
		va_start(ap, xpath_fmt);
 | 
						|
		vsnprintf(xpath, sizeof(xpath), xpath_fmt, ap);
 | 
						|
		va_end(ap);
 | 
						|
 | 
						|
		return yang_dnode_is_default(dnode, xpath);
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
bool yang_dnode_is_default_recursive(const struct lyd_node *dnode)
 | 
						|
{
 | 
						|
	struct lyd_node *root, *dnode_iter;
 | 
						|
 | 
						|
	if (!yang_dnode_is_default(dnode, NULL))
 | 
						|
		return false;
 | 
						|
 | 
						|
	if (CHECK_FLAG(dnode->schema->nodetype, LYS_LEAF | LYS_LEAFLIST))
 | 
						|
		return true;
 | 
						|
 | 
						|
	LY_LIST_FOR (lyd_child(dnode), root) {
 | 
						|
		LYD_TREE_DFS_BEGIN (root, dnode_iter) {
 | 
						|
			if (!yang_dnode_is_default(dnode_iter, NULL))
 | 
						|
				return false;
 | 
						|
 | 
						|
			LYD_TREE_DFS_END(root, dnode_iter);
 | 
						|
		}
 | 
						|
	}
 | 
						|
 | 
						|
	return true;
 | 
						|
}
 | 
						|
 | 
						|
void yang_dnode_change_leaf(struct lyd_node *dnode, const char *value)
 | 
						|
{
 | 
						|
	assert(dnode->schema->nodetype == LYS_LEAF);
 | 
						|
	lyd_change_term(dnode, value);
 | 
						|
}
 | 
						|
 | 
						|
struct lyd_node *yang_dnode_new(struct ly_ctx *ly_ctx, bool config_only)
 | 
						|
{
 | 
						|
	struct lyd_node *dnode = NULL;
 | 
						|
	int options = config_only ? LYD_VALIDATE_NO_STATE : 0;
 | 
						|
 | 
						|
	if (lyd_validate_all(&dnode, ly_ctx, options, NULL) != 0) {
 | 
						|
		/* Should never happen. */
 | 
						|
		flog_err(EC_LIB_LIBYANG, "%s: lyd_validate() failed", __func__);
 | 
						|
		exit(1);
 | 
						|
	}
 | 
						|
 | 
						|
	return dnode;
 | 
						|
}
 | 
						|
 | 
						|
struct lyd_node *yang_dnode_dup(const struct lyd_node *dnode)
 | 
						|
{
 | 
						|
	struct lyd_node *dup = NULL;
 | 
						|
	LY_ERR err;
 | 
						|
	err = lyd_dup_siblings(dnode, NULL, LYD_DUP_RECURSIVE, &dup);
 | 
						|
	assert(!err);
 | 
						|
	return dup;
 | 
						|
}
 | 
						|
 | 
						|
void yang_dnode_free(struct lyd_node *dnode)
 | 
						|
{
 | 
						|
	while (dnode->parent)
 | 
						|
		dnode = lyd_parent(dnode);
 | 
						|
	lyd_free_all(dnode);
 | 
						|
}
 | 
						|
 | 
						|
struct yang_data *yang_data_new(const char *xpath, const char *value)
 | 
						|
{
 | 
						|
	struct yang_data *data;
 | 
						|
 | 
						|
	data = XCALLOC(MTYPE_YANG_DATA, sizeof(*data));
 | 
						|
	strlcpy(data->xpath, xpath, sizeof(data->xpath));
 | 
						|
	if (value)
 | 
						|
		data->value = strdup(value);
 | 
						|
 | 
						|
	return data;
 | 
						|
}
 | 
						|
 | 
						|
void yang_data_free(struct yang_data *data)
 | 
						|
{
 | 
						|
	if (data->value)
 | 
						|
		free(data->value);
 | 
						|
	XFREE(MTYPE_YANG_DATA, data);
 | 
						|
}
 | 
						|
 | 
						|
struct list *yang_data_list_new(void)
 | 
						|
{
 | 
						|
	struct list *list;
 | 
						|
 | 
						|
	list = list_new();
 | 
						|
	list->del = (void (*)(void *))yang_data_free;
 | 
						|
 | 
						|
	return list;
 | 
						|
}
 | 
						|
 | 
						|
struct yang_data *yang_data_list_find(const struct list *list,
 | 
						|
				      const char *xpath_fmt, ...)
 | 
						|
{
 | 
						|
	char xpath[XPATH_MAXLEN];
 | 
						|
	struct yang_data *data;
 | 
						|
	struct listnode *node;
 | 
						|
	va_list ap;
 | 
						|
 | 
						|
	va_start(ap, xpath_fmt);
 | 
						|
	vsnprintf(xpath, sizeof(xpath), xpath_fmt, ap);
 | 
						|
	va_end(ap);
 | 
						|
 | 
						|
	for (ALL_LIST_ELEMENTS_RO(list, node, data))
 | 
						|
		if (strmatch(data->xpath, xpath))
 | 
						|
			return data;
 | 
						|
 | 
						|
	return NULL;
 | 
						|
}
 | 
						|
 | 
						|
/* Make libyang log its errors using FRR logging infrastructure. */
 | 
						|
static void ly_log_cb(LY_LOG_LEVEL level, const char *msg, const char *path)
 | 
						|
{
 | 
						|
	int priority = LOG_ERR;
 | 
						|
 | 
						|
	switch (level) {
 | 
						|
	case LY_LLERR:
 | 
						|
		priority = LOG_ERR;
 | 
						|
		break;
 | 
						|
	case LY_LLWRN:
 | 
						|
		priority = LOG_WARNING;
 | 
						|
		break;
 | 
						|
	case LY_LLVRB:
 | 
						|
	case LY_LLDBG:
 | 
						|
		priority = LOG_DEBUG;
 | 
						|
		break;
 | 
						|
	}
 | 
						|
 | 
						|
	if (path)
 | 
						|
		zlog(priority, "libyang: %s (%s)", msg, path);
 | 
						|
	else
 | 
						|
		zlog(priority, "libyang: %s", msg);
 | 
						|
}
 | 
						|
 | 
						|
const char *yang_print_errors(struct ly_ctx *ly_ctx, char *buf, size_t buf_len)
 | 
						|
{
 | 
						|
	struct ly_err_item *ei;
 | 
						|
	const char *path;
 | 
						|
 | 
						|
	ei = ly_err_first(ly_ctx);
 | 
						|
	if (!ei)
 | 
						|
		return "";
 | 
						|
 | 
						|
	strlcpy(buf, "YANG error(s):\n", buf_len);
 | 
						|
	for (; ei; ei = ei->next) {
 | 
						|
		strlcat(buf, " ", buf_len);
 | 
						|
		strlcat(buf, ei->msg, buf_len);
 | 
						|
		strlcat(buf, "\n", buf_len);
 | 
						|
	}
 | 
						|
 | 
						|
	path = ly_errpath(ly_ctx);
 | 
						|
	if (path) {
 | 
						|
		strlcat(buf, " YANG path: ", buf_len);
 | 
						|
		strlcat(buf, path, buf_len);
 | 
						|
		strlcat(buf, "\n", buf_len);
 | 
						|
	}
 | 
						|
 | 
						|
	ly_err_clean(ly_ctx, NULL);
 | 
						|
 | 
						|
	return buf;
 | 
						|
}
 | 
						|
 | 
						|
void yang_debugging_set(bool enable)
 | 
						|
{
 | 
						|
	if (enable) {
 | 
						|
		ly_log_level(LY_LLDBG);
 | 
						|
		ly_log_dbg_groups(0xFF);
 | 
						|
	} else {
 | 
						|
		ly_log_level(LY_LLERR);
 | 
						|
		ly_log_dbg_groups(0);
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
struct ly_ctx *yang_ctx_new_setup(bool embedded_modules, bool explicit_compile)
 | 
						|
{
 | 
						|
	struct ly_ctx *ctx = NULL;
 | 
						|
	const char *yang_models_path = YANG_MODELS_PATH;
 | 
						|
	LY_ERR err;
 | 
						|
 | 
						|
	if (access(yang_models_path, R_OK | X_OK)) {
 | 
						|
		yang_models_path = NULL;
 | 
						|
		if (errno == ENOENT)
 | 
						|
			zlog_info("yang model directory \"%s\" does not exist",
 | 
						|
				  YANG_MODELS_PATH);
 | 
						|
		else
 | 
						|
			flog_err_sys(EC_LIB_LIBYANG,
 | 
						|
				     "cannot access yang model directory \"%s\"",
 | 
						|
				     YANG_MODELS_PATH);
 | 
						|
	}
 | 
						|
 | 
						|
	uint options = LY_CTX_NO_YANGLIBRARY | LY_CTX_DISABLE_SEARCHDIR_CWD;
 | 
						|
	if (explicit_compile)
 | 
						|
		options |= LY_CTX_EXPLICIT_COMPILE;
 | 
						|
	err = ly_ctx_new(yang_models_path, options, &ctx);
 | 
						|
	if (err)
 | 
						|
		return NULL;
 | 
						|
 | 
						|
	if (embedded_modules)
 | 
						|
		ly_ctx_set_module_imp_clb(ctx, yang_module_imp_clb, NULL);
 | 
						|
 | 
						|
	return ctx;
 | 
						|
}
 | 
						|
 | 
						|
void yang_init(bool embedded_modules, bool defer_compile)
 | 
						|
{
 | 
						|
	/* Initialize libyang global parameters that affect all containers. */
 | 
						|
	ly_set_log_clb(ly_log_cb, 1);
 | 
						|
	ly_log_options(LY_LOLOG | LY_LOSTORE);
 | 
						|
 | 
						|
	/* Initialize libyang container for native models. */
 | 
						|
	ly_native_ctx = yang_ctx_new_setup(embedded_modules, defer_compile);
 | 
						|
	if (!ly_native_ctx) {
 | 
						|
		flog_err(EC_LIB_LIBYANG, "%s: ly_ctx_new() failed", __func__);
 | 
						|
		exit(1);
 | 
						|
	}
 | 
						|
 | 
						|
	yang_translator_init();
 | 
						|
}
 | 
						|
 | 
						|
void yang_init_loading_complete(void)
 | 
						|
{
 | 
						|
	/* Compile everything */
 | 
						|
	if (ly_ctx_compile(ly_native_ctx) != LY_SUCCESS) {
 | 
						|
		flog_err(EC_LIB_YANG_MODULE_LOAD,
 | 
						|
			 "%s: failed to compile loaded modules: %s", __func__,
 | 
						|
			 ly_errmsg(ly_native_ctx));
 | 
						|
		exit(1);
 | 
						|
	}
 | 
						|
}
 | 
						|
 | 
						|
void yang_terminate(void)
 | 
						|
{
 | 
						|
	struct yang_module *module;
 | 
						|
 | 
						|
	yang_translator_terminate();
 | 
						|
 | 
						|
	while (!RB_EMPTY(yang_modules, &yang_modules)) {
 | 
						|
		module = RB_ROOT(yang_modules, &yang_modules);
 | 
						|
 | 
						|
		/*
 | 
						|
		 * We shouldn't call ly_ctx_remove_module() here because this
 | 
						|
		 * function also removes other modules that depend on it.
 | 
						|
		 *
 | 
						|
		 * ly_ctx_destroy() will release all memory for us.
 | 
						|
		 */
 | 
						|
		RB_REMOVE(yang_modules, &yang_modules, module);
 | 
						|
		XFREE(MTYPE_YANG_MODULE, module);
 | 
						|
	}
 | 
						|
 | 
						|
	ly_ctx_destroy(ly_native_ctx);
 | 
						|
}
 | 
						|
 | 
						|
const struct lyd_node *yang_dnode_get_parent(const struct lyd_node *dnode,
 | 
						|
					     const char *name)
 | 
						|
{
 | 
						|
	const struct lyd_node *orig_dnode = dnode;
 | 
						|
 | 
						|
	while (orig_dnode) {
 | 
						|
		switch (orig_dnode->schema->nodetype) {
 | 
						|
		case LYS_LIST:
 | 
						|
		case LYS_CONTAINER:
 | 
						|
			if (!strcmp(orig_dnode->schema->name, name))
 | 
						|
				return orig_dnode;
 | 
						|
			break;
 | 
						|
		default:
 | 
						|
			break;
 | 
						|
		}
 | 
						|
 | 
						|
		orig_dnode = lyd_parent(orig_dnode);
 | 
						|
	}
 | 
						|
 | 
						|
	return NULL;
 | 
						|
}
 | 
						|
 | 
						|
bool yang_is_last_list_dnode(const struct lyd_node *dnode)
 | 
						|
{
 | 
						|
	return (((dnode->next == NULL)
 | 
						|
	     || (dnode->next
 | 
						|
		 && (strcmp(dnode->next->schema->name, dnode->schema->name)
 | 
						|
		     != 0)))
 | 
						|
	    && dnode->prev
 | 
						|
	    && ((dnode->prev == dnode)
 | 
						|
		|| (strcmp(dnode->prev->schema->name, dnode->schema->name)
 | 
						|
		    != 0)));
 | 
						|
}
 | 
						|
 | 
						|
bool yang_is_last_level_dnode(const struct lyd_node *dnode)
 | 
						|
{
 | 
						|
	const struct lyd_node *parent;
 | 
						|
	const struct lyd_node *key_leaf;
 | 
						|
	uint8_t keys_size;
 | 
						|
 | 
						|
	switch (dnode->schema->nodetype) {
 | 
						|
	case LYS_LIST:
 | 
						|
		assert(dnode->parent);
 | 
						|
		parent = lyd_parent(dnode);
 | 
						|
		uint snode_num_keys = yang_snode_num_keys(parent->schema);
 | 
						|
		/* XXX libyang2: q: really don't understand this code. */
 | 
						|
		key_leaf = dnode->prev;
 | 
						|
		for (keys_size = 1; keys_size < snode_num_keys; keys_size++)
 | 
						|
			key_leaf = key_leaf->prev;
 | 
						|
		if (key_leaf->prev == dnode)
 | 
						|
			return true;
 | 
						|
		break;
 | 
						|
	case LYS_CONTAINER:
 | 
						|
		return true;
 | 
						|
	default:
 | 
						|
		break;
 | 
						|
	}
 | 
						|
 | 
						|
	return false;
 | 
						|
}
 | 
						|
 | 
						|
const struct lyd_node *
 | 
						|
yang_get_subtree_with_no_sibling(const struct lyd_node *dnode)
 | 
						|
{
 | 
						|
	bool parent = true;
 | 
						|
	const struct lyd_node *node;
 | 
						|
 | 
						|
	node = dnode;
 | 
						|
	if (node->schema->nodetype != LYS_LIST)
 | 
						|
		return node;
 | 
						|
 | 
						|
	while (parent) {
 | 
						|
		switch (node->schema->nodetype) {
 | 
						|
		case LYS_CONTAINER:
 | 
						|
			if (!CHECK_FLAG(node->schema->flags, LYS_PRESENCE)) {
 | 
						|
				if (node->parent
 | 
						|
				    && (node->parent->schema->module
 | 
						|
					== dnode->schema->module))
 | 
						|
					node = lyd_parent(node);
 | 
						|
				else
 | 
						|
					parent = false;
 | 
						|
			} else
 | 
						|
				parent = false;
 | 
						|
			break;
 | 
						|
		case LYS_LIST:
 | 
						|
			if (yang_is_last_list_dnode(node)
 | 
						|
			    && yang_is_last_level_dnode(node)) {
 | 
						|
				if (node->parent
 | 
						|
				    && (node->parent->schema->module
 | 
						|
					== dnode->schema->module))
 | 
						|
					node = lyd_parent(node);
 | 
						|
				else
 | 
						|
					parent = false;
 | 
						|
			} else
 | 
						|
				parent = false;
 | 
						|
			break;
 | 
						|
		default:
 | 
						|
			parent = false;
 | 
						|
			break;
 | 
						|
		}
 | 
						|
	}
 | 
						|
	return node;
 | 
						|
}
 | 
						|
 | 
						|
uint32_t yang_get_list_pos(const struct lyd_node *node)
 | 
						|
{
 | 
						|
	return lyd_list_pos(node);
 | 
						|
}
 | 
						|
 | 
						|
uint32_t yang_get_list_elements_count(const struct lyd_node *node)
 | 
						|
{
 | 
						|
	unsigned int count;
 | 
						|
	const struct lysc_node *schema;
 | 
						|
 | 
						|
	if (!node
 | 
						|
	    || ((node->schema->nodetype != LYS_LIST)
 | 
						|
		&& (node->schema->nodetype != LYS_LEAFLIST))) {
 | 
						|
		return 0;
 | 
						|
	}
 | 
						|
 | 
						|
	schema = node->schema;
 | 
						|
	count = 0;
 | 
						|
	do {
 | 
						|
		if (node->schema == schema)
 | 
						|
			++count;
 | 
						|
		node = node->next;
 | 
						|
	} while (node);
 | 
						|
	return count;
 | 
						|
}
 |