msg_cpp.h File Reference

#include "aiomsg/msg_c.h"
#include "base/memory.h"
#include "base/string.h"
#include "base/list.h"
#include "base/number.h"

Go to the source code of this file.

Classes
class	msg_cpp
	message class internal message representation More...
class	msg_pack
	pack error and reply messages More...
class	conf_peer
	configuration for listener peers More...
class	conf_listener
	common class for config unit information More...
class	conf_connection
class	conf_unit
	class describes unit of a configuration More...
Typedefs
typedef room_array< ub1_t >	room_byte_t
typedef list< conf_peer >	msg_peer_list_t
	list of listner peer configurations
typedef list< conf_listener >	msg_listener_list_t
	list of listener configurations
typedef list< conf_connection >	msg_connection_list_t
	list of connection configurations
Enumerations
enum	transport_type { unknown = 0, sock, rpc }
	transport type, expandable to rpc, p2p, etc More...
Functions
bool	is_request (size_t type)
	checks if type is a user reply
Variables
const size_t	user_type_send = 0x10000001
	user type send, reply is required
const size_t	user_type_send_async = 0x10000002
	user type send asynchronously, reply is required
const size_t	user_type_post = 0x10000003
	user type post, no reply expected
const size_t	user_type_reply = 0x10000004
	this is a reply on user send
const size_t	user_type_reply_async = 0x10000005
	this is a reply on user send asynchronously
const size_t	user_type_mask = 0x10000007
	mask for all user types
const size_t	handshake_type = 0x20000000
	handhake type
const size_t	system_type = 0x40000000
	system type
const size_t	msg_id_handshake_request = 0x10000001
	hadnshake request
const size_t	msg_id_handshake_reply = 0x10000002
	handshake response
const size_t	msg_id_ping = 0x10000003
	ping message
const size_t	msg_id_shutdown = 0x10000004
	shutdown message
const size_t	msg_default_timeout = 10000
	deafult timeout in millseconds
const size_t	msg_crypt_block = 16
	crypto block size

---

Typedef Documentation

msg_connection_list_t

list of connection configurations

Definition at line 587 of file msg_cpp.h.

msg_listener_list_t

list of listener configurations

Definition at line 584 of file msg_cpp.h.

msg_peer_list_t

list of listner peer configurations

Definition at line 455 of file msg_cpp.h.

typedef room_array< ub1_t > room_byte_t

Definition at line 43 of file msg_cpp.h.

---

Enumeration Type Documentation

enum transport_type

transport type, expandable to rpc, p2p, etc

Enumerator:

unknown	unknown transport
sock	socket transport
rpc	rpc transport

Definition at line 47 of file msg_cpp.h.

---

Function Documentation

bool is_request

(

size_t

type

)

[inline]

checks if type is a user reply

Definition at line 89 of file msg_cpp.h.

References user_type_reply, and user_type_reply_async.

---

Variable Documentation

const size_t handshake_type = 0x20000000

handhake type

Definition at line 68 of file msg_cpp.h.

Referenced by msg_communicator::check_handshake(), msg_communicator::construct_handshake(), msg_pack::make_reply_msg(), msg_connection::process_incoming_message(), msg_communicator::reply_handshake(), and msg_sock_connection::v_do_job().

const size_t msg_crypt_block = 16

crypto block size

Definition at line 84 of file msg_cpp.h.

Referenced by msg_cpp::crypt_size().

const size_t msg_default_timeout = 10000

deafult timeout in millseconds

Definition at line 82 of file msg_cpp.h.

Referenced by msg_cpp::msg_cpp(), and msg_sock_connection::v_on_receive().

const size_t msg_id_handshake_reply = 0x10000002

handshake response

Definition at line 76 of file msg_cpp.h.

Referenced by msg_communicator::check_handshake(), and msg_communicator::reply_handshake().

const size_t msg_id_handshake_request = 0x10000001

hadnshake request

system internal messages

Definition at line 74 of file msg_cpp.h.

Referenced by msg_communicator::construct_handshake(), and msg_communicator::reply_handshake().

const size_t msg_id_ping = 0x10000003

ping message

Definition at line 78 of file msg_cpp.h.

Referenced by msg_communicator::comm_msg(), msg_communicator::construct_ping(), msg_connection::process_incoming_message(), and ServerPostBlock().

const size_t msg_id_shutdown = 0x10000004

shutdown message

Definition at line 80 of file msg_cpp.h.

Referenced by msg_communicator::shutdown_connection(), and msg_communicator::v_do_job().

const size_t system_type = 0x40000000

system type

Definition at line 70 of file msg_cpp.h.

Referenced by msg_communicator::comm_msg(), msg_communicator::construct_ping(), msg_pack::make_reply_msg(), msg_connection::process_incoming_message(), ServerPostBlock(), msg_communicator::shutdown_connection(), and msg_communicator::v_do_job().

const size_t user_type_mask = 0x10000007

mask for all user types

Definition at line 66 of file msg_cpp.h.

Referenced by ServerPostBlock(), and msg_sock_connection::v_do_job().

const size_t user_type_post = 0x10000003

user type post, no reply expected

Definition at line 60 of file msg_cpp.h.

Referenced by msg_user_connection::post(), msg_user_connection::process_income_message(), and msg_connection::process_incoming_message().

const size_t user_type_reply = 0x10000004

this is a reply on user send

Definition at line 62 of file msg_cpp.h.

Referenced by is_request(), msg_pack::make_reply_msg(), msg_connection::process_incoming_message(), and msg_user_connection::push_msg().

const size_t user_type_reply_async = 0x10000005

this is a reply on user send asynchronously

Definition at line 64 of file msg_cpp.h.

Referenced by is_request(), msg_pack::make_reply_msg(), msg_connection::process_incoming_message(), and msg_user_connection::push_msg().

const size_t user_type_send = 0x10000001

user type send, reply is required

message types

Definition at line 56 of file msg_cpp.h.

Referenced by msg_pack::make_reply_msg(), msg_user_connection::process_income_message(), msg_connection::process_incoming_message(), msg_user_connection::send(), msg_rpc_connection::send_msg(), msg_sock_connection::v_do_job(), and msg_communicator::v_do_job().

const size_t user_type_send_async = 0x10000002

user type send asynchronously, reply is required

Definition at line 58 of file msg_cpp.h.

Referenced by msg_pack::make_reply_msg(), msg_user_connection::process_income_message(), msg_connection::process_incoming_message(), msg_user_connection::send_async(), msg_rpc_connection::send_msg(), msg_sock_connection::v_do_job(), and msg_communicator::v_do_job().