_packetIdentifier | iot::mqtt_fast::SocketContext | private |
alreadyTotalProcessed | core::socket::stream::SocketContext | private |
alreadyTotalQueued | core::socket::stream::SocketContext | private |
attach() | core::socket::stream::SocketContext | privatevirtual |
close() override | core::socket::stream::SocketContext | virtual |
controlPacketFactory | iot::mqtt_fast::SocketContext | private |
detach() | core::socket::stream::SocketContext | privatevirtual |
durationToString(const std::chrono::time_point< std::chrono::system_clock > &bevore, const std::chrono::time_point< std::chrono::system_clock > &later=std::chrono::system_clock::now()) | core::socket::stream::SocketContext | privatestatic |
getOnlineDuration() const override | core::socket::stream::SocketContext | virtual |
getOnlineSince() const override | core::socket::stream::SocketContext | virtual |
getPacketIdentifier() | iot::mqtt_fast::SocketContext | inlineprivate |
getSocketConnection() const | core::socket::stream::SocketContext | |
getTotalProcessed() const override | core::socket::stream::SocketContext | virtual |
getTotalQueued() const override | core::socket::stream::SocketContext | virtual |
getTotalRead() const override | core::socket::stream::SocketContext | virtual |
getTotalSent() const override | core::socket::stream::SocketContext | virtual |
newSocketContext | core::socket::stream::SocketContext | private |
onConnack(const iot::mqtt_fast::packets::Connack &connack)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onConnect(const iot::mqtt_fast::packets::Connect &connect)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onConnected()=0 | core::socket::stream::SocketContext | privatepure virtual |
onDisconnect(const iot::mqtt_fast::packets::Disconnect &disconnect)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onDisconnected()=0 | core::socket::stream::SocketContext | privatepure virtual |
onlineSince | core::socket::stream::SocketContext | private |
onlineSinceTimePoint | core::socket::stream::SocketContext | private |
onPingreq(const iot::mqtt_fast::packets::Pingreq &pingreq)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onPingresp(const iot::mqtt_fast::packets::Pingresp &pingresp)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onPuback(const iot::mqtt_fast::packets::Puback &puback)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onPubcomp(const iot::mqtt_fast::packets::Pubcomp &pubcomp)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onPublish(const iot::mqtt_fast::packets::Publish &publish)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onPubrec(const iot::mqtt_fast::packets::Pubrec &pubrec)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onPubrel(const iot::mqtt_fast::packets::Pubrel &pubrel)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onReadError(int errnum) override | core::socket::stream::SocketContext | protectedvirtual |
onReceivedFromPeer() final | iot::mqtt_fast::SocketContext | privatevirtual |
onSignal(int sig)=0 | core::socket::SocketContext | protectedpure virtual |
onSuback(const iot::mqtt_fast::packets::Suback &suback)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onSubscribe(const iot::mqtt_fast::packets::Subscribe &subscribe)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onUnsuback(const iot::mqtt_fast::packets::Unsuback &unsuback)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onUnsubscribe(const iot::mqtt_fast::packets::Unsubscribe &unsubscribe)=0 | iot::mqtt_fast::SocketContext | privatepure virtual |
onWriteError(int errnum) override | core::socket::stream::SocketContext | protectedvirtual |
operator=(const SocketContext &)=delete | core::socket::SocketContext | |
operator=(SocketContext &&)=delete | core::socket::SocketContext | |
printData(const std::vector< char > &data) | iot::mqtt_fast::SocketContext | privatestatic |
readFromPeer(char *chunk, std::size_t chunklen) const final | core::socket::stream::SocketContext | virtual |
readFromPeer(std::size_t available) | core::socket::stream::SocketContext | protected |
readFromPeer(char *chunk, std::size_t chunklen) const=0 | core::socket::stream::SocketContext | virtual |
send(iot::mqtt_fast::ControlPacket &&controlPacket) const | iot::mqtt_fast::SocketContext | private |
send(iot::mqtt_fast::ControlPacket &controlPacket) const | iot::mqtt_fast::SocketContext | private |
send(std::vector< char > &&data) const | iot::mqtt_fast::SocketContext | private |
sendConnack(uint8_t returnCode, uint8_t flags) | iot::mqtt_fast::SocketContext | |
sendConnect(const std::string &clientId) | iot::mqtt_fast::SocketContext | |
sendDisconnect() | iot::mqtt_fast::SocketContext | |
sendPingreq() | iot::mqtt_fast::SocketContext | |
sendPingresp() | iot::mqtt_fast::SocketContext | |
sendPuback(uint16_t packetIdentifier) | iot::mqtt_fast::SocketContext | |
sendPubcomp(uint16_t packetIdentifier) | iot::mqtt_fast::SocketContext | |
sendPublish(const std::string &topic, const std::string &message, bool dup=false, uint8_t qoS=0, bool retain=false) | iot::mqtt_fast::SocketContext | |
sendPubrec(uint16_t packetIdentifier) | iot::mqtt_fast::SocketContext | |
sendPubrel(uint16_t packetIdentifier) | iot::mqtt_fast::SocketContext | |
sendSuback(uint16_t packetIdentifier, const std::list< uint8_t > &returnCodes) | iot::mqtt_fast::SocketContext | |
sendSubscribe(std::list< Topic > &topics) | iot::mqtt_fast::SocketContext | |
sendToPeer(const char *chunk, std::size_t chunkLen) const final | core::socket::stream::SocketContext | virtual |
sendToPeer(const std::string &data) const | core::socket::stream::SocketContext | |
sendToPeer(const char *chunk, std::size_t chunkLen) const=0 | core::socket::stream::SocketContext | virtual |
sendUnsuback(uint16_t packetIdentifier) | iot::mqtt_fast::SocketContext | |
sendUnsubscribe(const std::list< std::string > &topics) | iot::mqtt_fast::SocketContext | |
setTimeout(const utils::Timeval &timeout) final | core::socket::stream::SocketContext | virtual |
shutdownRead() | core::socket::stream::SocketContext | |
shutdownWrite(bool forceClose=false) | core::socket::stream::SocketContext | |
socketConnection | core::socket::stream::SocketContext | private |
SocketContext(core::socket::stream::SocketConnection *socketConnection) | iot::mqtt_fast::SocketContext | explicit |
core::socket::SocketContext::SocketContext()=default | core::socket::SocketContext | protected |
core::socket::SocketContext::SocketContext(const SocketContext &)=delete | core::socket::SocketContext | |
core::socket::SocketContext::SocketContext(SocketContext &&)=delete | core::socket::SocketContext | |
streamEof() | core::socket::stream::SocketContext | |
streamToPeer(core::pipe::Source *source) const | core::socket::stream::SocketContext | |
Super typedef | core::socket::stream::SocketContext | private |
switchSocketContext(SocketContext *newSocketContext) | core::socket::stream::SocketContext | virtual |
timePointToString(const std::chrono::time_point< std::chrono::system_clock > &timePoint) | core::socket::stream::SocketContext | privatestatic |
~SocketContext() override | core::socket::stream::SocketContext | virtual |