msg_rpc.cpp File Reference

#include "msg_rpc.h"
#include "imsg.h"
#include "base/string.hpp"
#include "base/list.hpp"
#include "base/memory.hpp"
#include "base/template.hpp"
#include "base/common.hpp"
#include "base/except.h"
#include "base/number.hpp"

Go to the source code of this file.

Classes
class	rpc2_communicator_keeper
Defines
#define	prc_s_duplicate_endpoint   RPC_S_DUPLICATE_ENDPOINT
Functions
static ub1_t *	uustring (char *x, size_t len, const guid_t &y)
static void	rpcStatus (int status_)
void	ServerConnect (rpc_binding_handle_t handle_, unsigned long szsend, unsigned char *sender, unsigned long *szrecv, unsigned char **receiver)
void	ServerPostBlock (rpc_binding_handle_t handle_, unsigned long sz, ub1_t *buf, ub1_t **reply)
Variables
BEGIN_TERIMBER_NAMESPACE exception_table	msgMsgTable
exception_item	rpcMsgs []
exception_table	rpcMsgTable (rpcMsgs)
static const char *	g_protocol = "ncalrpc"
static const char *	g_protocol_ = "ncalrpc:"
static const IMSG_SERVER_EPV	g_epv = {ServerConnect, ServerPostBlock}
static char	g_name [300]
msg_rpc_global	g_rpc_global

---

Define Documentation

#define prc_s_duplicate_endpoint   RPC_S_DUPLICATE_ENDPOINT

Definition at line 45 of file msg_rpc.cpp.

---

Function Documentation

static void rpcStatus

(

int

status_

)

[static]

Definition at line 143 of file msg_rpc.cpp.

References exception::_throw(), rpc_s_ok, and rpcMsgTable.

Referenced by msg_rpc_connection::connect(), msg_rpc_global::init(), ServerConnect(), ServerPostBlock(), msg_rpc_listener::v_off(), and msg_rpc_listener::v_on().

void ServerConnect	(	rpc_binding_handle_t	handle_,
		unsigned long	szsend,
		unsigned char *	sender,
		unsigned long *	szrecv,
		unsigned char **	receiver
	)

*

Definition at line 544 of file msg_rpc.cpp.

References exception::_throw(), msg_cpp::block_size(), msg_listener::get_info(), msg_base::is_on(), midl_user_allocate(), MSG_RESULT_ACCESS_DENIED, MSG_RESULT_INVALID_MSGFORMAT, MSG_RESULT_NOTMEMORY, msg_rpc_connection::msg_rpc_connection(), msgMsgTable, msg_connection::prepare_handshake_reply(), rpc, rpc_binding_free, rpc_binding_inq_object, rpc_c_binding_min_timeout, rpc_mgmt_set_com_timeout, and rpcStatus().

void ServerPostBlock	(	rpc_binding_handle_t	handle_,
		unsigned long	sz,
		ub1_t *	buf,
		ub1_t **	reply
	)

Definition at line 653 of file msg_rpc.cpp.

References conf_connection::_session, exception::_throw(), msg_cpp::block_size(), smart_pointer< C >::detach(), en_log_info, terimber_log::format_logging(), msg_connection::get_crypt_key(), msg_connection::get_info(), msg_connection::get_rsa(), msg_queue< P, C >::is_block(), msg_base::is_on(), midl_user_allocate(), msg_id_ping, MSG_RESULT_ACCESS_DENIED, MSG_RESULT_INVALID_MSGFORMAT, msgMsgTable, msg_connection::process_incoming_message(), rpc, rpc_binding_inq_object, rpcStatus(), str_template::strlen(), system_type, user_type_mask, and exception::what().

static ub1_t* uustring	(	char *	x,
		size_t	len,
		const guid_t &	y
	)			[inline, static]

Definition at line 131 of file msg_rpc.cpp.

References _terimber_guid_::Data1, _terimber_guid_::Data2, _terimber_guid_::Data3, _terimber_guid_::Data4, and str_template::strprint().

Referenced by msg_rpc_connection::connect(), and msg_rpc_listener::v_on().

---

Variable Documentation

const IMSG_SERVER_EPV g_epv = {ServerConnect, ServerPostBlock} [static]

Definition at line 149 of file msg_rpc.cpp.

Referenced by msg_rpc_listener::v_on().

char g_name[300] [static]

Definition at line 150 of file msg_rpc.cpp.

Referenced by msg_rpc_connection::connect(), and msg_rpc_global::init().

const char* g_protocol = "ncalrpc" [static]

Definition at line 140 of file msg_rpc.cpp.

Referenced by msg_rpc_connection::connect(), msg_rpc_global::init(), and msg_rpc_listener::v_on().

const char* g_protocol_ = "ncalrpc:" [static]

Definition at line 141 of file msg_rpc.cpp.

Referenced by msg_rpc_connection::connect(), and msg_rpc_global::init().

msg_rpc_global g_rpc_global

Definition at line 153 of file msg_rpc.cpp.

BEGIN_TERIMBER_NAMESPACE exception_table msgMsgTable

exception_item rpcMsgs[]

Definition at line 47 of file msg_rpc.cpp.

exception_table rpcMsgTable(rpcMsgs)

Referenced by rpcStatus().