Starts a socket send operation, sending bytes to a remote endpoint. More...

#include <Async.h>

Inheritance diagram for SC::AsyncSocketSend:

Classes
struct	CompletionData
	Completion data for AsyncSocketSend. More...

Public Types
using	Result = AsyncResultOf< AsyncSocketSend, CompletionData >
	Callback result for AsyncSocketSend. More...

Public Types inherited from SC::AsyncRequest
enum class	Type : uint8_t { LoopTimeout , LoopWakeUp , LoopWork , ProcessExit , SocketAccept , SocketConnect , SocketSend , SocketReceive , SocketClose , FileRead , FileWrite , FileClose , FilePoll }
	Type of async request. More...

Public Member Functions
SC::Result	start (AsyncEventLoop &eventLoop, const SocketDescriptor &socketDescriptor, Span< const char > data)
	Starts a socket send operation. More...

Public Member Functions inherited from SC::AsyncRequest
void	setDebugName (const char *newDebugName)

AsyncEventLoop *	getEventLoop () const
	Get the event loop associated with this AsyncRequest. More...

	AsyncRequest (Type type)
	Constructs a free async request of given type. More...

Result	stop ()
	Stops the async operation. More...

Public Attributes
Function< void(Result &)>	callback
	Called when socket is ready to send more data. More...

Public Attributes inherited from SC::AsyncRequest
AsyncRequest *	next = nullptr

AsyncRequest *	prev = nullptr

Friends
struct	AsyncEventLoop

Additional Inherited Members
Protected Member Functions inherited from SC::AsyncRequest
Result	validateAsync ()

Result	queueSubmission (AsyncEventLoop &eventLoop)

Result	queueSubmission (AsyncEventLoop &eventLoop, ThreadPool &threadPool, AsyncTask &task)

Static Protected Member Functions inherited from SC::AsyncRequest
static void	updateTime (AsyncEventLoop &loop)

Protected Attributes inherited from SC::AsyncRequest
AsyncEventLoop *	eventLoop = nullptr

AsyncTask *	asyncTask = nullptr

Detailed Description

Starts a socket send operation, sending bytes to a remote endpoint.

Callback will be called when the given socket is ready to send more data.
Socket library can be used to create a Socket but the socket should be created with SC::SocketFlags::NonBlocking and associated to the event loop with SC::AsyncEventLoop::associateExternallyCreatedTCPSocket or though AsyncSocketAccept.
Alternatively SC::AsyncEventLoop::createAsyncTCPSocket creates and associates the socket to the loop.

// Assuming an already created (and running) AsyncEventLoop named `eventLoop`
// and a connected or accepted socket named `client`
// ...
const char sendBuffer[] = {123, 111};
 
// The memory pointed by the span must be valid until callback is called
Span<const char> sendData = {sendBuffer, sizeof(sendBuffer)};
 
AsyncSocketSend sendAsync;
sendAsync.callback = [&](AsyncSocketSend::Result& res)
{
    if(res.isValid())
    {
        // Now we could free the data pointed by span and queue new data
        console.printLine("Ready to send more data");
    }
};
 
SC_TRY(sendAsync.start(eventLoop, client, sendData));

Member Typedef Documentation

◆ Result

using SC::AsyncSocketSend::Result = AsyncResultOf<AsyncSocketSend, CompletionData>

Callback result for AsyncSocketSend.

Member Function Documentation

◆ start()

SC::Result SC::AsyncSocketSend::start	(	AsyncEventLoop &	eventLoop,
		const SocketDescriptor &	socketDescriptor,
		Span< const char >	data
	)

Starts a socket send operation.

Callback will be called when the given socket is ready to send more data.

Parameters

eventLoop	The event loop where queuing this async request
socketDescriptor	The socket to send data to
data	The data to be sent

Returns: Valid Result if the request has been successfully queued

Member Data Documentation

◆ callback

Function<void(Result&)> SC::AsyncSocketSend::callback

Called when socket is ready to send more data.

The documentation for this struct was generated from the following file:

Async.h

Classes

Public Types

Public Member Functions

Public Attributes

Friends