#include <SubProtocol.h>

Inheritance diagram for iot::mqtt::SubProtocol< WSSubProtocolRoleT >:

Collaboration diagram for iot::mqtt::SubProtocol< WSSubProtocolRoleT >:

Public Member Functions
	SubProtocol (web::websocket::SubProtocolContext subProtocolContext, const std::string &name, iot::mqtt::Mqtt mqtt)
	~SubProtocol () override=default
std::size_t	recv (char *chunk, std::size_t chunklen) override
void	send (const char *chunk, std::size_t chunklen) override
void	end () override
void	close () override

Private Types
using	WSSubProtocolRole = WSSubProtocolRoleT

Private Member Functions
void	onConnected () override
void	onMessageStart (int opCode) override
void	onMessageData (const char *chunk, std::size_t chunkLen) override
void	onMessageEnd () override
void	onMessageError (uint16_t errnum) override
void	onDisconnected () override
bool	onSignal (int sig) override
core::socket::stream::SocketConnection *	getSocketConnection () const override
Private Member Functions inherited from iot::mqtt::MqttContext
	MqttContext (Mqtt *mqtt)
	MqttContext (const MqttContext &)=default
MqttContext &	operator= (const MqttContext &)=default
virtual	~MqttContext ()
void	onConnected ()
std::size_t	onReceivedFromPeer ()
void	onDisconnected ()
bool	onSignal (int sig)

Private Attributes
OnReceivedFromPeerEvent	onReceivedFromPeerEvent
std::string	data
std::vector< char >	buffer
std::size_t	cursor = 0
std::size_t	size = 0
Private Attributes inherited from iot::mqtt::MqttContext
Mqtt *	mqtt

Detailed Description

template<typename WSSubProtocolRoleT>
class iot::mqtt::SubProtocol< WSSubProtocolRoleT >

Definition at line 83 of file SubProtocol.h.

Member Typedef Documentation

◆ WSSubProtocolRole

template<typename WSSubProtocolRoleT>

using iot::mqtt::SubProtocol< WSSubProtocolRoleT >::WSSubProtocolRole = WSSubProtocolRoleT

private

Definition at line 87 of file SubProtocol.h.

Constructor & Destructor Documentation

◆ SubProtocol()

template<typename WSSubProtocolRole>

iot::mqtt::SubProtocol< WSSubProtocolRole >::SubProtocol	(	web::websocket::SubProtocolContext *	subProtocolContext,
		const std::string &	name,
		iot::mqtt::Mqtt *	mqtt )

Definition at line 59 of file SubProtocol.hpp.

        : WSSubProtocolRole(subProtocolContext, name, 0)
        , iot::mqtt::MqttContext(mqtt)
        , onReceivedFromPeerEvent([this]([[maybe_unused]] const utils::Timeval& currentTime) {
            iot::mqtt::MqttContext::onReceivedFromPeer();
 
            if (size > 0) {
                onReceivedFromPeerEvent.span();
            } else {
                buffer.clear();
                cursor = 0;
            }
        }) {
    }

References buffer, cursor, iot::mqtt::MqttContext::onReceivedFromPeer(), onReceivedFromPeerEvent, size, and core::EventReceiver::span().

Here is the call graph for this function:

◆ ~SubProtocol()

template<typename WSSubProtocolRoleT>

iot::mqtt::SubProtocol< WSSubProtocolRoleT >::~SubProtocol ( )

overridedefault

Member Function Documentation

◆ close()

template<typename WSSubProtocolRole>

void iot::mqtt::SubProtocol< WSSubProtocolRole >::close ( )

overridevirtual

Implements iot::mqtt::MqttContext.

Definition at line 99 of file SubProtocol.hpp.

                                               {
        const std::string reason = "Protocol error";
 
        WSSubProtocolRole::sendClose(1002, reason.data(), reason.length());
    }

Referenced by onMessageStart().

Here is the caller graph for this function:

◆ end()

template<typename WSSubProtocolRole>

void iot::mqtt::SubProtocol< WSSubProtocolRole >::end ( )

overridevirtual

Implements iot::mqtt::MqttContext.

Definition at line 94 of file SubProtocol.hpp.

                                             {
        WSSubProtocolRole::sendClose();
    }

◆ getSocketConnection()

template<typename WSSubProtocolRole>

core::socket::stream::SocketConnection * iot::mqtt::SubProtocol< WSSubProtocolRole >::getSocketConnection ( ) const

overrideprivatevirtual

Implements iot::mqtt::MqttContext.

Definition at line 168 of file SubProtocol.hpp.

                                                                                                {
        return WSSubProtocolRole::subProtocolContext->getSocketConnection();
    }

Referenced by onConnected(), onDisconnected(), onMessageData(), onMessageEnd(), onMessageError(), onMessageStart(), and onSignal().

Here is the caller graph for this function:

◆ onConnected()

template<typename WSSubProtocolRole>

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onConnected ( )

overrideprivate

Definition at line 106 of file SubProtocol.hpp.

                                                     {
        LOG(INFO) << getSocketConnection()->getConnectionName() << " WsMqtt: connected:";
        iot::mqtt::MqttContext::onConnected();
    }

References getSocketConnection(), and iot::mqtt::MqttContext::onConnected().

Here is the call graph for this function:

◆ onDisconnected()

template<typename WSSubProtocolRole>

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onDisconnected ( )

overrideprivate

Definition at line 151 of file SubProtocol.hpp.

                                                        {
        iot::mqtt::MqttContext::onDisconnected();
        LOG(DEBUG) << getSocketConnection()->getConnectionName() << " WsMqtt: disconnected";
    }

References getSocketConnection(), and iot::mqtt::MqttContext::onDisconnected().

Here is the call graph for this function:

◆ onMessageData()

template<typename WSSubProtocolRole>

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onMessageData	(	const char *	chunk,
		std::size_t	chunkLen )

overrideprivate

Definition at line 122 of file SubProtocol.hpp.

                                                                                            {
        data.append(std::string(chunk, chunkLen));
 
        LOG(DEBUG) << getSocketConnection()->getConnectionName() << " WsMqtt: Frame Data:\n"
                   << std::string(32, ' ').append(utils::hexDump(std::vector<char>(chunk, chunk + chunkLen), 32));
    }

References data, getSocketConnection(), and utils::hexDump().

Here is the call graph for this function:

◆ onMessageEnd()

template<typename WSSubProtocolRole>

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onMessageEnd ( )

overrideprivate

Definition at line 130 of file SubProtocol.hpp.

                                                      {
        LOG(DEBUG) << getSocketConnection()->getConnectionName() << " WsMqtt: Message END";
 
        buffer.insert(buffer.end(), data.begin(), data.end());
        size += data.size();
        data.clear();
 
        if (size > 0) {
            onReceivedFromPeerEvent.span();
        } else {
            buffer.clear();
            cursor = 0;
        }
    }

References buffer, cursor, data, getSocketConnection(), onReceivedFromPeerEvent, size, and core::EventReceiver::span().

Here is the call graph for this function:

◆ onMessageError()

template<typename WSSubProtocolRole>

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onMessageError ( uint16_t errnum )

overrideprivate

Definition at line 146 of file SubProtocol.hpp.

                                                                       {
        LOG(ERROR) << getSocketConnection()->getConnectionName() << " WsMqtt: Message error: " << errnum;
    }

References getSocketConnection().

Here is the call graph for this function:

◆ onMessageStart()

template<typename WSSubProtocolRole>

void iot::mqtt::SubProtocol< WSSubProtocolRole >::onMessageStart ( int opCode )

overrideprivate

Definition at line 112 of file SubProtocol.hpp.

                                                                  {
        if (opCode == web::websocket::SubProtocolContext::OpCode::TEXT) {
            LOG(ERROR) << getSocketConnection()->getConnectionName() << " WsMqtt: Wrong Opcode: " << opCode << " (TEXT)";
            this->close();
        } else {
            LOG(DEBUG) << getSocketConnection()->getConnectionName() << " WsMqtt: Message START: " << opCode << " (BIN)";
        }
    }

References close(), getSocketConnection(), and web::websocket::SubProtocolContext::TEXT.

Here is the call graph for this function:

◆ onSignal()

template<typename WSSubProtocolRole>

bool iot::mqtt::SubProtocol< WSSubProtocolRole >::onSignal ( int sig )

overrideprivate

Definition at line 157 of file SubProtocol.hpp.

                                                         {
        bool ret = iot::mqtt::MqttContext::onSignal(sig);
        LOG(INFO) << getSocketConnection()->getConnectionName() << " WsMqtt: exit due to '" << strsignal(sig) << "' (SIG"
                  << utils::system::sigabbrev_np(sig) << " = " << sig << ")";
 
        this->sendClose();
 
        return ret;
    }

References getSocketConnection(), iot::mqtt::MqttContext::onSignal(), and utils::system::sigabbrev_np().

Here is the call graph for this function:

◆ recv()

template<typename WSSubProtocolRole>

std::size_t iot::mqtt::SubProtocol< WSSubProtocolRole >::recv	(	char *	chunk,
		std::size_t	chunklen )

overridevirtual

Implements iot::mqtt::MqttContext.

Definition at line 77 of file SubProtocol.hpp.

                                                                                  {
        std::size_t maxReturn = std::min(chunklen, size);
 
        std::copy(buffer.data() + cursor, buffer.data() + cursor + maxReturn, chunk);
 
        cursor += maxReturn;
        size -= maxReturn;
 
        return maxReturn;
    }

References buffer, cursor, and size.

◆ send()

template<typename WSSubProtocolRole>

void iot::mqtt::SubProtocol< WSSubProtocolRole >::send	(	const char *	chunk,
		std::size_t	chunklen )

overridevirtual

Implements iot::mqtt::MqttContext.

Definition at line 89 of file SubProtocol.hpp.

                                                                                   {
        WSSubProtocolRole::sendMessage(chunk, chunklen);
    }

Member Data Documentation

◆ buffer

template<typename WSSubProtocolRoleT>

std::vector<char> iot::mqtt::SubProtocol< WSSubProtocolRoleT >::buffer

private

Definition at line 113 of file SubProtocol.h.

Referenced by onMessageEnd(), recv(), and SubProtocol().

◆ cursor

template<typename WSSubProtocolRoleT>

std::size_t iot::mqtt::SubProtocol< WSSubProtocolRoleT >::cursor = 0

private

Definition at line 114 of file SubProtocol.h.

Referenced by onMessageEnd(), recv(), and SubProtocol().

◆ data

template<typename WSSubProtocolRoleT>

std::string iot::mqtt::SubProtocol< WSSubProtocolRoleT >::data

private

Definition at line 112 of file SubProtocol.h.

Referenced by onMessageData(), and onMessageEnd().

◆ onReceivedFromPeerEvent

template<typename WSSubProtocolRoleT>

OnReceivedFromPeerEvent iot::mqtt::SubProtocol< WSSubProtocolRoleT >::onReceivedFromPeerEvent

private

Definition at line 110 of file SubProtocol.h.

Referenced by onMessageEnd(), and SubProtocol().

◆ size

template<typename WSSubProtocolRoleT>

std::size_t iot::mqtt::SubProtocol< WSSubProtocolRoleT >::size = 0

private

Definition at line 115 of file SubProtocol.h.

Referenced by onMessageEnd(), recv(), and SubProtocol().

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

iot/mqtt/SubProtocol.h
iot/mqtt/SubProtocol.hpp

SNode.C

Public Member Functions

Private Types

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ WSSubProtocolRole

Constructor & Destructor Documentation

◆ SubProtocol()

◆ ~SubProtocol()

Member Function Documentation

◆ close()

◆ end()

◆ getSocketConnection()

◆ onConnected()

◆ onDisconnected()

◆ onMessageData()

◆ onMessageEnd()

◆ onMessageError()

◆ onMessageStart()

◆ onSignal()

◆ recv()

◆ send()

Member Data Documentation

◆ buffer

◆ cursor

◆ data

◆ onReceivedFromPeerEvent

◆ size