Пространство имен so_4::rt::comm

---

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

Коммуникационные средства SObjectizer.

Классы
class	msg_fld_to_send_msg_t
class	msg_subscriber_t
class	a_cln_channel_t
	Класс агента клиентского канала связи. Подробнее...
class	a_cln_channel_base_t
	Базовый класс агента клиентского канала связи. Подробнее...
class	a_communicator_t
	Основной агент для реализации поддержки SOP. Подробнее...
struct	msg_sop_package
	Расшифровать SOP-пакет. Подробнее...
struct	msg_raw_package
	Обработать входящие данные из raw соединения. Подробнее...
struct	msg_send_package
	Команда на отправку пакета в коммуникационный канал. Подробнее...
struct	msg_client_connected
	Уведомление о появлении нового коммуникационного канала. Подробнее...
struct	msg_client_disconnected
	Уведомление о закрытии коммуникационного канала. Подробнее...
struct	msg_channel_destroyed
	Уведомление о разрушении коммуникационного канала. Подробнее...
struct	msg_set_filter
	Сообщение на установление фильтра для канала. Подробнее...
struct	msg_close_channel
	Команда на принудительное закрытие канала. Подробнее...
struct	msg_unblock_channel
	Указание разблокировать канал после превышения порога входящего потока. Подробнее...
struct	msg_start_channel_timing
	Необходимо начать отсчет тайм-аутов для канала. Подробнее...
struct	msg_set_channel_transformator
	Установка трансформатора трафика для указанного канала. Подробнее...
struct	msg_set_server_filter
	Установка входящего фильтра для серверного канала. Подробнее...
struct	msg_remove_server_filter
	Изъятие входящего фильтра для серверного канала. Подробнее...
class	a_raw_cln_channel_t
	Класс агента клиентского raw канала связи. Подробнее...
class	a_raw_srv_channel_t
	Класс агента серверного канала связи. Подробнее...
class	a_sockcln_t
	Агент для коммуникации через клиентский TCP/IP сокет по SOP. Подробнее...
class	a_socksrv_t
	Класс агента для коммуникации через серверный TCP/IP сокет. Подробнее...
class	a_srv_channel_t
	Класс агента серверного канала связи. Подробнее...
class	a_srv_channel_base_t
	Базовый класс агента серверного канала связи. Подробнее...
class	io_channel_t
	передачу данных. Подробнее...
class	client_factory_t
	Базовый класс для создателя клиентских соединений. Подробнее...
class	server_channel_t
	Базовый класс для серверного канала. Подробнее...
class	threshold_t
	Класс для представления порога объема трафика. Подробнее...
class	traffic_transformator_t
	Интерфейс трансформатора коммуникационного трафика. Подробнее...
class	null_transformator_t
	Трансформатор, который не выполняет никаких преобразований. Подробнее...
class	zlib_transformator_t
	Реализация трансформатора SOP трафика с использованием zlib. Подробнее...
Пространства имен
namespace	a_cln_channel_impl
	Пространство имен деталей реализации агента a_cln_channel_base_t.
namespace	channels_impl
	Детали реализации понятия коммуникационных каналов.
namespace	impl
	Детали реализации.
namespace	zlib_transformator
	Детали реализации zlib-трансформатора.
Функции
	SOL4_MSG_START (msg_set_channel_transformator, so_4::rt::comm::msg_set_channel_transformator) SOL4_EVENT_STC(evt_set_channel_transformator
	SOL4_MSG_START (msg_success, so_4::rt::comm::a_cln_channel_base_t::msg_success) SOL4_MSG_START(msg_fail
so_4::rt::comm::a_cln_channel_base_t::msg_fail	SOL4_MSG_START (msg_connect, so_4::rt::comm::a_cln_channel_base_t::msg_connect) SOL4_MSG_START(msg_do_io
so_4::rt::comm::a_cln_channel_base_t::msg_fail so_4::rt::comm::a_cln_channel_base_t::msg_do_io	SOL4_MSG_START (msg_client_connected, so_4::rt::comm::msg_client_connected) SOL4_MSG_START(msg_client_disconnected
so_4::rt::comm::a_cln_channel_base_t::msg_fail so_4::rt::comm::a_cln_channel_base_t::msg_do_io so_4::rt::comm::msg_client_disconnected	SOL4_EVENT_WITH_INCIDENT_TYPE (evt_start, so_4::rt::msg_start) SOL4_EVENT_WITH_INCIDENT_TYPE(evt_connect
so_4::rt::comm::a_cln_channel_base_t::msg_fail so_4::rt::comm::a_cln_channel_base_t::msg_do_io so_4::rt::comm::msg_client_disconnected so_4::rt::comm::a_cln_channel_base_t::msg_connect	SOL4_EVENT_WITH_INCIDENT_TYPE (evt_close_channel, so_4::rt::comm::msg_close_channel) SOL4_EVENT_WITH_INCIDENT_TYPE(evt_send_package
so_4::rt::comm::a_cln_channel_base_t::msg_fail so_4::rt::comm::a_cln_channel_base_t::msg_do_io so_4::rt::comm::msg_client_disconnected so_4::rt::comm::a_cln_channel_base_t::msg_connect so_4::rt::comm::msg_send_package	SOL4_EVENT_WITH_INCIDENT_TYPE (evt_do_io, so_4::rt::comm::a_cln_channel_base_t::msg_do_io) SOL4_EVENT_WITH_INCIDENT_TYPE(evt_unblock_channel
static void	create_send_msg_info (const event_data_t &data, so_4::sop::req_info_storage_t &reqs)
	Создание SOP-запроса send-msg.
static void	channel_closer (const so_4::rt::comm_channel_t &channel)
	Предикат для std::for_each.
	SOL4_MSG_START (msg_sop_package, so_4::rt::comm::msg_sop_package) SOL4_MSG_START(msg_send_package
so_4::rt::comm::msg_send_package so_4::rt::comm::msg_client_disconnected	SOL4_MSG_START (msg_channel_destroyed, so_4::rt::comm::msg_channel_destroyed) SOL4_MSG_START(msg_set_filter
so_4::rt::comm::msg_send_package so_4::rt::comm::msg_client_disconnected so_4::rt::comm::msg_set_filter	SOL4_MSG_START (msg_close_channel, so_4::rt::comm::msg_close_channel) SOL4_MSG_START(msg_check_no_activity_time
so_4::rt::comm::msg_send_package so_4::rt::comm::msg_client_disconnected so_4::rt::comm::msg_set_filter so_4::rt::comm::a_communicator_t::msg_check_no_activity_time	SOL4_MSG_START (msg_unblock_channel, so_4::rt::comm::msg_unblock_channel) SOL4_MSG_START(msg_start_channel_timing
so_4::rt::comm::msg_send_package so_4::rt::comm::msg_client_disconnected so_4::rt::comm::msg_set_filter so_4::rt::comm::a_communicator_t::msg_check_no_activity_time so_4::rt::comm::msg_start_channel_timing	SOL4_MSG_START (msg_set_server_filter, so_4::rt::comm::msg_set_server_filter) SOL4_MSG_START(msg_remove_server_filter
so_4::rt::comm::msg_send_package so_4::rt::comm::msg_client_disconnected so_4::rt::comm::msg_set_filter so_4::rt::comm::a_communicator_t::msg_check_no_activity_time so_4::rt::comm::msg_start_channel_timing so_4::rt::comm::msg_remove_server_filter	SOL4_EVENT_WITH_INCIDENT_TYPE (evt_sop_package, so_4::rt::comm::msg_sop_package) SOL4_EVENT_WITH_FACTORY(evt_global_agent_msg
so_4::rt::comm::msg_send_package so_4::rt::comm::msg_client_disconnected so_4::rt::comm::msg_set_filter so_4::rt::comm::a_communicator_t::msg_check_no_activity_time so_4::rt::comm::msg_start_channel_timing so_4::rt::comm::msg_remove_server_filter so_4::rt::impl::retranslator_evt_factory	SOL4_EVENT_WITH_INCIDENT_TYPE (evt_set_filter, so_4::rt::comm::msg_set_filter) SOL4_EVENT_STC(evt_channel_destroyed
so_4::rt::comm::msg_send_package so_4::rt::comm::msg_client_disconnected so_4::rt::comm::msg_set_filter so_4::rt::comm::a_communicator_t::msg_check_no_activity_time so_4::rt::comm::msg_start_channel_timing so_4::rt::comm::msg_remove_server_filter so_4::rt::impl::retranslator_evt_factory so_4::rt::comm::msg_channel_destroyed	SOL4_EVENT_STC (evt_client_connected, so_4::rt::comm::msg_client_connected) SOL4_EVENT_WITH_INCIDENT_TYPE(evt_check_no_activity_time
so_4::rt::comm::msg_send_package so_4::rt::comm::msg_client_disconnected so_4::rt::comm::msg_set_filter so_4::rt::comm::a_communicator_t::msg_check_no_activity_time so_4::rt::comm::msg_start_channel_timing so_4::rt::comm::msg_remove_server_filter so_4::rt::impl::retranslator_evt_factory so_4::rt::comm::msg_channel_destroyed so_4::rt::comm::a_communicator_t::msg_check_no_activity_time	SOL4_EVENT_WITH_INCIDENT_TYPE (evt_start_channel_timing, so_4::rt::comm::msg_start_channel_timing) SOL4_EVENT_STC(evt_set_server_filter
const std::string &	communicator_agent_name ()
	Реальное имя агента a_communicator.
	SOL4_MSG_START (msg_raw_package, so_4::rt::comm::msg_raw_package) SOL4_MSG_START(msg_send_package
	SOL4_MSG_START (msg_creation_ok, so_4::rt::comm::a_sockcln_t::msg_creation_ok) SOL4_MSG_START(msg_creation_failed
so_4::rt::comm::a_sockcln_t::msg_creation_failed	SOL4_EVENT_WITH_INCIDENT_TYPE (evt_success, so_4::rt::comm::a_cln_channel_base_t::msg_success) SOL4_EVENT_WITH_INCIDENT_TYPE(evt_fail
	SOL4_MSG_START (msg_creation_ok, so_4::rt::comm::a_socksrv_t::msg_creation_ok) SOL4_MSG_START(msg_creation_failed
so_4::rt::comm::a_socksrv_t::msg_creation_failed	SOL4_EVENT_WITH_INCIDENT_TYPE (evt_success, so_4::rt::comm::a_srv_channel_base_t::msg_success) SOL4_EVENT_WITH_INCIDENT_TYPE(evt_fail
	SOL4_MSG_START (msg_success, so_4::rt::comm::a_srv_channel_base_t::msg_success) SOL4_MSG_START(msg_fail
so_4::rt::comm::a_srv_channel_base_t::msg_fail	SOL4_MSG_START (msg_do_io, so_4::rt::comm::a_srv_channel_base_t::msg_do_io) SOL4_MSG_START(msg_client_connected
so_4::rt::comm::a_srv_channel_base_t::msg_fail so_4::rt::comm::msg_client_connected	SOL4_MSG_START (msg_client_disconnected, so_4::rt::comm::msg_client_disconnected) SOL4_EVENT_WITH_INCIDENT_TYPE(evt_start
so_4::rt::comm::a_srv_channel_base_t::msg_fail so_4::rt::comm::msg_client_connected so_4::rt::msg_start	SOL4_EVENT_WITH_INCIDENT_TYPE (evt_send_package, so_4::rt::comm::msg_send_package) SOL4_EVENT_WITH_INCIDENT_TYPE(evt_do_io
std::ostream &	operator<< (std::ostream &to, const threshold_t &o)
	Отобразить значение порога в указанный поток.
Переменные
so_4::rt::comm::a_cln_channel_base_t::msg_fail so_4::rt::comm::a_cln_channel_base_t::msg_do_io so_4::rt::comm::msg_client_disconnected so_4::rt::comm::a_cln_channel_base_t::msg_connect so_4::rt::comm::msg_send_package so_4::rt::comm::msg_unblock_channel const unsigned int	do_io_period
so_4::rt::comm::a_srv_channel_base_t::msg_fail so_4::rt::comm::msg_client_connected so_4::rt::msg_start so_4::rt::comm::a_srv_channel_base_t::msg_do_io so_4::rt::comm::msg_unblock_channel const unsigned int	do_io_period
const int	success
	Успешное завершение функции.
const int	no_new_connections
	Нет новых подключений.
const int	invalid_package_header
	Некорректный заголовок SOP пакета.
const int	server_channel_creation_fail
	Ошибка создания серверного физического канала.
const int	receive_failed
	Ошибка чтения данных.
const int	send_failed
	Ошибка отсылки данных.
const int	awaiting_obuf_too_large
	Превышен допустимый размер буфера ожидающих отправки данных.
const int	ibuf_too_large
	Превышен допустимый размер буфера прочитанных данных.
const int	connection_closed
	Соединение закрыто на другом конце.
const int	notwriteable_timeout
	недоступности для записи.
const int	incorrect_data
	Ошибка в полученных из канала данных.

---

Функции

static void so_4::rt::comm::channel_closer (  const so_4::rt::comm_channel_t &  channel  )  [static]

Предикат для std::for_each. Отсылает транспортным агентам, обслуживающим указанный коммуникационный канал сообщение msg_close_channel.

const std::string & so_4::rt::comm::communicator_agent_name (   )

Реальное имя агента a_communicator. Внимание: для подписки или отсылки сообщений агента a_communicator для определения имени агента-коммуникатора необходимо использовать только эту функцию. Примеры: sample/high_traffic/client.cpp.

static void so_4::rt::comm::create_send_msg_info (  const event_data_t &  data, so_4::sop::req_info_storage_t &  reqs )  [static]

Создание SOP-запроса send-msg. Занесение в SOP-запрос значений полей реального сообщения. Созданный SOP-запрос помещается в указанное хранилище.

std::ostream& so_4::rt::comm::operator<< (  std::ostream &  to, const threshold_t &  o )  [inline]

Отобразить значение порога в указанный поток. Начиная с: v.4.2.6

---

Переменные

const int so_4::rt::comm::awaiting_obuf_too_large

Превышен допустимый размер буфера ожидающих отправки данных. Начиная с: v.4.2.4

const int so_4::rt::comm::connection_closed

Соединение закрыто на другом конце. Начиная с: v.4.2.4

const int so_4::rt::comm::ibuf_too_large

Превышен допустимый размер буфера прочитанных данных. Начиная с: v.4.2.4

const int so_4::rt::comm::incorrect_data

Ошибка в полученных из канала данных. Начиная с: v.4.2.7 Например, не совпадение контрольных сумм.

const int so_4::rt::comm::invalid_package_header

Некорректный заголовок SOP пакета. Начиная с: v.4.2.4

const int so_4::rt::comm::no_new_connections

Нет новых подключений. Начиная с: v.4.2.4

const int so_4::rt::comm::notwriteable_timeout

недоступности для записи. Начиная с: v.4.2.4

const int so_4::rt::comm::receive_failed

Ошибка чтения данных. Начиная с: v.4.2.4

const int so_4::rt::comm::send_failed

Ошибка отсылки данных. Начиная с: v.4.2.4

const int so_4::rt::comm::server_channel_creation_fail

Ошибка создания серверного физического канала. Начиная с: v.4.2.4

const int so_4::rt::comm::success

Успешное завершение функции. Начиная с: v.4.2.4

---