fc::udp_socket Class Reference

#include <udp_socket.hpp>

Classes
class	impl

Public Member Functions
	udp_socket ()
	udp_socket (const udp_socket &s)
	~udp_socket ()
void	initialize (boost::asio::io_service &)
void	open ()
void	send_to (const char *b, size_t l, boost::asio::ip::udp::endpoint &to)
void	send_to (const std::shared_ptr< const char > &b, size_t l, boost::asio::ip::udp::endpoint &to)
void	close ()
void	set_reuse_address (bool)
void	connect (const boost::asio::ip::udp::endpoint &e)
const boost::asio::ip::udp::endpoint	local_endpoint () const

Detailed Description

The udp_socket class has reference semantics, all copies will refer to the same underlying socket.

Definition at line 17 of file udp_socket.hpp.

Constructor & Destructor Documentation

udp_socket() [1/2]

fc::udp_socket::udp_socket

(

)

Definition at line 16 of file udp_socket.cpp.

    : my(new impl())
  {
  }

udp_socket() [2/2]

fc::udp_socket::udp_socket

(

const udp_socket &

s

)

~udp_socket()

fc::udp_socket::~udp_socket

(

)

Definition at line 26 of file udp_socket.cpp.

  {
    try 
    {
      if(my->_sock)
        my->_sock->close(); //close boost socket to make any pending reads run their completion handler
    }
    catch (...) //avoid destructor throw and likely this is just happening because socket wasn't open.
    {
    }
  }

Member Function Documentation

close()

void fc::udp_socket::close

(

)

Definition at line 91 of file udp_socket.cpp.

  {
    my->_sock->close();
  }

Here is the caller graph for this function:

connect()

void fc::udp_socket::connect

(

const boost::asio::ip::udp::endpoint &

e

)

Definition at line 101 of file udp_socket.cpp.

  {
    my->_sock->connect(e);
  }

initialize()

void fc::udp_socket::initialize

(

boost::asio::io_service &

service

)

Definition at line 21 of file udp_socket.cpp.

  {
    my->_sock.reset(new boost::asio::ip::udp::socket(service));
  }

local_endpoint()

const boost::asio::ip::udp::endpoint fc::udp_socket::local_endpoint

(

)

const

Definition at line 96 of file udp_socket.cpp.

  {
    return my->_sock->local_endpoint();
  }

open()

void fc::udp_socket::open

(

)

Definition at line 85 of file udp_socket.cpp.

  {
    my->_sock->open(boost::asio::ip::udp::v4());
    my->_sock->non_blocking(true);
  }

Here is the caller graph for this function:

send_to() [1/2]

void fc::udp_socket::send_to	(	const char *	b,
		size_t	l,
		boost::asio::ip::udp::endpoint &	to )

Definition at line 38 of file udp_socket.cpp.

  {
    try 
    {
      my->_sock->send_to(boost::asio::buffer(buffer, length), to);
      return;
    } 
    catch(const boost::system::system_error& e)
    {
      if(e.code() == boost::asio::error::would_block)
      {
          auto send_buffer_ptr = std::make_shared<std::vector<char>>(buffer, buffer+length);
          my->_sock->async_send_to(boost::asio::buffer(send_buffer_ptr.get(), length), to,
                                   [send_buffer_ptr](const boost::system::error_code& /*ec*/, std::size_t /*bytes_transferred*/)
          {
            // Swallow errors.  Currently only used for GELF logging, so depend on local
            // log to catch anything that doesn't make it across the network.
          });
       }
       // All other exceptions ignored.
    }
  }

Here is the caller graph for this function:

send_to() [2/2]

void fc::udp_socket::send_to	(	const std::shared_ptr< const char > &	b,
		size_t	l,
		boost::asio::ip::udp::endpoint &	to )

Definition at line 61 of file udp_socket.cpp.

  {
    try
    {
      my->_sock->send_to(boost::asio::buffer(buffer.get(), length), to);
      return;
    } 
    catch(const boost::system::system_error& e)
    {
      if(e.code() == boost::asio::error::would_block)
      {
          auto preserved_buffer_ptr = buffer;
          my->_sock->async_send_to(boost::asio::buffer(preserved_buffer_ptr.get(), length), to,
                                   [preserved_buffer_ptr](const boost::system::error_code& /*ec*/, std::size_t /*bytes_transferred*/)
          {
            // Swallow errors.  Currently only used for GELF logging, so depend on local
            // log to catch anything that doesn't make it across the network.
          });
       }
       // All other exceptions ignored.
    }
  }

set_reuse_address()

void fc::udp_socket::set_reuse_address

(

bool

s

)

Definition at line 106 of file udp_socket.cpp.

  {
    my->_sock->set_option( boost::asio::ip::udp::socket::reuse_address(s) );
  }

---

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

• libraries/fc/include/fc/network/udp_socket.hpp
• libraries/fc/src/network/udp_socket.cpp