Slic3r::UdpSocket Class Reference

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

Inheritance diagram for Slic3r::UdpSocket:

Collaboration diagram for Slic3r::UdpSocket:

Public Member Functions
	UdpSocket (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)
	UdpSocket (Bonjour::ReplyFn replyfn, const boost::asio::ip::address &multicast_address, std::shared_ptr< boost::asio::io_context > io_service)
void	send ()
void	async_receive ()
void	cancel ()

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

Protected Attributes
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

UdpSocket() [1/2]

Slic3r::UdpSocket::UdpSocket	(	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 )

References io_service, multicast_address, and replyfn.

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

Here is the caller graph for this function:

UdpSocket() [2/2]

Slic3r::UdpSocket::UdpSocket	(	Bonjour::ReplyFn	replyfn,
		const boost::asio::ip::address &	multicast_address,
		std::shared_ptr< boost::asio::io_context >	io_service )

References io_service, multicast_address, and replyfn.

Member Function Documentation

async_receive()

void Slic3r::UdpSocket::async_receive

(

)

{
  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 ( )

inline

{ socket.cancel(); }

References socket.

create_session()

virtual SharedSession Slic3r::UdpSocket::create_session ( ) const

protectedpure virtual

Implemented in Slic3r::LookupSocket, and Slic3r::ResolveSocket.

Referenced by async_receive().

Here is the caller graph for this function:

receive_handler()

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

protected

{
  // 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

(

)

{
  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

protected

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

protected

Referenced by send().

multicast_address

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

protected

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

replyfn

Bonjour::ReplyFn Slic3r::UdpSocket::replyfn

protected

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().

requests

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

protected

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

socket

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

protected

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

---

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