Simple stateless translator for incoming TCP messages from binary format into the structured format. More...

Inheritance diagram for openlcb::TcpRecvFlow:

Public Member Functions
	TcpRecvFlow (MessageHandler *target)

void	send (Buffer< HubData > *data, unsigned prio) override
	Entry point for the incoming (binary) data.

Public Member Functions inherited from FlowInterface< Buffer< HubData > >
virtual Pool *	pool ()

virtual Buffer< HubData > *	type_helper ()
	This function is never user in the code, but GDB can use it to infer the correct message types.

Buffer< HubData > *	alloc ()
	Synchronously allocates a message buffer from the pool of this flow.

void	alloc_async (Executable *target)
	Asynchronously allocates a message buffer from the pool of this flow.

Private Attributes
MessageHandler *	target_
	Flow(interface) where to pass on the parsed GenMessage.

Additional Inherited Members
Public Types inherited from FlowInterface< Buffer< HubData > >
typedef Buffer< HubData >	message_type
	Stores the message template type for external reference.

Static Public Member Functions inherited from FlowInterface< Buffer< HubData > >
static Buffer< HubData > *	cast_alloc (QMember *entry)
	Down casts and initializes an asynchronous allocation result to the appropriate flow's buffer type.

Detailed Description

Simple stateless translator for incoming TCP messages from binary format into the structured format.

Drops everything to the floor that is not a valid TCP message. Performs synchronous allocation and keeps the done callback passed along.

Definition at line 588 of file IfTcpImpl.hxx.

Constructor & Destructor Documentation

openlcb::TcpRecvFlow::TcpRecvFlow ( MessageHandler * target )

inline

Parameters

target is where to send the parsed messages. Usually the interface's dispatcher flow.

Definition at line 593 of file IfTcpImpl.hxx.

void openlcb::TcpRecvFlow::send	(	Buffer< HubData > *	data,
		unsigned	prio
	)

inlineoverridevirtual

Entry point for the incoming (binary) data.

These are already segmented correctly to openlcb-TCP packet boundaries.

Parameters

data	buffer
prio	priority

Definition at line 602 of file IfTcpImpl.hxx.

MessageHandler* openlcb::TcpRecvFlow::target_

private

Flow(interface) where to pass on the parsed GenMessage.

Definition at line 615 of file IfTcpImpl.hxx.

The documentation for this class was generated from the following file: