send()

bool MayaFlux::Core::TCPBackend::send ( uint64_t  endpoint_id, const uint8_t *  data, size_t  size  )

overridevirtual

Send data through an endpoint.

Parameters

endpoint_id	Target endpoint.
data	Pointer to payload bytes.
size	Payload size in bytes.

Returns

true if the send was accepted (queued or completed).

For UDP: sends a single datagram via sendto(). Non-blocking. For TCP: writes framed message. May block briefly if kernel send buffer is full. For SHM: writes into the shared segment.

Implements MayaFlux::Core::INetworkBackend.

Definition at line 286 of file TCPBackend.cpp.

{
    std::shared_lock lock(m_connections_mutex);
    auto it = m_connections.find(endpoint_id);
    if (it == m_connections.end()) {
        return false;
    }
 
    auto& conn = *it->second;
    if (conn.info.state != EndpointState::OPEN) {
        return false;
    }
 
    auto frame = std::make_shared<std::vector<uint8_t>>(sizeof(uint32_t) + size);
    uint32_t net_len = htonl(static_cast<uint32_t>(size));
    std::memcpy(frame->data(), &net_len, sizeof(uint32_t));
    std::memcpy(frame->data() + sizeof(uint32_t), data, size);
 
    asio::async_write(
        conn.socket,
        asio::buffer(*frame),
        [frame, endpoint_id, this](const asio::error_code& ec, size_t) {
            if (ec) {
                MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
                    "TCP write failed on endpoint {}: {}", endpoint_id, ec.message());
 
                std::shared_lock lk(m_connections_mutex);
                auto cit = m_connections.find(endpoint_id);
                if (cit != m_connections.end()) {
                    on_connection_error(*cit->second, ec);
                }
            }
        });
 
    return true;
}

References m_connections, m_connections_mutex, MayaFlux::Core::OPEN, and size.