ingress.c File Reference

#include "ingress.h"
#include "agent.h"
#include <cace/util/daemon_run.h>
#include <cace/util/logging.h>

Include dependency graph for ingress.c:

Functions
void *	refda_ingress_worker (void *arg)
	Work thread function for the Agent transport ingress.
void	refda_ingress_push_move (refda_agent_t *agent, const cace_amm_msg_if_metadata_t *meta, cace_ari_t *ari)
	API for external thread to push ARIs into exec thread.

Function Documentation

refda_ingress_push_move()

void refda_ingress_push_move	(	refda_agent_t *	agent,
		const cace_amm_msg_if_metadata_t *	meta,
		cace_ari_t *	ari
	)

API for external thread to push ARIs into exec thread.

This can be used instead of the refda_ingress_worker. To do this, set the agent's cace_amm_msg_if_t.recv to NULL to prevent starting the ingress thread.

Parameters

agent	a pointer to the agent
meta	structure containing the manager's endpoint ID.
ari	The value to insert, which will be moved from.

References agent, cace_ari_get_execset(), cace_ari_is_undefined(), cace_ari_set_copy(), cace_ari_set_move(), CACE_LOG_DEBUG, CACE_LOG_ERR, refda_agent_t::execs, refda_agent_t::execs_sem, refda_msgdata_t::ident, refda_agent_t::instr, refda_instr_t::num_execset_recv, refda_msgdata_init(), cace_amm_msg_if_metadata_t::src, and refda_msgdata_t::value.

refda_ingress_worker()

void * refda_ingress_worker

(

void *

arg

)

Work thread function for the Agent transport ingress.

Parameters

[in]

arg

The context refda_agent_t pointer.

Returns

Always NULL pointer.

References agent, cace_amm_msg_if_metadata_deinit(), cace_amm_msg_if_metadata_init(), cace_ari_get_execset(), cace_ari_is_undefined(), cace_ari_set_copy(), cace_ari_set_move(), cace_daemon_run_get(), CACE_LOG_CRIT, CACE_LOG_ERR, CACE_LOG_INFO, cace_amm_msg_if_t::ctx, refda_agent_t::execs, refda_agent_t::execs_sem, refda_msgdata_t::ident, refda_agent_t::instr, refda_instr_t::last_time_recv, refda_agent_t::mif, refda_instr_t::mutex, refda_instr_t::num_execset_recv, refda_instr_t::num_execset_recv_failure, cace_amm_msg_if_t::recv, REFDA_INSTR_MSG_FAIL_MUTEX_ACQUIRE, REFDA_INSTR_MSG_FAIL_MUTEX_RELEASE, refda_msgdata_init(), refda_agent_t::running, cace_amm_msg_if_metadata_t::src, cace_amm_msg_if_metadata_t::timestamp, and refda_msgdata_t::value.

Referenced by refda_agent_start().