Пространство имен so_5_transport

Основное пространство транспортного SObjectizer. Подробнее...

Пространства имен
namespace	ace
	Обертки над кассами ACE_Reactor для SObjectizer 5 Transport.
namespace	socket
	Реализация транспортного слоя SObjectizer на основе сокетов.

Классы
class	a_channel_base_t
	Базовый класс канального агента. Подробнее...
class	a_client_base_t
	Базовый класс агента выполняющего роль клиента. Подробнее...
class	a_server_base_t
	Базовый класс агента выполняющего роль сервера. Подробнее...
class	a_transport_agent_t
	Базовый класс транспортного агента. Подробнее...
class	a_server_transport_agent_t
	Серверный транспортный агент. Подробнее...
struct	client_reconnect_params_t
	Стратегия переподключения при разрыве связи клиентского транспортного агента. Подробнее...
class	a_client_transport_agent_t
	Клиентсикй транспортный агент. Подробнее...
class	channel_controller_t
	Интерфейс для контроллера канала. Подробнее...
class	channel_controller_ref_t
	Умная ссылка на channel_controller_t. Подробнее...
class	channel_io_t
	Класс для получения потоков канала. Подробнее...
class	channel_params_t
	Инкапсуляция различных параметров транспортного канала. Подробнее...
class	channel_input_stream_t
	Входящий oess_2::io::ibinstream_t поток берущий данные из scattered_block_stream_t. Подробнее...
class	channel_output_stream_t
	Исходящий oess_2::io поток вставляющий данные в scattered_block_stream_t. Подробнее...
class	connector_controller_t
	Интерфейс управления объектом-connector-ом. Подробнее...
class	acceptor_controller_t
	Интерфейс управления объектом-acceptor-ом. Подробнее...
class	input_trx_t
	Класс транзакции чтения данных. Подробнее...
class	output_trx_t
	Класс транзакции записи данных. Подробнее...
struct	msg_create_server_socket_result
	Статус создания серверного сокета. Подробнее...
struct	msg_channel_created
	Сообщение об успешном создании транспортного канала. Подробнее...
struct	msg_channel_failed
	Сообщение о неудачном создании транспортного канала. Подробнее...
struct	msg_channel_lost
	Сообщение о закрытии транспортного канала. Подробнее...
struct	msg_incoming_package
	Сообщение-уведомление о поступлении нового пакета данных. Подробнее...
class	raw_block_t
	Коммуникационный блок-буфер. Подробнее...
class	reactor_layer_params_t
	Класс для добавления параметров слоя реакторов Подробнее...
class	reactor_layer_t
	Класс для обеспечения работы с диспетчерами. Подробнее...
struct	scattered_block_stream_params_t
	Параметры блочного потока-буфера. Подробнее...
class	scattered_block_stream_t
	Поток блоков-буферов. Подробнее...
class	scattered_block_stream_ref_t
	Умная ссылка не scattered_block_stream_t. Подробнее...

Определения типов
typedef std::unique_ptr < channel_input_stream_t >	channel_input_stream_unique_ptr_t
	Псевдоним unique_ptr для channel_input_stream_t.
typedef std::unique_ptr < channel_output_stream_t >	channel_output_stream_unique_ptr_t
	Псевдоним unique_ptr для channel_output_stream_t.
typedef unsigned long	channel_id_t
	Тип идентификатора транспортного канала.
typedef std::unique_ptr < connector_controller_t >	connector_controller_unique_ptr_t
	Псевдоним unique_ptr для connector_controller_t.
typedef std::unique_ptr < acceptor_controller_t >	acceptor_controller_unique_ptr_t
	Псевдоним unique_ptr для acceptor_controller_t.
typedef std::unique_ptr < input_trx_t >	input_trx_unique_ptr_t
	Псевдоним unique_ptr для input_trx_t.
typedef std::unique_ptr < output_trx_t >	output_trx_unique_ptr_t
	Псевдоним unique_ptr для output_trx_t.
typedef std::list< raw_block_t * >	raw_block_chain_t
	Псевдоним для цепочки блоков. Подробнее...
typedef ACE_Hash_Map_Manager_Ex < std::string, so_5_transport::ace::reactor_instance_ref_t, std_string_djb_hash_t, ACE_Equal_To< std::string > , ACE_Null_Mutex >	reactor_instance_hash_map_t
	Тип Hash_Map-а для хранения reactor_instance.

Функции
void	close_channel (const channel_controller_ref_t &controller)
ACE_UINT32	hash_DJB (const char *string, size_t string_size)
void	handle_trx_is_not_running ()
void	handle_no_free_blocks_available ()

Переменные
Ошибки работы с реакторами.
const int	rc_reactor_task_activation_failed
const int	rc_default_reactor_start_failed
const int	rc_named_reactor_start_failed
const int	rc_failed_to_enforce_input_detection_no_free_blocks
const int	rc_reactor_layer_is_not_set
	Слой реакторов не установлен.
const int	rc_reactor_not_found
	Реактор не найден.
Ошибки транспортного слоя.
const int	rc_acceptor_creation_failed
	Не удается создать acceptor.
const int	rc_not_enough_data_to_read_from_buffer
	В буфере недостаточно места для чтения данных.
const int	rc_no_free_blocks_available_in_buffer
	В буфере нет места для записи данных.
const int	rc_transactiorn_not_started
	Попытка начать запись в поток над которым не начата транзакция.
const int	rc_notification_mbox_zero_ptr
	При указании mbox-а на который отсылать уведомления о событиях с каналом, был указан пустой mbox.
const int	rc_ta_mbox_zero_ptr
	При указании mbox-а транспортного агента, был указан пустой mbox.
const int	rc_controller_is_closed
	Нельзя выполнять действий с контроллером после того как он был закрыт.
const int	rc_connect_failed
	Не удается установить соединение с сервером.
Ошибки общего плана.
const int	rc_common_error_mask
	Маска для ошибок общего плана.
const int	rc_empty_name
	Пустое имя ( mbox-а, кооперации ).
const int	rc_unexpected_error

Подробное описание

Основное пространство транспортного SObjectizer.

Типы

typedef std::list< raw_block_t * > so_5_transport::raw_block_chain_t

Псевдоним для цепочки блоков.

Используется в scattered_block_stream_t.

См. также

scattered_block_stream_t::occupy(), scattered_block_stream_t::release().