Message Class Reference

#include <message.hpp>

Collaboration diagram for Message:

Public Types
using	CompletionCallback = std::function<void(CompletionStatus)>

Public Member Functions
	Message ()=default
void	async_readMsg (asio::ip::tcp::socket &socket, CompletionCallback onComplete)
void	async_sendMsg (asio::ip::tcp::socket &socket, CompletionCallback onComplete)
void	clear ()
bool	empty () const
size_t	getSize () const
std::string_view	getStr () const
bool	isSendingNow () const
void	setStr (std::string_view msg)

Private Member Functions
void	async_readBody (asio::ip::tcp::socket &socket, CompletionCallback onComplete, const std::error_code &ec, size_t readLen)
void	async_readBodyComplete (CompletionCallback onComplete, const std::error_code &ec, size_t readLen)
void	async_sendComplete (CompletionCallback onComplete, const std::error_code &ec, size_t sentLen)

Private Attributes
char	data [headerSize+bodySize]
bool	sendingNow = false
size_t	size = 0

Static Private Attributes
static constexpr size_t	bodySize = 2048
static constexpr size_t	headerSize = 5

Detailed Description

Definition at line 45 of file message.hpp.

Member Typedef Documentation

CompletionCallback

using Message::CompletionCallback = std::function<void(CompletionStatus)>

Definition at line 47 of file message.hpp.

Constructor & Destructor Documentation

Message()

Message::Message ( )

default

Member Function Documentation

async_readBody()

void Message::async_readBody ( asio::ip::tcp::socket & socket, CompletionCallback onComplete, const std::error_code & ec, size_t readLen )

private

Definition at line 78 of file message.cpp.

{
        if(ec){
                std::cerr << "Msg error " << ec.message() << "\n";
                onComplete(ec == asio::error::eof ?
                                CompletionStatus::UnexpectedDisconnect : CompletionStatus::Error);
                return;
        }
 
        assert(readLen == headerSize);
        size_t expectedSize = 0;
 
        auto res = std::from_chars(data, data + headerSize, expectedSize);
        if(res.ec != std::errc()){
                onComplete(CompletionStatus::Error);
                return;
        }
 
        using namespace std::placeholders;
        asio::async_read(socket,
                        asio::buffer(data + headerSize, expectedSize),
                        std::bind(&Message::async_readBodyComplete,
                                this, onComplete, _1, _2));
 
}

References async_readBodyComplete(), data, Error, headerSize, and UnexpectedDisconnect.

Referenced by async_readMsg().

Here is the call graph for this function:

async_readBodyComplete()

void Message::async_readBodyComplete ( CompletionCallback onComplete, const std::error_code & ec, size_t readLen )

private

Definition at line 106 of file message.cpp.

{
        if(ec){
                std::cerr << "Msg error: " << ec.message() << "\n";
                onComplete(ec == asio::error::eof ?
                                CompletionStatus::UnexpectedDisconnect : CompletionStatus::Error);
                return;
        }
 
        size = readLen;
 
        onComplete(CompletionStatus::Success);
}

References Error, size, Success, and UnexpectedDisconnect.

Referenced by async_readBody().

async_readMsg()

void Message::async_readMsg	(	asio::ip::tcp::socket &	socket,
		CompletionCallback	onComplete )

Definition at line 47 of file message.cpp.

{
        using namespace std::placeholders;
        asio::async_read(socket,
                        asio::buffer(data, headerSize),
                        std::bind(&Message::async_readBody,
                                this, std::ref(socket), onComplete, _1, _2));
}

References async_readBody(), data, and headerSize.

Referenced by Client::readCandidate(), Client::readDescription(), Client::readNameComplete(), and Client::readRoomComplete().

Here is the call graph for this function:

async_sendComplete()

void Message::async_sendComplete ( CompletionCallback onComplete, const std::error_code & ec, size_t sentLen )

private

Definition at line 121 of file message.cpp.

{
        sendingNow = false;
        onComplete(!ec ? CompletionStatus::Success : CompletionStatus::Error);
}

References Error, sendingNow, and Success.

Referenced by async_sendMsg().

async_sendMsg()

void Message::async_sendMsg	(	asio::ip::tcp::socket &	socket,
		CompletionCallback	onComplete )

Definition at line 67 of file message.cpp.

{
        using namespace std::placeholders;
        sendingNow = true;
        asio::async_write(socket,
                        asio::buffer(data, headerSize + size),
                        std::bind(&Message::async_sendComplete,
                                this, onComplete, _1, _2));
}

References async_sendComplete(), data, headerSize, sendingNow, and size.

Referenced by Client::onMsgSent(), and Client::sendMsg().

Here is the call graph for this function:

clear()

void Message::clear

(

)

empty()

bool Message::empty ( ) const

inline

Definition at line 60 of file message.hpp.

{ return size == 0; }

References size.

getSize()

size_t Message::getSize ( ) const

inline

Definition at line 59 of file message.hpp.

{ return size; }

References size.

getStr()

std::string_view Message::getStr

(

)

const

Definition at line 43 of file message.cpp.

                                    {
        return std::string_view(data + headerSize, size);
}

References data, headerSize, and size.

Referenced by Client::readCandidateComplete(), Client::readDescComplete(), Client::readNameComplete(), and Client::readRoomComplete().

isSendingNow()

bool Message::isSendingNow ( ) const

inline

Definition at line 61 of file message.hpp.

{ return sendingNow; }

References sendingNow.

Referenced by Client::isSendCallbackPending().

setStr()

void Message::setStr

(

std::string_view

msg

)

Definition at line 57 of file message.cpp.

                                      {
        assert(!sendingNow);
        size = std::min(bodySize, msg.size());
 
        memset(data, ' ', headerSize);
        std::to_chars(data, data + headerSize, size);
 
        memcpy(data + headerSize, msg.data(), size);
}

References bodySize, data, headerSize, sendingNow, and size.

Referenced by Client::onMsgSent(), and Client::sendMsg().

Member Data Documentation

bodySize

size_t Message::bodySize = 2048

staticconstexprprivate

Definition at line 80 of file message.hpp.

Referenced by setStr().

data

char Message::data[headerSize+bodySize]

private

Definition at line 81 of file message.hpp.

Referenced by async_readBody(), async_readMsg(), async_sendMsg(), getStr(), and setStr().

headerSize

size_t Message::headerSize = 5

staticconstexprprivate

Definition at line 79 of file message.hpp.

Referenced by async_readBody(), async_readMsg(), async_sendMsg(), getStr(), and setStr().

sendingNow

bool Message::sendingNow = false

private

Definition at line 77 of file message.hpp.

Referenced by async_sendComplete(), async_sendMsg(), isSendingNow(), and setStr().

size

size_t Message::size = 0

private

Definition at line 75 of file message.hpp.

Referenced by async_readBodyComplete(), async_sendMsg(), empty(), getSize(), getStr(), and setStr().

---

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

• nat-helper/message.hpp
• nat-helper/message.cpp