acquire_socket()

UDPBackend::SocketState * MayaFlux::Core::UDPBackend::acquire_socket ( uint16_t  local_port )

private

Get or create a socket bound to local_port.

If a socket for this port already exists, increments ref_count and returns it. Otherwise binds a new socket and starts the async receive loop.

Definition at line 268 of file UDPBackend.cpp.

{
    std::unique_lock lock(m_sockets_mutex);
 
    auto it = m_sockets.find(local_port);
    if (it != m_sockets.end()) {
        it->second->ref_count++;
        return it->second.get();
    }
 
    auto state = std::make_unique<SocketState>(m_context);
    state->local_port = local_port;
    state->ref_count = 1;
 
    asio::error_code ec;
    if (state->socket.open(asio::ip::udp::v4(), ec)) {
        MF_ERROR(Journal::Component::Core, Journal::Context::NetworkBackend,
            "Failed to open UDP socket: {}", ec.message());
        return nullptr;
    }
 
    if (state->socket.set_option(asio::socket_base::reuse_address(true), ec)) {
        MF_ERROR(Journal::Component::Core, Journal::Context::NetworkBackend,
            "Failed to set SO_REUSEADDR on UDP socket: {}", ec.message());
        return nullptr;
    }
 
    if (local_port > 0) {
        if (
            state->socket.bind(
                asio::ip::udp::endpoint(asio::ip::udp::v4(), local_port), ec)) {
            MF_ERROR(Journal::Component::Core, Journal::Context::NetworkBackend,
                "Failed to bind UDP socket to port {}: {}", local_port, ec.message());
            return nullptr;
        }
    }
 
    if (m_config.receive_buffer_size > 0) {
        if (state->socket.set_option(
                asio::socket_base::receive_buffer_size(
                    static_cast<int>(m_config.receive_buffer_size)),
                ec)) {
            MF_WARN(Journal::Component::Core, Journal::Context::NetworkBackend,
                "Failed to set receive buffer size on UDP socket: {}", ec.message());
        }
    }
 
    auto* raw = state.get();
    m_sockets[local_port] = std::move(state);
 
    start_receive_loop(*raw);
 
    MF_DEBUG(Journal::Component::Core, Journal::Context::NetworkBackend,
        "UDP socket bound to port {}", local_port);
 
    return raw;
}

References MayaFlux::Journal::Core, m_config, m_context, m_sockets, m_sockets_mutex, MF_DEBUG, MF_ERROR, MF_WARN, MayaFlux::Journal::NetworkBackend, MayaFlux::Core::UDPBackendInfo::receive_buffer_size, and start_receive_loop().

Referenced by open_endpoint().

Here is the call graph for this function:

Here is the caller graph for this function: