msg_rpc_connection Class Reference

classes implement the RPC protocol communication More...

#include <msg_rpc.h>

Inheritance diagram for msg_rpc_connection:

List of all members.

Public Member Functions

msg_rpc_connection (msg_communicator *communicator_, rpc_binding_handle_t handle_, const conf_listener &linfo, const conf_connection &info)

constructor for receiver

msg_rpc_connection (msg_communicator *communicator_, rpc_binding_handle_t handle_, const conf_connection &info)

constructor for initiator

virtual ~msg_rpc_connection ()

destructor

Static Public Member Functions

static msg_connection * connect (msg_communicator *communicator_, const conf_connection &info)

establishes RPC connection due to info

static void send_msg (msg_communicator *communicator_, msg_rpc_connection *_this, rpc_binding_handle_t handle_, msg_cpp *msg_)

send RPC message to the peer

Protected Member Functions

virtual void v_do_job (size_t ident, void *user_data)

override the base functionality

Private Attributes

rpc_binding_handle_t _handle

keeps the RPC handle for connection

Detailed Description

classes implement the RPC protocol communication

Definition at line 46 of file msg_rpc.h.

Constructor & Destructor Documentation

msg_rpc_connection::msg_rpc_connection	(	msg_communicator *	communicator_,
		rpc_binding_handle_t	handle_,
		const conf_listener &	linfo,
		const conf_connection &	info
	)

constructor for receiver

Parameters:

communicator_	communicator
handle_	rpc handle
linfo	listener info
info	connection info

Definition at line 336 of file msg_rpc.cpp.

Referenced by connect(), and ServerConnect().

msg_rpc_connection::msg_rpc_connection	(	msg_communicator *	communicator_,
		rpc_binding_handle_t	handle_,
		const conf_connection &	info
	)

constructor for initiator

Parameters:

communicator_	communicator
handle_	rpc handle
info	connection info

Definition at line 341 of file msg_rpc.cpp.

msg_rpc_connection::~msg_rpc_connection ( ) [virtual]

destructor

Definition at line 346 of file msg_rpc.cpp.

References _handle, and rpc_binding_free.

Member Function Documentation

msg_connection * msg_rpc_connection::connect	(	msg_communicator *	communicator_,
		const conf_connection &	info
	)			`[static]`

establishes RPC connection due to info

Parameters:

communicator_	communicator
info	connection info

Definition at line 392 of file msg_rpc.cpp.

References conf_connection::_address, exception::_throw(), msg_communicator::add_connection(), msg_cpp::block_size(), g_name, g_protocol, g_protocol_, midl_user_free(), MSG_RESULT_ACCESS_DENIED, MSG_RESULT_CONNECTION_BROKEN, MSG_RESULT_INVALID_MSGFORMAT, MSG_RESULT_NOTMEMORY, msg_rpc_connection(), msgMsgTable, msg_connection::prepare_handshake_msg(), rpc_binding_free, rpc_binding_from_string_binding, rpc_c_binding_min_timeout, rpc_mgmt_set_com_timeout, rpc_s_ok, rpc_string_binding_compose, rpc_string_free, rpcStatus(), str_template::strlen(), uustring(), and msg_connection::validate_handshake_reply().

Referenced by msg_communicator::_connect().

void msg_rpc_connection::send_msg	(	msg_communicator *	communicator_,
		msg_rpc_connection *	_this,
		rpc_binding_handle_t	handle_,
		msg_cpp *	msg_
	)			`[static]`

send RPC message to the peer

Parameters:

communicator_	communicator
_this	rpc connection
handle_	rpc handle
msg_	message

Definition at line 492 of file msg_rpc.cpp.

References exception::_throw(), msg_cpp::_type, msg_communicator::comm_msg(), smart_pointer< C >::detach(), en_log_info, terimber_log::format_logging(), msg_cpp::get_block(), msg_connection::get_crypt_key(), msg_pack::make_error_msg(), msg_pack::make_reply_msg(), midl_user_free(), MSG_RESULT_CONNECTION_BROKEN, msgMsgTable, msg_cpp::pack_msg(), user_type_send, and user_type_send_async.

Referenced by v_do_job().

void msg_rpc_connection::v_do_job	(	size_t	ident,
		void *	user_data
	)			`[protected, virtual]`

override the base functionality

Parameters:

ident	thread ident
user_data	user data

Implements terimber_thread_employer.

Definition at line 356 of file msg_rpc.cpp.

References msg_base::_communicator, _handle, msg_communicator::log_msg(), msg_queue< 3 >::pop(), queue_thread_ident, send_msg(), msg_connection::set_last_activity(), and msg_communicator::shutdown_connection().

Member Data Documentation

rpc_binding_handle_t msg_rpc_connection::_handle [private]

keeps the RPC handle for connection

Definition at line 88 of file msg_rpc.h.

Referenced by v_do_job(), and ~msg_rpc_connection().

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