ingress.c File Reference

#include "ingress.h"
#include "mgr.h"
#include "agents.h"
#include <cace/ari/text.h>
#include <cace/util/daemon_run.h>
#include <cace/util/logging.h>

Include dependency graph for ingress.c:

Functions
static void	handle_recv (refdm_mgr_t *mgr, refdm_agent_t *agent, cace_ari_t *val)
	Handle a received RPTSET value.
void *	refdm_ingress_worker (void *arg)
	Work thread function for the Manager transport ingress.

Function Documentation

handle_recv()

static void handle_recv ( refdm_mgr_t *  mgr, refdm_agent_t *  agent, cace_ari_t *  val  )

static

Handle a received RPTSET value.

Parameters

[in]	mgr	The manager to operate under.
[in]	agent	The agent object associated with this reception.
[in,out]	val	The value to move from.

References agent, refdm_mgr_t::agent_log_cfg, cace_ari_set_copy(), CACE_ARI_TEXT_ENC_OPTS_DEFAULT, cace_ari_text_encode(), CACE_LOG_INFO, mgr, refdm_agent_rotate_log(), refdm_db_insert_rptset(), and refdm_agent_autologging_cfg_t::rx_rpt.

Referenced by refdm_ingress_worker().

refdm_ingress_worker()

void * refdm_ingress_worker

(

void *

arg

)

Work thread function for the Manager transport ingress.

Parameters

[in]

arg

The context refdm_mgr_t pointer.

Returns

Always NULL pointer.

References agent, cace_amm_msg_if_metadata_deinit(), cace_amm_msg_if_metadata_init(), cace_ari_cget_tstr_cstr(), cace_ari_get_rptset(), CACE_ARI_TEXT_ENC_OPTS_DEFAULT, cace_ari_text_encode(), cace_daemon_run_get(), CACE_LOG_DEBUG, CACE_LOG_ERR, CACE_LOG_INFO, cace_log_is_enabled_for(), cace_amm_msg_if_t::ctx, handle_recv(), refdm_mgr_t::instr, mgr, refdm_mgr_t::mif, refdm_instr_t::num_rptset_recv, cace_amm_msg_if_t::recv, refdm_mgr_agent_add(), refdm_mgr_agent_get_eid(), refdm_mgr_t::running, and cace_amm_msg_if_metadata_t::src.

Referenced by refdm_mgr_start().