MayaFlux 1.0.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 518 of file TCPBackend.cpp.

520{
521 if (ec) {
522 on_connection_error(conn, ec);
523 return;
524 }
525
526 if (m_receive_callback) {
527 std::string peer_str = conn.info.remote_address + ":" + std::to_string(conn.info.remote_port);
528
529 m_receive_callback(conn.info.id,
530 conn.payload_buf.data(), conn.payload_buf.size(),
531 peer_str);
532 }
533
535}
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.