|
| SocketContext (core::socket::stream::SocketConnection *socketConnection) |
|
void | sendConnect (const std::string &clientId) |
|
void | sendConnack (uint8_t returnCode, uint8_t flags) |
|
void | sendPublish (const std::string &topic, const std::string &message, bool dup=false, uint8_t qoS=0, bool retain=false) |
|
void | sendPuback (uint16_t packetIdentifier) |
|
void | sendPubrec (uint16_t packetIdentifier) |
|
void | sendPubrel (uint16_t packetIdentifier) |
|
void | sendPubcomp (uint16_t packetIdentifier) |
|
void | sendSubscribe (std::list< Topic > &topics) |
|
void | sendSuback (uint16_t packetIdentifier, const std::list< uint8_t > &returnCodes) |
|
void | sendUnsubscribe (const std::list< std::string > &topics) |
|
void | sendUnsuback (uint16_t packetIdentifier) |
|
void | sendPingreq () |
|
void | sendPingresp () |
|
void | sendDisconnect () |
|
| SocketContext (core::socket::stream::SocketConnection *socketConnection) |
|
| ~SocketContext () override |
|
void | sendToPeer (const char *chunk, std::size_t chunkLen) const final |
|
bool | streamToPeer (core::pipe::Source *source) const |
|
void | streamEof () |
|
std::size_t | readFromPeer (char *chunk, std::size_t chunklen) const final |
|
void | setTimeout (const utils::Timeval &timeout) final |
|
void | shutdownRead () |
|
void | shutdownWrite (bool forceClose=false) |
|
void | close () override |
|
std::size_t | getTotalSent () const override |
|
std::size_t | getTotalQueued () const override |
|
std::size_t | getTotalRead () const override |
|
std::size_t | getTotalProcessed () const override |
|
std::string | getOnlineSince () const override |
|
std::string | getOnlineDuration () const override |
|
SocketConnection * | getSocketConnection () const |
|
virtual void | switchSocketContext (SocketContext *newSocketContext) |
|
virtual std::size_t | readFromPeer (char *chunk, std::size_t chunklen) const=0 |
|
void | sendToPeer (const std::string &data) const |
|
virtual void | sendToPeer (const char *chunk, std::size_t chunkLen) const=0 |
|
| SocketContext (const SocketContext &)=delete |
|
| SocketContext (SocketContext &&)=delete |
|
SocketContext & | operator= (const SocketContext &)=delete |
|
SocketContext & | operator= (SocketContext &&)=delete |
|
void | sendToPeer (const std::string &data) const |
|
Definition at line 85 of file SocketContext.h.
std::size_t iot::mqtt_fast::SocketContext::onReceivedFromPeer |
( |
| ) |
|
|
finalprivatevirtual |
Implements core::socket::SocketContext.
Definition at line 163 of file SocketContext.cpp.
163 {
165
167 LOG(ERROR) << "MQTT (fast): SocketContext: Error during ControlPacket construction";
170 LOG(DEBUG) << "MQTT (fast): ======================================================";
174
176
180 break;
183 break;
186 break;
189 break;
192 break;
195 break;
198 break;
201 break;
204 break;
207 break;
210 break;
213 break;
216 break;
219 break;
220 default:
222 break;
223 }
224
226 }
227
228 return consumed;
229 }
uint64_t getRemainingLength()
iot::mqtt_fast::types::Binary & getPacket()
virtual void onPubrel(const iot::mqtt_fast::packets::Pubrel &pubrel)=0
virtual void onSuback(const iot::mqtt_fast::packets::Suback &suback)=0
virtual void onPingresp(const iot::mqtt_fast::packets::Pingresp &pingresp)=0
virtual void onPubcomp(const iot::mqtt_fast::packets::Pubcomp &pubcomp)=0
virtual void onDisconnect(const iot::mqtt_fast::packets::Disconnect &disconnect)=0
virtual void onConnect(const iot::mqtt_fast::packets::Connect &connect)=0
virtual void onPuback(const iot::mqtt_fast::packets::Puback &puback)=0
virtual void onUnsuback(const iot::mqtt_fast::packets::Unsuback &unsuback)=0
virtual void onSubscribe(const iot::mqtt_fast::packets::Subscribe &subscribe)=0
virtual void onConnack(const iot::mqtt_fast::packets::Connack &connack)=0
static void printData(const std::vector< char > &data)
virtual void onUnsubscribe(const iot::mqtt_fast::packets::Unsubscribe &unsubscribe)=0
virtual void onPubrec(const iot::mqtt_fast::packets::Pubrec &pubrec)=0
virtual void onPublish(const iot::mqtt_fast::packets::Publish &publish)=0
virtual void onPingreq(const iot::mqtt_fast::packets::Pingreq &pingreq)=0
std::vector< char > & getValue()
References core::socket::stream::SocketContext::close(), iot::mqtt_fast::packets::Connack::Connack(), iot::mqtt_fast::packets::Connect::Connect(), iot::mqtt_fast::ControlPacketFactory::construct(), controlPacketFactory, iot::mqtt_fast::packets::Disconnect::Disconnect(), iot::mqtt_fast::ControlPacketFactory::getPacket(), iot::mqtt_fast::ControlPacketFactory::getPacketFlags(), iot::mqtt_fast::ControlPacketFactory::getPacketType(), iot::mqtt_fast::ControlPacketFactory::getRemainingLength(), iot::mqtt_fast::types::Binary::getValue(), iot::mqtt_fast::ControlPacketFactory::isComplete(), iot::mqtt_fast::ControlPacketFactory::isError(), onConnack(), onConnect(), onDisconnect(), onPingreq(), onPingresp(), onPuback(), onPubcomp(), onPublish(), onPubrec(), onPubrel(), onSuback(), onSubscribe(), onUnsuback(), onUnsubscribe(), iot::mqtt_fast::packets::Pingreq::Pingreq(), iot::mqtt_fast::packets::Pingresp::Pingresp(), printData(), iot::mqtt_fast::packets::Puback::Puback(), iot::mqtt_fast::packets::Pubcomp::Pubcomp(), iot::mqtt_fast::packets::Publish::Publish(), iot::mqtt_fast::packets::Pubrec::Pubrec(), iot::mqtt_fast::packets::Pubrel::Pubrel(), iot::mqtt_fast::ControlPacketFactory::reset(), iot::mqtt_fast::packets::Suback::Suback(), iot::mqtt_fast::packets::Subscribe::Subscribe(), iot::mqtt_fast::packets::Unsuback::Unsuback(), and iot::mqtt_fast::packets::Unsubscribe::Unsubscribe().