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

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

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

---

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

Реализация интерфейса data_processor, которая преобразует входящие данные в сообщения msg_raw_package.

Начиная с:

v.4.4.0-b4 Каждый вызов метода process_incoming() приводит к отсылке сообщения msg_raw_package.

Метод process_outgoing() просто копирует данные из входящего буфера в исходящий.

Открытые члены
	raw_data_processor_t (const comm_channel_t &channel_id)
virtual so_4::ret_code_t	process_incoming (const void *from, size_t size, bool &is_blocked)
	Метод для обработки входящих данных.
virtual so_4::ret_code_t	append_outgoing_data (const void *what, size_t what_size, oess_1::io::obinstream_t &awaiting, oess_1::io::obinstream_t &outgoing)
virtual so_4::ret_code_t	make_outgoing_data (const void *what, size_t what_size, oess_1::io::obinstream_t &outgoing)
Закрытые данные
const comm_channel_t	m_channel_id
	Идентификатор, назначенный каналу, из которого читаются входящие данные.

---

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

so_4::rt::comm::raw_data_processor_t::raw_data_processor_t

(

const comm_channel_t &

channel_id

)

Аргументы:

channel_id

Идентификатор, назначенный каналу, из которого читаются входящие данные.

---

Методы

so_4::ret_code_t so_4::rt::comm::raw_data_processor_t::process_incoming	(	const void *	data,
		size_t	data_size,
		bool &	is_channel_blocked
	)			[virtual]

Метод для обработки входящих данных.

Этот метод вызывается контроллером канала после извлечения из канала очередной порции входящих данных. Метод должен передать транспортному агенту все данные, находящиеся в data.

Замещает so_4::transport_layer::data_processor_t.

Перекрестные ссылки so_4::rt::comm_channel_t::comm_agent(), m_channel_id и so_4::api::send_msg_safely().

so_4::ret_code_t so_4::rt::comm::raw_data_processor_t::append_outgoing_data	(	const void *	what,
		size_t	what_size,
		oess_1::io::obinstream_t &	awaiting,
		oess_1::io::obinstream_t &	outgoing
	)			[virtual]

Начиная с:

v.4.4.0-b5

Помещает данные сразу в outgoing.

Замещает so_4::transport_layer::data_processor_t.

so_4::ret_code_t so_4::rt::comm::raw_data_processor_t::make_outgoing_data	(	const void *	what,
		size_t	what_size,
		oess_1::io::obinstream_t &	outgoing
	)			[virtual]

Начиная с:

v.4.4.0-b5

Ничего не делает.

Замещает so_4::transport_layer::data_processor_t.