Класс so_4::rt::comm::a_raw_outgoing_channel_t

Граф наследования:so_4::rt::comm::a_raw_outgoing_channel_t:

Полный список членов класса

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

Агент исходящего RAW-канала.

Начиная с:

v.4.4.0-b4 В дополнение к унаследованным владеет следующими сообщениями:

msg_connect (so_4::rt::comm::msg_connect) принудительное установление соединения;
msg_success (so_4::rt::comm::msg_success) успешное установление соединения;
msg_fail (so_4::rt::comm::msg_fail) неудачная попытка установления соединения;
msg_channel_failed (so_4::transport_layer::msg_channel_failed) неудачная попытка создания канала.

Примеры:: sample/raw_channel/tcp_cln.cpp.


Открытые типы
Собственные сообщения, которые нужны для взаимодействия с контроллером канала.
Канал не создан.
typedef so_4::transport_layer::msg_channel_failed	msg_channel_failed
Открытые члены
	a_raw_outgoing_channel_t (const std::string &name, so_4::transport_layer::connector_controller_auto_ptr_t connector_controller, disconnect_handler_auto_ptr_t disconnect_handler)
bool	set_autoconnect_on_start (bool flag)
	Управление автоматическим началом попыток установления соединения сразу после старта агента.
Относящиеся к SObjectizer-у части агента.
virtual const char *	so_query_type () const
	Имя типа агента.
virtual void	so_on_subscription ()
	Подписка событий агента.
void	evt_start ()
	Реакция на регистрацию в SObjectizer.
void	evt_connect ()
	Реакция на сообщение msg_connect.
void	evt_channel_failed (const msg_channel_failed &cmd)
	Реакция на неудачную попытку установления соединения.
Защищенные члены
Реализация унаследованных методов.
virtual so_4::ret_code_t	on_channel_acception (so_4::transport_layer::channel_controller_t &controller, const comm_channel_t &channel_id)
virtual void	on_disconnection_initiated (const comm_channel_t &channel_id)
virtual void	on_channel_destroying (const comm_channel_t &channel_id)
Закрытые типы
typedef a_channel_processor_base_t	base_type_t
	Псевдоним базового класса.
Закрытые данные
so_4::transport_layer::connector_controller_auto_ptr_t	m_connector
	Интерфейс для управление установлением соединения.
disconnect_handler_auto_ptr_t	m_disconnect_handler
	Обработчик разрывов связи.
so_4::transport_layer::channel_id_t	m_id_counter
	Счетчик идентификаторов каналов.
bool	m_autoconnect_flag
	Признак разрешенности автоматического установления соединения сразу после старта агента в SObjectizer.

Конструктор(ы)

so_4::rt::comm::a_raw_outgoing_channel_t::a_raw_outgoing_channel_t	(	const std::string &	name,
		so_4::transport_layer::connector_controller_auto_ptr_t	connector_controller,
		disconnect_handler_auto_ptr_t	disconnect_handler
	)

Конструктор.

Аргументы:

name	Имя агента.
connector_controller	Интерфейс управления попытками установления соединения.
disconnect_handler	Объект, который будет управлять восстановлением связи после обрывов. Может быть нулевым указателем, если автоматическое восстановление связи не предусмотрено.

Методы

bool so_4::rt::comm::a_raw_outgoing_channel_t::set_autoconnect_on_start ( bool flag )

Управление автоматическим началом попыток установления соединения сразу после старта агента.

По умолчанию агент пытается установить соединение сразу после своей регистрации в SObjectizer-е.

Передав false в этот метод можно запретить агенту выполнять попытки установления соединения сразу после старта. В этом случае агент будет ожидать поступления сообщения msg_connect.

Возвращает:: Предыдущее значения признака автоматического установления соединения после старта.

Аргументы:

flag

true если установка соединения разрешена, false в противном случае.

Перекрестные ссылки m_autoconnect_flag.

virtual const char* so_4::rt::comm::a_raw_outgoing_channel_t::so_query_type ( ) const [virtual]

Имя типа агента.

Автоматически реализуется описанием класса агента посредством макросов SOL4_CLASS_START, SOL4_CLASS_FINISH.

Переопределяет метод предка so_4::rt::comm::a_channel_processor_base_t.

void so_4::rt::comm::a_raw_outgoing_channel_t::so_on_subscription ( ) [virtual]

Подписка событий агента.

Самый первый метод, который вызывается у агента после его регистрации в SObjectizer.

Предназначен для подписки событий агента.

У всех агентов регистрируемой кооперации вызываются методы so_on_subscription. Только после этого рассылается сообщение msg_coop_registered.

Переопределяет метод предка so_4::rt::comm::a_channel_processor_base_t.

Перекрестные ссылки so_4::rt::comm::a_channel_processor_base_t::so_on_subscription(), so_4::rt::agent_t::so_subscribe() и so_4::rt::sobjectizer_agent_name().

void so_4::rt::comm::a_raw_outgoing_channel_t::evt_start ( )

Реакция на регистрацию в SObjectizer.

Инициирует периодическое сообщение msg_timer.

Если разрешено автоматическое установление соединение после старта, то отсылает самому себе сообщение msg_connect.

Перекрестные ссылки m_autoconnect_flag, so_4::api::send_msg() и so_4::rt::agent_t::so_query_name().

void so_4::rt::comm::a_raw_outgoing_channel_t::evt_connect ( )

Реакция на сообщение msg_connect.

Инициирует попытку установления соединения.

Перекрестные ссылки so_4::transport_layer::create_std_channel_owner_notificator(), m_connector, m_disconnect_handler, so_4::api::send_msg_safely(), so_4::rt::agent_t::so_change_state() и so_4::rt::agent_t::so_query_name().

void so_4::rt::comm::a_raw_outgoing_channel_t::evt_channel_failed ( const msg_channel_failed & cmd )

Реакция на неудачную попытку установления соединения.

Отсылает msg_fail.

Задействует disconnect_handler для автоматической попытки повтора установления соединения.

Перекрестные ссылки m_disconnect_handler, so_4::transport_layer::msg_channel_failed::m_reason, so_4::api::send_msg_safely(), so_4::rt::agent_t::so_change_state() и so_4::rt::agent_t::so_query_name().

so_4::ret_code_t so_4::rt::comm::a_raw_outgoing_channel_t::on_channel_acception	(	so_4::transport_layer::channel_controller_t &	controller,
		const comm_channel_t &	channel_id
	)			`[protected, virtual]`