#include "util/ari.h"
#include "util/agent.h"
#include <refda/exec.h>
#include <refda/exec_proc.h>
#include <refda/register.h>
#include <refda/edd_prod_ctx.h>
#include <refda/ctrl_exec_ctx.h>
#include <refda/amm/const.h>
#include <refda/amm/ctrl.h>
#include <refda/adm/ietf.h>
#include <cace/amm/semtype.h>
#include <cace/ari/text_util.h>
#include <cace/ari/cbor.h>
#include <cace/util/logging.h>
#include <cace/ari/text.h>
#include <cace/util/defs.h>
#include <timespec.h>
#include <unity.h>

Include dependency graph for test_exec.c:

Macros
#define	TEST_CASE(...)

#define	EXAMPLE_ORG_ENUM 65535

#define	EXAMPLE_ADM_ENUM 10

Functions
static void	suite_adms_init (refda_agent_t *agent)

void	suiteSetUp (void)

int	suiteTearDown (int failures)

void	setUp (void)

static void	test_reporting_edd_one_int (refda_edd_prod_ctx_t *ctx)

static void	test_exec_ctrl_exec_one_int (refda_ctrl_exec_ctx_t *ctx)

static void	check_execute (const cace_ari_t *target, int expect_exp, int wait_limit, int wait_ms[])
	Perform a single execution on a single target from a dummy manager.

void	test_refda_exec_target (const char targethex, int expect_exp, const char expectloghex)

void	test_refda_exec_wait_for (int delay_ms)

void	test_refda_exec_wait_until (int delay_ms)

void	test_refda_exec_wait_cond (int delay_ms)

void	test_refda_exec_time_based_rule (const char actionhex, const char starthex, bool convert_start_to_tp, const char *periodhex, int max_exec_count, bool init_enabled, cace_ari_uvast expect_exec_count)

void	test_refda_exec_state_based_rule (const char actionhex, const char condhex, const char *min_interval_hex, int max_exec_count, bool init_enabled, int expect_enable, cace_ari_uvast expect_exec_count)

void	test_refda_exec_state_based_rule_cond_false_then_true (const char actionhex, const char condhex, const char *min_interval_hex, int max_exec_count, bool init_enabled, int expect_enable, int expect_exec_count)

Variables
static refda_agent_t	agent

static atomic_int	edd_backing_value = ATOMIC_VAR_INIT(0)

static cace_ari_list_t	exec_log

Macro Definition Documentation

◆ EXAMPLE_ADM_ENUM

#define EXAMPLE_ADM_ENUM 10

◆ EXAMPLE_ORG_ENUM

#define EXAMPLE_ORG_ENUM 65535

◆ TEST_CASE

#define TEST_CASE ( ... )

Function Documentation

◆ check_execute()

static void check_execute	(	const cace_ari_t *	target,
		int	expect_exp,
		int	wait_limit,
		int	wait_ms[]
	)

static

Perform a single execution on a single target from a dummy manager.

Parameters

[in]	target	The target to execute.
	expect_exp	The expected refda_exec_exp_target() return code.

References agent, CACE_ARI_TEXT_ENC_OPTS_DEFAULT, cace_ari_text_encode(), CACE_LOG_DEBUG, cace_timeperiod_encode(), refda_timeline_exec_event_t::callback, refda_timeline_event_t::exec, refda_agent_t::exec_timeline, refda_exec_item_t::execution_stage, refda_timeline_exec_event_t::item, refda_exec_seq_t::items, refda_ctrl_exec_ctx_deinit(), refda_ctrl_exec_ctx_init(), refda_exec_proc_expand(), refda_exec_proc_run(), refda_exec_seq_deinit(), refda_exec_seq_init(), REFDA_EXEC_WAITING, refda_runctx_from(), refda_exec_seq_t::runctx, and refda_timeline_event_t::ts.

Referenced by test_refda_exec_target(), test_refda_exec_wait_cond(), test_refda_exec_wait_for(), and test_refda_exec_wait_until().

◆ setUp()

void setUp ( void )

References agent, exec_log, refda_agent_t::exec_state, and refda_agent_t::exec_timeline.

◆ suite_adms_init()

static void suite_adms_init ( refda_agent_t * agent )

static

Register CONST objects

Register EDD objects

Register CTRL objects

References agent, cace_amm_idseg_ref_withenum(), cace_amm_obj_store_add_ns(), cace_amm_type_set_use_builtin(), cace_ari_params_set_ac(), cace_ari_set_ac(), cace_ari_set_int(), cace_ari_set_objref_path_intid(), CACE_ARI_TYPE_CTRL, CACE_ARI_TYPE_INT, CACE_MALLOC, EXAMPLE_ADM_ENUM, EXAMPLE_ORG_ENUM, refda_amm_ctrl_desc_t::execute, cace_ari_ac_t::items, refda_agent_t::objs, cace_ari_ref_t::params, refda_amm_edd_desc_t::prod_type, refda_amm_edd_desc_t::produce, refda_agent_bindrefs(), refda_amm_const_desc_init(), refda_amm_ctrl_desc_init(), refda_amm_edd_desc_init(), refda_register_add_param(), refda_register_const(), refda_register_ctrl(), refda_register_edd(), refda_amm_ctrl_desc_t::res_type, test_exec_ctrl_exec_one_int(), test_reporting_edd_one_int(), cace_amm_formal_param_t::typeobj, and refda_amm_const_desc_t::value.

Referenced by suiteSetUp().

◆ suiteSetUp()

void suiteSetUp ( void )

References agent, cace_openlog(), exec_log, REFDA_ADM_IETF_DTNMA_AGENT_ACL_ENUM_OBJID_IDENT_PRODUCE, refda_agent_init(), suite_adms_init(), test_util_agent_crit_adms(), and test_util_agent_permission().

◆ suiteTearDown()

int suiteTearDown ( int failures )

References agent, cace_closelog(), exec_log, and refda_agent_deinit().

◆ test_exec_ctrl_exec_one_int()

static void test_exec_ctrl_exec_one_int ( refda_ctrl_exec_ctx_t * ctx )

static

References CACE_ARI_TEXT_ENC_OPTS_DEFAULT, cace_ari_text_encode(), CHKVOID, exec_log, refda_ctrl_exec_ctx_t::item, refda_exec_item_t::ref, refda_ctrl_exec_ctx_get_aparam_index(), and refda_ctrl_exec_ctx_set_result_copy().

Referenced by suite_adms_init().

◆ test_refda_exec_state_based_rule()

void test_refda_exec_state_based_rule	(	const char *	actionhex,
		const char *	condhex,
		const char *	min_interval_hex,
		int	max_exec_count,
		bool	init_enabled,
		int	expect_enable,
		cace_ari_uvast	expect_exec_count
	)

References refda_amm_sbr_desc_t::action, agent, cace_ari_get_td(), CACE_LOG_ERR, refda_amm_sbr_desc_t::condition, refda_amm_sbr_desc_t::exec_count, refda_agent_t::exec_timeline, refda_amm_sbr_desc_t::max_exec_count, refda_amm_sbr_desc_t::min_interval, refda_amm_sbr_desc_deinit(), refda_amm_sbr_desc_init(), refda_exec_sbr_enable(), refda_exec_waiting(), refda_exec_worker_iteration(), and test_util_ari_decode().

◆ test_refda_exec_state_based_rule_cond_false_then_true()

void test_refda_exec_state_based_rule_cond_false_then_true	(	const char *	actionhex,
		const char *	condhex,
		const char *	min_interval_hex,
		int	max_exec_count,
		bool	init_enabled,
		int	expect_enable,
		int	expect_exec_count
	)

References refda_amm_sbr_desc_t::action, agent, cace_ari_get_td(), refda_amm_sbr_desc_t::condition, edd_backing_value, refda_amm_sbr_desc_t::exec_count, refda_amm_sbr_desc_t::max_exec_count, refda_amm_sbr_desc_t::min_interval, refda_amm_sbr_desc_deinit(), refda_amm_sbr_desc_init(), refda_exec_sbr_enable(), refda_exec_waiting(), refda_exec_worker_iteration(), and test_util_ari_decode().

◆ test_refda_exec_target()

void test_refda_exec_target	(	const char *	targethex,
		int	expect_exp,
		const char *	expectloghex
	)

◆ test_refda_exec_time_based_rule()

void test_refda_exec_time_based_rule	(	const char *	actionhex,
		const char *	starthex,
		bool	convert_start_to_tp,
		const char *	periodhex,
		int	max_exec_count,
		bool	init_enabled,
		cace_ari_uvast	expect_exec_count
	)