CCF: ccf::Forwarder< ChannelProxy > Class Template Reference

CCF

Loading...

Searching...

No Matches

#include <forwarder.h>

Inherits ccf::AbstractForwarder.

Classes
struct	ForwardedResponseResult

Public Member Functions
	Forwarder (std::weak_ptr< ccf::AbstractRPCResponder > rpcresponder, std::shared_ptr< ChannelProxy > n2n_channels, std::weak_ptr< ccf::RPCMap > rpc_map_)

void	initialize (const NodeId &self_)

bool	forward_command (std::shared_ptr< ccf::RpcContextImpl > rpc_ctx, const NodeId &to, const std::vector< uint8_t > &caller_cert, const std::chrono::milliseconds &timeout) override

template<typename TFwdHdr >
std::shared_ptr<::http::HttpRpcContext >	recv_forwarded_command (const NodeId &from, const uint8_t *data, size_t size)

template<typename TFwdHdr >
void	send_forwarded_response (size_t client_session_id, const NodeId &from_node, const TFwdHdr &header, const std::vector< uint8_t > &data)

template<typename TFwdHdr >
std::optional< ForwardedResponseResult >	recv_forwarded_response (const NodeId &from, const uint8_t *data, size_t size)

std::shared_ptr< ForwardedRpcHandler >	get_forwarder_handler (std::shared_ptr<::http::HttpRpcContext > &ctx)

void	recv_message (const ccf::NodeId &from, const uint8_t *data, size_t size)

Public Member Functions inherited from ccf::AbstractForwarder
virtual	~AbstractForwarder ()

Constructor & Destructor Documentation

◆ Forwarder()

template<typename ChannelProxy >

ccf::Forwarder< ChannelProxy >::Forwarder	(	std::weak_ptr< ccf::AbstractRPCResponder >	rpcresponder,
		std::shared_ptr< ChannelProxy >	n2n_channels,
		std::weak_ptr< ccf::RPCMap >	rpc_map_
	)

inline

Member Function Documentation

◆ forward_command()

template<typename ChannelProxy >

bool ccf::Forwarder< ChannelProxy >::forward_command	(	std::shared_ptr< ccf::RpcContextImpl >	rpc_ctx,
		const NodeId &	to,
		const std::vector< uint8_t > &	caller_cert,
		const std::chrono::milliseconds &	timeout
	)

inlineoverridevirtual

Implements ccf::AbstractForwarder.

◆ get_forwarder_handler()

template<typename ChannelProxy >

std::shared_ptr< ForwardedRpcHandler > ccf::Forwarder< ChannelProxy >::get_forwarder_handler ( std::shared_ptr<::http::HttpRpcContext > & ctx )

inline

◆ initialize()

template<typename ChannelProxy >

void ccf::Forwarder< ChannelProxy >::initialize ( const NodeId & self_ )

inline

◆ recv_forwarded_command()

template<typename ChannelProxy >

template<typename TFwdHdr >

std::shared_ptr<::http::HttpRpcContext > ccf::Forwarder< ChannelProxy >::recv_forwarded_command	(	const NodeId &	from,
		const uint8_t *	data,
		size_t	size
	)

inline

◆ recv_forwarded_response()

template<typename ChannelProxy >

template<typename TFwdHdr >

std::optional< ForwardedResponseResult > ccf::Forwarder< ChannelProxy >::recv_forwarded_response	(	const NodeId &	from,
		const uint8_t *	data,
		size_t	size
	)

inline

◆ recv_message()

template<typename ChannelProxy >

void ccf::Forwarder< ChannelProxy >::recv_message	(	const ccf::NodeId &	from,
		const uint8_t *	data,
		size_t	size
	)

inline

◆ send_forwarded_response()

template<typename ChannelProxy >

template<typename TFwdHdr >

void ccf::Forwarder< ChannelProxy >::send_forwarded_response	(	size_t	client_session_id,
		const NodeId &	from_node,
		const TFwdHdr &	header,
		const std::vector< uint8_t > &	data
	)

inline

The documentation for this class was generated from the following file:

src/node/rpc/forwarder.h