mgr.c File Reference

#include "mgr.h"
#include "ingress.h"
#include <cace/util/logging.h>
#include <cace/util/defs.h>

Include dependency graph for mgr.c:

Functions
void	refdm_mgr_init (refdm_mgr_t *mgr)
	Initialize a new manager state with default config.
void	refdm_mgr_deinit (refdm_mgr_t *mgr)
int	refdm_mgr_start (refdm_mgr_t *mgr)
	Begin the REFDM daemon operation.
int	refdm_mgr_stop (refdm_mgr_t *mgr)
	End daemon operation.
refdm_agent_t *	refdm_mgr_agent_add (refdm_mgr_t *mgr, const char *agent_eid)
	Add a new known agent by its EID URI.
refdm_agent_t *	refdm_mgr_agent_get_eid (refdm_mgr_t *mgr, const char *eid)
refdm_agent_t *	refdm_mgr_agent_get_index (refdm_mgr_t *mgr, size_t index)
void	refdm_mgr_clear_reports (refdm_mgr_t *mgr, refdm_agent_t *agent)
	Clear reports for a specific agent.

Function Documentation

refdm_mgr_agent_add()

refdm_agent_t * refdm_mgr_agent_add	(	refdm_mgr_t *	mgr,
		const char *	agent_eid
	)

Add a new known agent by its EID URI.

Parameters

[in]	mgr	The manager to update.
[in]	agent_eid	The unique agent EID. Adding will fail if the EID already exists in the agent list.

Returns

The new manager, or NULL if adding failed.

References agent, refdm_mgr_t::agent_dict, refdm_mgr_t::agent_list, refdm_mgr_t::agent_log_cfg, refdm_mgr_t::agent_mutex, CACE_LOG_CRIT, CACE_LOG_ERR, CACE_LOG_INFO, CACE_MALLOC, CHKNULL, mgr, refdm_agent_init(), refdm_agent_rotate_log(), and refdm_db_insert_agent().

Referenced by agentsPostHandler(), and refdm_ingress_worker().

refdm_mgr_agent_get_eid()

refdm_agent_t * refdm_mgr_agent_get_eid	(	refdm_mgr_t *	mgr,
		const char *	eid
	)

References refdm_mgr_t::agent_dict, refdm_mgr_t::agent_mutex, CACE_LOG_CRIT, CHKNULL, and mgr.

Referenced by getAgentFromEid(), and refdm_ingress_worker().

refdm_mgr_agent_get_index()

refdm_agent_t * refdm_mgr_agent_get_index	(	refdm_mgr_t *	mgr,
		size_t	index
	)

References refdm_mgr_t::agent_list, refdm_mgr_t::agent_mutex, CACE_LOG_CRIT, CHKNULL, and mgr.

Referenced by getAgentFromIdx().

refdm_mgr_clear_reports()

void refdm_mgr_clear_reports	(	refdm_mgr_t *	mgr,
		refdm_agent_t *	agent
	)

Clear reports for a specific agent.

References agent, refdm_db_clear_rptset(), and refdm_db_fetch_agent_idx().

Referenced by agentEidClearReportsHandler(), and agentIdxClearReportsHandler().

refdm_mgr_deinit()

void refdm_mgr_deinit

(

refdm_mgr_t *

mgr

)

References agent, refdm_mgr_t::agent_dict, refdm_mgr_t::agent_list, refdm_mgr_t::agent_mutex, cace_daemon_run_cleanup(), CACE_FREE, CHKVOID, mgr, refdm_agent_deinit(), refdm_db_mgt_close(), refdm_mgr_t::running, and refdm_mgr_t::threads.

Referenced by main().

refdm_mgr_init()

void refdm_mgr_init

(

refdm_mgr_t *

mgr

)

Initialize a new manager state with default config.

Parameters

[in,out]

mgr

The manager state.

References refdm_mgr_t::agent_dict, refdm_mgr_t::agent_list, refdm_mgr_t::agent_log_cfg, refdm_mgr_t::agent_mutex, cace_daemon_run_init(), CHKVOID, refdm_agent_autologging_cfg_t::enabled, mgr, MGR_UI_DEFAULT, refdm_mgr_t::mgr_ui_mode, refdm_db_mgt_init(), refdm_mgr_t::running, and refdm_mgr_t::threads.

Referenced by main().

refdm_mgr_start()

int refdm_mgr_start

(

refdm_mgr_t *

mgr

)

Begin the REFDM daemon operation.

Precondition

The manager must have set values for:

• refdm_mgr_t::agent_log_cfg
• refdm_mgr_t::rest_listen_port

Parameters

[in]

mgr

The manager to start.

See also

refdm_mgr_stop()

References cace_threadset_start(), mgr, refdm_ingress_worker(), refdm_nm_rest_start(), and refdm_mgr_t::threads.

Referenced by main().

refdm_mgr_stop()

int refdm_mgr_stop

(

refdm_mgr_t *

mgr

)

End daemon operation.

Precondition

The manager must have been successfully started with refdm_mgr_start().

Parameters

[in]

mgr

The manager to stop.

References cace_daemon_run_stop(), cace_threadset_join(), mgr, refdm_nm_rest_stop(), refdm_mgr_t::running, and refdm_mgr_t::threads.

Referenced by main().