This header is associated with proxied messaging from the user/client side, where the peer identity prefix and the entire message contents are visible. More...

#include "cace/amm/msg_if.h"
#include "cace/ari.h"
#include <m-string.h>
#include <pthread.h>

Include dependency graph for proxy_cli.h:

This graph shows which files directly or indirectly include this file:

Data Structures
struct	cace_amp_proxy_cli_state_t
	State for the BP-proxy socket transport. More...

Functions
void	cace_amp_proxy_cli_state_init (cace_amp_proxy_cli_state_t *state)
	Initialize an empty state.

void	cace_amp_proxy_cli_state_deinit (cace_amp_proxy_cli_state_t *state)
	Deinitialize any resources.

int	cace_amp_proxy_cli_state_connect (cace_amp_proxy_cli_state_t *state, const m_string_t sock_path)
	Connect a unix domain SEQDATA socket to a specific filesystem path.

void	cace_amp_proxy_cli_state_disconnect (cace_amp_proxy_cli_state_t *state)
	Disconnect any current socket and remove it if necessary.

int	cace_amp_proxy_cli_send (const cace_ari_list_t data, const cace_amm_msg_if_metadata_t meta, void ctx)
	Provider of cace_amm_msg_if_t::send interface for BP-proxy socket transport.

int	cace_amp_proxy_cli_recv (cace_ari_list_t data, cace_amm_msg_if_metadata_t meta, cace_daemon_run_t running, void *ctx)
	Provider of cace_amm_msg_if_t::recv interface for BP-proxy socket transport.

Detailed Description

This header is associated with proxied messaging from the user/client side, where the peer identity prefix and the entire message contents are visible.

Function Documentation

◆ cace_amp_proxy_cli_recv()

int cace_amp_proxy_cli_recv	(	cace_ari_list_t	data,
		cace_amm_msg_if_metadata_t *	meta,
		cace_daemon_run_t *	running,
		void *	ctx
	)

Provider of cace_amm_msg_if_t::recv interface for BP-proxy socket transport.

The user data for this function is a cace_amp_proxy_cli_state_t instance.

References cace_ari_cbor_decode(), cace_ari_text_encode(), cace_data_deinit(), cace_data_init_view(), CACE_LOG_DEBUG, CACE_LOG_ERR, CACE_LOG_INFO, CACE_LOG_WARNING, CHKERR1, and cace_amm_msg_if_metadata_t::src.

◆ cace_amp_proxy_cli_send()

int cace_amp_proxy_cli_send	(	const cace_ari_list_t	data,
		const cace_amm_msg_if_metadata_t *	meta,
		void *	ctx
	)

Provider of cace_amm_msg_if_t::send interface for BP-proxy socket transport.

The user data for this function is a cace_amp_proxy_cli_state_t instance.

References cace_ari_cbor_encode(), cace_ari_text_encode(), cace_data_deinit(), cace_data_init(), CACE_LOG_ERR, CACE_LOG_INFO, CHKERR1, cace_amm_msg_if_metadata_t::dest, cace_data_t::len, and cace_data_t::ptr.

◆ cace_amp_proxy_cli_state_connect()

int cace_amp_proxy_cli_state_connect	(	cace_amp_proxy_cli_state_t *	state,
		const m_string_t	sock_path
	)

Connect a unix domain SEQDATA socket to a specific filesystem path.

Parameters

[in,out]	state	The state to bind.
[in]	sock_path	The file path to bind to.

Returns: Zero if successful.

References CHKERR1, cace_amp_proxy_cli_state_t::path, and cace_amp_proxy_cli_state_t::sock_mutex.

◆ cace_amp_proxy_cli_state_disconnect()

void cace_amp_proxy_cli_state_disconnect ( cace_amp_proxy_cli_state_t * state )

Disconnect any current socket and remove it if necessary.

Parameters

[in,out] state The state to bind.

References CACE_LOG_DEBUG, CHKVOID, cace_amp_proxy_cli_state_t::path, cace_amp_proxy_cli_state_t::sock_fd, and cace_amp_proxy_cli_state_t::sock_mutex.