MayaFlux 0.4.0
Digital-First Multimedia Processing Framework
Loading...
Searching...
No Matches

◆ on_payload_received()

void MayaFlux::Core::TCPBackend::on_payload_received ( ConnectionState conn,
const asio::error_code &  ec,
size_t  bytes 
)
private

Payload read completion handler.

Definition at line 514 of file TCPBackend.cpp.

516{
517 if (ec) {
518 on_connection_error(conn, ec);
519 return;
520 }
521
522 if (m_receive_callback) {
523 std::string peer_str = conn.info.remote_address + ":" + std::to_string(conn.info.remote_port);
524
525 m_receive_callback(conn.info.id,
526 conn.payload_buf.data(), conn.payload_buf.size(),
527 peer_str);
528 }
529
531}
void start_receive_chain(ConnectionState &conn)
Start the framed message receive chain on a connection.
NetworkReceiveCallback m_receive_callback
void on_connection_error(ConnectionState &conn, const asio::error_code &ec)
Handle a connection error (read/write failure).

References MayaFlux::Core::EndpointInfo::id, MayaFlux::Core::TCPBackend::ConnectionState::info, MayaFlux::Core::TCPBackend::ConnectionState::payload_buf, MayaFlux::Core::EndpointInfo::remote_address, and MayaFlux::Core::EndpointInfo::remote_port.