#include <Pt/Net/UdpSocket.h>

UDP server and client socket.

Public Member Functions
	UdpSocket ()
	Default constructor.

	UdpSocket (System::EventLoop &loop)
	Construct with event loop.

	~UdpSocket ()
	Destructor.

void	bind (const Endpoint &ep)
	Bind to local endpoint. More...

void	bind (const Endpoint &ep, const UdpSocketOptions &o)
	Bind to local endpoint. More...

bool	beginBind (const Endpoint &ep)
	Begin bind to local endpoint. More...

bool	beginBind (const Endpoint &ep, const UdpSocketOptions &o)
	Begin bind to local endpoint. More...

void	endBind ()
	end bind to local endpoint. More...

Signal< UdpSocket & > &	bound ()
	Notifies that the socket was bound. More...

bool	isBound () const
	Returns true if bound.

void	connect (const Endpoint &ep)
	Connect to an endpoint. More...

void	connect (const Endpoint &ep, const UdpSocketOptions &o)
	Connect to an endpoint. More...

void	setTarget (const Endpoint &ep)
	Set target endpoint. More...

void	setTarget (const Endpoint &ep, const UdpSocketOptions &o)
	Set target endpoint. More...

bool	beginConnect (const Endpoint &ep)
	Begin connect to an endpoint. More...

bool	beginConnect (const Endpoint &ep, const UdpSocketOptions &o)
	Begin connect to an endpoint. More...

void	endConnect ()
	End connect to an endpoint. More...

Signal< UdpSocket & > &	connected ()
	Notifies that the socket was connected. More...

bool	isConnected () const
	Returns true if connected.

void	joinMulticastGroup (const std::string &ipaddr)
	Joins a multicast group.

void	localEndpoint (Endpoint &ep) const
	Gets the local endpoint.

const Endpoint &	remoteEndpoint () const
	Gets the remote endpoint.

void	close ()
	Closes the device.

void	setTimeout (std::size_t timeout)
	Sets the timeout for blocking I/O in milliseconds.

void	beginRead (char *buffer, std::size_t n)
	Begins to read data.

std::size_t	endRead ()
	Ends reading data.

std::size_t	read (char *buffer, std::size_t n)
	Read data from I/O device. More...

void	beginWrite (const char *buffer, std::size_t n)
	Begins to write data.

std::size_t	endWrite ()
	Ends writing data.

std::size_t	write (const char *buffer, std::size_t n)
	Write data to I/O device. More...

bool	seekable () const
	Returns true if device is seekable.

pos_type	seek (off_type offset, seekdir sd)
	Moves the read position to the given offset. More...

std::size_t	peek (char *buffer, std::size_t n)
	Peek data from I/O device without consuming them. More...

void	sync ()
	Synchronize device. More...

pos_type	position ()
	Returns the current I/O position. More...

bool	isEof () const
	Returns if the device has reached EOF.

Signal< IODevice & > &	inputReady ()
	Notifies about available data. More...

Signal< IODevice & > &	outputReady ()
	Notifies when data can be written. More...

bool	isReading () const
	Returns true if the device is reading.

bool	isWriting () const
	Returns true if the device is writing.

EventLoop *	loop () const
	Returns the used event loop.

void	setActive (EventLoop &parent)
	Sets the parent loop, so that operations can be run.

void	detach ()
	Remove from event loop and cancels outstanding operations.

void	cancel ()
	Cancels all operations.

bool	run ()
	Run operation if it is ready.

EventLoop *	parent () const
	Returns the used event loop.

Protected Member Functions
virtual bool	onRun ()
	Check if ready and run.

virtual void	onCancel ()
	Blocks until operation has cancelled.

virtual void	onAttach (EventLoop &loop)
	Attached to loop.

virtual void	onDetach (EventLoop &loop)
	Detached from loop.

void	post ()
	Posts this selectable to its event loop from any thread.

Member Function Documentation

◆ bind() [1/2]

void bind ( const Endpoint & ep )

Exceptions

System::AccessFailed if the host is not reachable

◆ bind() [2/2]

void bind	(	const Endpoint &	ep,
		const UdpSocketOptions &	o
	)

Exceptions

System::AccessFailed if the host is not reachable

◆ beginBind() [1/2]

bool beginBind ( const Endpoint & ep )

Begins binding to the Endpoint ep. The UdpSocket must be attached to a event loop with setActive(). Once the binding has completed, the signal bound() will be sent. In response, the method endBind() has to be called to finish the bind operation.

Exceptions

System::AccessFailed if the host is not reachable

◆ beginBind() [2/2]

bool beginBind	(	const Endpoint &	ep,
		const UdpSocketOptions &	o
	)

Exceptions

System::AccessFailed if the host is not reachable

◆ endBind()

void endBind ( )

Exceptions

System::AccessFailed if the host is not reachable

◆ bound()

Signal<UdpSocket&>& bound ( )

This signal is send when the UdpSocket is monitored in an EventLoop and was bound to a local endpoint.

◆ connect() [1/2]

void connect ( const Endpoint & ep )

Exceptions

System::AccessFailed if the host is not reachable

◆ connect() [2/2]

void connect	(	const Endpoint &	ep,
		const UdpSocketOptions &	o
	)

Exceptions

System::AccessFailed if the host is not reachable

◆ setTarget() [1/2]

void setTarget ( const Endpoint & ep )

Exceptions

System::AccessFailed if the host is not reachable

◆ setTarget() [2/2]

void setTarget	(	const Endpoint &	ep,
		const UdpSocketOptions &	o
	)

Exceptions

System::AccessFailed if the host is not reachable

◆ beginConnect() [1/2]

bool beginConnect ( const Endpoint & ep )

Exceptions

System::AccessFailed if the host is not reachable

◆ beginConnect() [2/2]

bool beginConnect	(	const Endpoint &	ep,
		const UdpSocketOptions &	o
	)

Exceptions

System::AccessFailed if the host is not reachable

◆ endConnect()

void endConnect ( )

Exceptions

System::AccessFailed if the host is not reachable

◆ connected()

Signal<UdpSocket&>& connected ( )

This signal is send when the UdpSocket is monitored in an EventLoop and a connection was established.

◆ read()

std::size_t read	(	char *	buffer,
		std::size_t	n
	)

inherited

Reads up to n bytes and stores them in buffer. Returns the number of bytes read, which may be less than requested and even 0 if the device operates in asynchronous (non-blocking) mode. In case of EOF the IODevice is set to eof.

Parameters

buffer	buffer where to place the data to be read.
n	number of bytes to read

Returns: number of bytes read, which may be less than requested.

Exceptions

IOError

◆ write()

std::size_t write	(	const char *	buffer,
		std::size_t	n
	)

inherited

Writes n bytes from buffer to this I/O device. Returns the number of bytes written, which may be less than requested. In case of EOF the IODevice is set to eof.

Exceptions

IOError

◆ seek()

pos_type seek	(	off_type	offset,
		seekdir	sd
	)

inherited

Exceptions

IOError

◆ peek()

std::size_t peek	(	char *	buffer,
		std::size_t	n
	)

inherited

Exceptions

IOError

◆ sync()

void sync ( )

inherited

Commits written data to physical device.

Exceptions

IOError

◆ position()

pos_type position ( )

inherited

The current I/O position is returned or an IOError is thrown if the device is not seekable. Seekability can be tested with seekable().

Exceptions

IOError

◆ inputReady()

Signal<IODevice&>& inputReady ( )

inherited

This signal is send when the IODevice is monitored in an EventLoop and data becomes available.

◆ outputReady()

Signal<IODevice&>& outputReady ( )

inherited

This signal is send when the IODevice is monitored in an EventLoop and the device is ready to write data.

The Power in your Hands

Public Member Functions

Protected Member Functions

Member Function Documentation

◆ bind() [1/2]

◆ bind() [2/2]

◆ beginBind() [1/2]

◆ beginBind() [2/2]

◆ endBind()

◆ bound()

◆ connect() [1/2]

◆ connect() [2/2]

◆ setTarget() [1/2]

◆ setTarget() [2/2]

◆ beginConnect() [1/2]

◆ beginConnect() [2/2]

◆ endConnect()

◆ connected()

◆ read()

◆ write()

◆ seek()

◆ peek()

◆ sync()

◆ position()

◆ inputReady()

◆ outputReady()