OpenSDN source code
Classes | Public Types | Public Member Functions | Static Public Attributes | Protected Member Functions | Private Member Functions | Private Attributes | Static Private Attributes | Friends | List of all members
UdpServer Class Reference

#include <udp_server.h>

Inheritance diagram for UdpServer:
Inheritance graph
[legend]
Collaboration diagram for UdpServer:
Collaboration graph
[legend]

Classes

class  Reader
 

Public Types

enum  ServerState { OK = 42 , Uninitialized , SocketOpenFailed , SocketBindFailed }
 
typedef boost::asio::ip::udp::endpoint Endpoint
 
typedef boost::asio::ip::udp::socket Socket
 

Public Member Functions

 UdpServer (EventManager *evm, int buffer_size=kDefaultBufferSize)
 
 UdpServer (boost::asio::io_context *io_service, int buffer_size=kDefaultBufferSize)
 
virtual ~UdpServer ()
 
virtual bool Initialize (unsigned short port)
 
virtual bool Initialize (const std::string &ipaddress, unsigned short port)
 
virtual bool Initialize (boost::asio::ip::udp::endpoint local_endpoint)
 
virtual void Shutdown ()
 
void StartSend (boost::asio::ip::udp::endpoint ep, std::size_t bytes_to_send, boost::asio::const_buffer buffer)
 
void StartReceive ()
 
ServerState GetServerState () const
 
boost::asio::ip::udp::endpoint GetLocalEndpoint (boost::system::error_code *error) const
 
std::string GetLocalEndpointAddress () const
 
int GetLocalEndpointPort () const
 
boost::asio::mutable_buffer AllocateBuffer ()
 
boost::asio::mutable_buffer AllocateBuffer (std::size_t s)
 
void DeallocateBuffer (const boost::asio::const_buffer &buffer)
 
const io::SocketStats & GetSocketStats () const
 
void GetRxSocketStats (SocketIOStats *socket_stats) const
 
void GetTxSocketStats (SocketIOStats *socket_stats) const
 

Static Public Attributes

static const int kDefaultBufferSize = 4 * 1024
 

Protected Member Functions

EventManager * event_manager ()
 
virtual bool DisableSandeshLogMessages ()
 
virtual std::string ToString ()
 
virtual void HandleReceive (const boost::asio::const_buffer &recv_buffer, boost::asio::ip::udp::endpoint remote_endpoint, std::size_t bytes_transferred, const boost::system::error_code &error)
 
virtual void OnRead (const boost::asio::const_buffer &recv_buffer, const boost::asio::ip::udp::endpoint &remote_endpoint)
 
virtual int reader_task_id () const
 
virtual int reader_task_instance (const boost::asio::ip::udp::endpoint &remote_endpoint) const
 
virtual void HandleSend (boost::asio::const_buffer send_buffer, boost::asio::ip::udp::endpoint remote_endpoint, std::size_t bytes_transferred, const boost::system::error_code &error)
 

Private Member Functions

void SetName (boost::asio::ip::udp::endpoint ep)
 
void HandleReceiveInternal (boost::asio::const_buffer recv_buffer, std::size_t bytes_transferred, const boost::system::error_code &error)
 
void HandleSendInternal (boost::asio::const_buffer send_buffer, boost::asio::ip::udp::endpoint remote_endpoint, std::size_t bytes_transferred, const boost::system::error_code &error)
 
 DISALLOW_COPY_AND_ASSIGN (UdpServer)
 

Private Attributes

boost::asio::ip::udp::socket socket_
 
int buffer_size_
 
ServerState state_
 
EventManager * evm_
 
std::string name_
 
boost::asio::ip::udp::endpoint remote_endpoint_
 
tbb::mutex state_guard_
 
tbb::mutex pbuf_guard_
 
std::vector< uint8_t * > pbuf_
 
tbb::atomic< int > refcount_
 
io::SocketStats stats_
 

Static Private Attributes

static int reader_task_id_ = -1
 

Friends

void intrusive_ptr_add_ref (UdpServer *server)
 
void intrusive_ptr_release (UdpServer *server)
 

Detailed Description

Definition at line 18 of file udp_server.h.

Member Typedef Documentation

◆ Endpoint

typedef boost::asio::ip::udp::endpoint UdpServer::Endpoint

Definition at line 20 of file udp_server.h.

◆ Socket

typedef boost::asio::ip::udp::socket UdpServer::Socket

Definition at line 21 of file udp_server.h.

Member Enumeration Documentation

◆ ServerState

enum UdpServer::ServerState
Enumerator
OK 
Uninitialized 
SocketOpenFailed 
SocketBindFailed 

Definition at line 23 of file udp_server.h.

Constructor & Destructor Documentation

◆ UdpServer() [1/2]

UdpServer::UdpServer ( EventManager *  evm,
int  buffer_size = kDefaultBufferSize 
)
explicit

Definition at line 62 of file udp_server.cc.

Here is the call graph for this function:

◆ UdpServer() [2/2]

UdpServer::UdpServer ( boost::asio::io_context *  io_service,
int  buffer_size = kDefaultBufferSize 
)
explicit

Definition at line 49 of file udp_server.cc.

Here is the call graph for this function:

◆ ~UdpServer()

UdpServer::~UdpServer ( )
virtual

Definition at line 86 of file udp_server.cc.

Member Function Documentation

◆ AllocateBuffer() [1/2]

mutable_buffer UdpServer::AllocateBuffer ( )

Definition at line 178 of file udp_server.cc.

◆ AllocateBuffer() [2/2]

mutable_buffer UdpServer::AllocateBuffer ( std::size_t  s)

Definition at line 169 of file udp_server.cc.

◆ DeallocateBuffer()

void UdpServer::DeallocateBuffer ( const boost::asio::const_buffer &  buffer)

Definition at line 182 of file udp_server.cc.

◆ DisableSandeshLogMessages()

virtual bool UdpServer::DisableSandeshLogMessages ( )
inlineprotectedvirtual

Definition at line 68 of file udp_server.h.

◆ DISALLOW_COPY_AND_ASSIGN()

UdpServer::DISALLOW_COPY_AND_ASSIGN ( UdpServer  )
private

◆ event_manager()

EventManager* UdpServer::event_manager ( )
inlineprotected

Definition at line 67 of file udp_server.h.

◆ GetLocalEndpoint()

udp::endpoint UdpServer::GetLocalEndpoint ( boost::system::error_code *  error) const

Definition at line 300 of file udp_server.cc.

◆ GetLocalEndpointAddress()

std::string UdpServer::GetLocalEndpointAddress ( ) const

Definition at line 305 of file udp_server.cc.

Here is the call graph for this function:

◆ GetLocalEndpointPort()

int UdpServer::GetLocalEndpointPort ( ) const

Definition at line 313 of file udp_server.cc.

Here is the call graph for this function:

◆ GetRxSocketStats()

void UdpServer::GetRxSocketStats ( SocketIOStats *  socket_stats) const

Definition at line 321 of file udp_server.cc.

Here is the call graph for this function:

◆ GetServerState()

ServerState UdpServer::GetServerState ( ) const
inline

Definition at line 48 of file udp_server.h.

◆ GetSocketStats()

const io::SocketStats& UdpServer::GetSocketStats ( ) const
inline

Definition at line 62 of file udp_server.h.

◆ GetTxSocketStats()

void UdpServer::GetTxSocketStats ( SocketIOStats *  socket_stats) const

Definition at line 325 of file udp_server.cc.

Here is the call graph for this function:

◆ HandleReceive()

void UdpServer::HandleReceive ( const boost::asio::const_buffer &  recv_buffer,
boost::asio::ip::udp::endpoint  remote_endpoint,
std::size_t  bytes_transferred,
const boost::system::error_code &  error 
)
protectedvirtual

Reimplemented in BFD::UDPConnectionManager::UDPRecvServer.

Definition at line 276 of file udp_server.cc.

Here is the call graph for this function:

◆ HandleReceiveInternal()

void UdpServer::HandleReceiveInternal ( boost::asio::const_buffer  recv_buffer,
std::size_t  bytes_transferred,
const boost::system::error_code &  error 
)
private

Definition at line 251 of file udp_server.cc.

Here is the call graph for this function:

◆ HandleSend()

void UdpServer::HandleSend ( boost::asio::const_buffer  send_buffer,
boost::asio::ip::udp::endpoint  remote_endpoint,
std::size_t  bytes_transferred,
const boost::system::error_code &  error 
)
protectedvirtual

Definition at line 294 of file udp_server.cc.

Here is the call graph for this function:

◆ HandleSendInternal()

void UdpServer::HandleSendInternal ( boost::asio::const_buffer  send_buffer,
boost::asio::ip::udp::endpoint  remote_endpoint,
std::size_t  bytes_transferred,
const boost::system::error_code &  error 
)
private

Definition at line 210 of file udp_server.cc.

Here is the call graph for this function:

◆ Initialize() [1/3]

virtual bool UdpServer::Initialize ( boost::asio::ip::udp::endpoint  local_endpoint)
virtual

◆ Initialize() [2/3]

bool UdpServer::Initialize ( const std::string &  ipaddress,
unsigned short  port 
)
virtual

Definition at line 123 of file udp_server.cc.

Here is the call graph for this function:

◆ Initialize() [3/3]

bool UdpServer::Initialize ( unsigned short  port)
virtual

Definition at line 136 of file udp_server.cc.

◆ OnRead()

void UdpServer::OnRead ( const boost::asio::const_buffer &  recv_buffer,
const boost::asio::ip::udp::endpoint &  remote_endpoint 
)
protectedvirtual

Definition at line 288 of file udp_server.cc.

◆ reader_task_id()

virtual int UdpServer::reader_task_id ( ) const
inlineprotectedvirtual

Definition at line 81 of file udp_server.h.

◆ reader_task_instance()

int UdpServer::reader_task_instance ( const boost::asio::ip::udp::endpoint &  remote_endpoint) const
protectedvirtual

Definition at line 75 of file udp_server.cc.

◆ SetName()

void UdpServer::SetName ( boost::asio::ip::udp::endpoint  ep)
private

Definition at line 79 of file udp_server.cc.

◆ Shutdown()

void UdpServer::Shutdown ( void  )
virtual

Definition at line 98 of file udp_server.cc.

◆ StartReceive()

void UdpServer::StartReceive ( )

Definition at line 235 of file udp_server.cc.

Here is the call graph for this function:

◆ StartSend()

void UdpServer::StartSend ( boost::asio::ip::udp::endpoint  ep,
std::size_t  bytes_to_send,
boost::asio::const_buffer  buffer 
)

Definition at line 194 of file udp_server.cc.

Here is the call graph for this function:

◆ ToString()

virtual std::string UdpServer::ToString ( )
inlineprotectedvirtual

Definition at line 69 of file udp_server.h.

Friends And Related Function Documentation

◆ intrusive_ptr_add_ref

void intrusive_ptr_add_ref ( UdpServer *  server)
friend

Definition at line 138 of file udp_server.h.

◆ intrusive_ptr_release

void intrusive_ptr_release ( UdpServer *  server)
friend

Definition at line 142 of file udp_server.h.

Member Data Documentation

◆ buffer_size_

int UdpServer::buffer_size_
private

Definition at line 122 of file udp_server.h.

◆ evm_

EventManager* UdpServer::evm_
private

Definition at line 124 of file udp_server.h.

◆ kDefaultBufferSize

const int UdpServer::kDefaultBufferSize = 4 * 1024
static

Definition at line 29 of file udp_server.h.

◆ name_

std::string UdpServer::name_
private

Definition at line 125 of file udp_server.h.

◆ pbuf_

std::vector<uint8_t *> UdpServer::pbuf_
private

Definition at line 129 of file udp_server.h.

◆ pbuf_guard_

tbb::mutex UdpServer::pbuf_guard_
private

Definition at line 128 of file udp_server.h.

◆ reader_task_id_

int UdpServer::reader_task_id_ = -1
staticprivate

Definition at line 120 of file udp_server.h.

◆ refcount_

tbb::atomic<int> UdpServer::refcount_
private

Definition at line 130 of file udp_server.h.

◆ remote_endpoint_

boost::asio::ip::udp::endpoint UdpServer::remote_endpoint_
private

Definition at line 126 of file udp_server.h.

◆ socket_

boost::asio::ip::udp::socket UdpServer::socket_
private

Definition at line 121 of file udp_server.h.

◆ state_

ServerState UdpServer::state_
private

Definition at line 123 of file udp_server.h.

◆ state_guard_

tbb::mutex UdpServer::state_guard_
private

Definition at line 127 of file udp_server.h.

◆ stats_

io::SocketStats UdpServer::stats_
private

Definition at line 131 of file udp_server.h.

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