Slic3r::LookupSocket Class Reference

#include </home/runner/work/OrcaSlicer/OrcaSlicer/src/slic3r/Utils/Bonjour.hpp>

Inheritance diagram for Slic3r::LookupSocket:

Collaboration diagram for Slic3r::LookupSocket:

Public Member Functions
	LookupSocket (Bonjour::TxtKeys txt_keys, std::string service, std::string service_dn, std::string protocol, Bonjour::ReplyFn replyfn, const boost::asio::ip::address &multicast_address, const boost::asio::ip::address &interface_address, std::shared_ptr< boost::asio::io_context > io_service)
	LookupSocket (Bonjour::TxtKeys txt_keys, std::string service, std::string service_dn, std::string protocol, Bonjour::ReplyFn replyfn, const boost::asio::ip::address &multicast_address, std::shared_ptr< boost::asio::io_context > io_service)
const Bonjour::TxtKeys	get_txt_keys () const
const std::string	get_service () const
const std::string	get_service_dn () const
void	send ()
void	async_receive ()
void	cancel ()

Protected Member Functions
SharedSession	create_session () const override
void	create_request ()
void	receive_handler (SharedSession session, const boost::system::error_code &error, size_t bytes)

Protected Attributes
boost::optional< BonjourRequest >	request
Bonjour::TxtKeys	txt_keys
std::string	service
std::string	service_dn
std::string	protocol
Bonjour::ReplyFn	replyfn
boost::asio::ip::address	multicast_address
boost::asio::ip::udp::socket	socket
boost::asio::ip::udp::endpoint	mcast_endpoint
std::shared_ptr< boost::asio::io_context >	io_service
std::vector< BonjourRequest >	requests

Detailed Description

Constructor & Destructor Documentation

LookupSocket() [1/2]

Slic3r::LookupSocket::LookupSocket ( Bonjour::TxtKeys txt_keys, std::string service, std::string service_dn, std::string protocol, Bonjour::ReplyFn replyfn, const boost::asio::ip::address & multicast_address, const boost::asio::ip::address & interface_address, std::shared_ptr< boost::asio::io_context > io_service )

inline

    : UdpSocket(replyfn, multicast_address, interface_address, io_service)
    , txt_keys(txt_keys)
    , service(service)
    , service_dn(service_dn)
    , protocol(protocol)
  {
    assert(!service.empty() && replyfn);
    create_request();
  }

References Slic3r::UdpSocket::UdpSocket(), create_request(), Slic3r::UdpSocket::io_service, Slic3r::UdpSocket::multicast_address, protocol, Slic3r::UdpSocket::replyfn, service, service_dn, and txt_keys.

Here is the call graph for this function:

LookupSocket() [2/2]

Slic3r::LookupSocket::LookupSocket ( Bonjour::TxtKeys txt_keys, std::string service, std::string service_dn, std::string protocol, Bonjour::ReplyFn replyfn, const boost::asio::ip::address & multicast_address, std::shared_ptr< boost::asio::io_context > io_service )

inline

    : UdpSocket(replyfn, multicast_address, io_service)
    , txt_keys(txt_keys)
    , service(service)
    , service_dn(service_dn)
    , protocol(protocol)
  {
    assert(!service.empty() && replyfn);
    create_request();
  }

References Slic3r::UdpSocket::UdpSocket(), create_request(), Slic3r::UdpSocket::io_service, Slic3r::UdpSocket::multicast_address, protocol, Slic3r::UdpSocket::replyfn, service, service_dn, and txt_keys.

Here is the call graph for this function:

Member Function Documentation

async_receive()

void Slic3r::UdpSocket::async_receive ( )

inherited

{
  try {
    // our session to hold the buffer + endpoint
    auto session = create_session();
    socket.async_receive_from(asio::buffer(session->buffer, session->buffer.size())
      , session->remote_endpoint
      , boost::bind(&UdpSocket::receive_handler, this, session, asio::placeholders::error, asio::placeholders::bytes_transferred));
  }
  catch (std::exception& e) {
    BOOST_LOG_TRIVIAL(error) << e.what();
  }
}

References create_session(), receive_handler(), and socket.

Referenced by receive_handler(), and send().

Here is the call graph for this function:

Here is the caller graph for this function:

cancel()

void Slic3r::UdpSocket::cancel ( )

inlineinherited

{ socket.cancel(); }

References socket.

create_request()

void Slic3r::LookupSocket::create_request ( )

inlineprotected

  {
    requests.clear();
    // create PTR request
    if (auto rqst = BonjourRequest::make_PTR(service, protocol); rqst)
      requests.push_back(std::move(rqst.get()));
  }

References Slic3r::BonjourRequest::make_PTR(), protocol, Slic3r::UdpSocket::requests, and service.

Referenced by LookupSocket(), and LookupSocket().

Here is the call graph for this function:

Here is the caller graph for this function:

create_session()

SharedSession Slic3r::LookupSocket::create_session ( ) const

overrideprotectedvirtual

Implements Slic3r::UdpSocket.

{ 
  return std::shared_ptr< LookupSession >(new LookupSession(this, replyfn));
}

References Slic3r::UdpSocket::replyfn.

get_service()

const std::string Slic3r::LookupSocket::get_service ( ) const

inline

{ return service; }

References service.

get_service_dn()

const std::string Slic3r::LookupSocket::get_service_dn ( ) const

inline

{ return service_dn; }

References service_dn.

get_txt_keys()

const Bonjour::TxtKeys Slic3r::LookupSocket::get_txt_keys ( ) const

inline

{ return txt_keys; }

References txt_keys.

receive_handler()

void Slic3r::UdpSocket::receive_handler ( SharedSession session, const boost::system::error_code & error, size_t bytes )

protectedinherited

{
  // let io_service to handle the datagram on session
  // from boost documentation io_service::post:
  // The io_service guarantees that the handler will only be called in a thread in which the run(), run_one(), poll() or poll_one() member functions is currently being invoked.
  boost::asio::post(*io_service, boost::bind(&UdpSession::handle_receive, session, error, bytes));
  // immediately accept new datagrams
  async_receive();
}

References async_receive(), Slic3r::UdpSession::handle_receive(), and io_service.

Referenced by async_receive().

Here is the call graph for this function:

Here is the caller graph for this function:

send()

void Slic3r::UdpSocket::send ( )

inherited

{
  try {
    for (const auto& request : requests)
      socket.send_to(asio::buffer(request.m_data), mcast_endpoint);
    
    // Should we care if this is called while already receiving? (async_receive call from receive_handler)
    async_receive();
  }
  catch (std::exception& e) {
    BOOST_LOG_TRIVIAL(error) << e.what();
  }
}

References async_receive(), mcast_endpoint, requests, and socket.

Here is the call graph for this function:

Member Data Documentation

io_service

std::shared_ptr< boost::asio::io_context > Slic3r::UdpSocket::io_service

protectedinherited

Referenced by Slic3r::LookupSocket::LookupSocket(), Slic3r::LookupSocket::LookupSocket(), Slic3r::ResolveSocket::ResolveSocket(), Slic3r::ResolveSocket::ResolveSocket(), UdpSocket(), UdpSocket(), and receive_handler().

mcast_endpoint

boost::asio::ip::udp::endpoint Slic3r::UdpSocket::mcast_endpoint

protectedinherited

Referenced by send().

multicast_address

boost::asio::ip::address Slic3r::UdpSocket::multicast_address

protectedinherited

Referenced by Slic3r::LookupSocket::LookupSocket(), Slic3r::LookupSocket::LookupSocket(), Slic3r::ResolveSocket::ResolveSocket(), Slic3r::ResolveSocket::ResolveSocket(), UdpSocket(), and UdpSocket().

protocol

std::string Slic3r::LookupSocket::protocol

protected

Referenced by LookupSocket(), LookupSocket(), and create_request().

replyfn

Bonjour::ReplyFn Slic3r::UdpSocket::replyfn

protectedinherited

Referenced by Slic3r::LookupSocket::LookupSocket(), Slic3r::LookupSocket::LookupSocket(), Slic3r::ResolveSocket::ResolveSocket(), Slic3r::ResolveSocket::ResolveSocket(), UdpSocket(), UdpSocket(), Slic3r::LookupSocket::create_session(), and Slic3r::ResolveSocket::create_session().

request

boost::optional<BonjourRequest> Slic3r::LookupSocket::request

protected

requests

std::vector<BonjourRequest> Slic3r::UdpSocket::requests

protectedinherited

Referenced by Slic3r::LookupSocket::create_request(), Slic3r::ResolveSocket::create_requests(), and send().

service

std::string Slic3r::LookupSocket::service

protected

Referenced by LookupSocket(), LookupSocket(), create_request(), and get_service().

service_dn

std::string Slic3r::LookupSocket::service_dn

protected

Referenced by LookupSocket(), LookupSocket(), and get_service_dn().

socket

boost::asio::ip::udp::socket Slic3r::UdpSocket::socket

protectedinherited

Referenced by async_receive(), cancel(), and send().

txt_keys

Bonjour::TxtKeys Slic3r::LookupSocket::txt_keys

protected

Referenced by LookupSocket(), LookupSocket(), and get_txt_keys().

---

The documentation for this class was generated from the following files:

• /home/runner/work/OrcaSlicer/OrcaSlicer/src/slic3r/Utils/Bonjour.hpp
• /home/runner/work/OrcaSlicer/OrcaSlicer/src/slic3r/Utils/Bonjour.cpp