NetworkSink() [1/3]

MayaFlux::Portal::Network::NetworkSink::NetworkSink ( const StreamConfig &  config )

explicit

Open a send endpoint from a StreamConfig.

Parameters

config

Stream configuration.

Resolves the transport hint, opens the endpoint via NetworkService, and logs a warning if the service is unavailable.

Definition at line 34 of file NetworkSink.cpp.

    : m_name(config.name)
{
    auto* svc = Registry::BackendRegistry::instance()
                    .get_service<Registry::Service::NetworkService>();
 
    if (!svc) {
        MF_WARN(Journal::Component::Portal, Journal::Context::Networking,
            "NetworkSink '{}': NetworkService not available", m_name);
        return;
    }
 
    m_service = svc;
 
    Core::EndpointInfo info;
    info.transport = resolve_transport(config.transport, config.profile);
    info.role = Core::EndpointRole::SEND;
    info.remote_address = config.endpoint.address;
    info.remote_port = config.endpoint.port;
    info.local_port = config.endpoint.local_port;
    info.label = config.name;
 
    m_endpoint_id = svc->open_endpoint(info);
 
    if (m_endpoint_id == 0) {
        MF_WARN(Journal::Component::Portal, Journal::Context::Networking,
            "NetworkSink '{}': endpoint open failed", m_name);
        return;
    }
 
    MF_DEBUG(Journal::Component::Portal, Journal::Context::Networking,
        "NetworkSink '{}' opened endpoint {}", m_name, m_endpoint_id);
}

References MayaFlux::Portal::Network::StreamEndpoint::address, MayaFlux::Portal::Network::StreamConfig::endpoint, MayaFlux::Registry::BackendRegistry::get_service(), MayaFlux::Registry::BackendRegistry::instance(), MayaFlux::Core::EndpointInfo::label, MayaFlux::Core::EndpointInfo::local_port, MayaFlux::Portal::Network::StreamEndpoint::local_port, m_endpoint_id, m_name, m_service, MF_DEBUG, MF_WARN, MayaFlux::Portal::Network::StreamConfig::name, MayaFlux::Journal::Networking, MayaFlux::Portal::Network::StreamEndpoint::port, MayaFlux::Journal::Portal, MayaFlux::Portal::Network::StreamConfig::profile, MayaFlux::Core::EndpointInfo::remote_address, MayaFlux::Core::EndpointInfo::remote_port, MayaFlux::Core::EndpointInfo::role, MayaFlux::Core::SEND, MayaFlux::Core::EndpointInfo::transport, and MayaFlux::Portal::Network::StreamConfig::transport.

Here is the call graph for this function: