2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
42#ifndef NET_SYSTEM_SIGNAL_H
43#define NET_SYSTEM_SIGNAL_H
45#ifndef DOXYGEN_SHOULD_SKIP_THIS
virtual std::size_t recv(char *chunk, std::size_t chunklen)=0
std::size_t onReceivedFromPeer()
MqttContext(const MqttContext &)=default
MqttContext & operator=(const MqttContext &)=default
virtual void send(const char *chunk, std::size_t chunklen)=0
virtual core::socket::stream::SocketConnection * getSocketConnection() const =0
virtual void end(bool fatal=false)=0
void onEvent(const utils::Timeval ¤tTime) override
OnReceivedFromPeerEvent(const std::function< void(const utils::Timeval &)> &onReceivedFromPeer)
std::function< void(const utils::Timeval &)> onReceivedFromPeer
void onMessageError(uint16_t errnum) override
bool onSignal(int sig) override
void send(const char *chunk, std::size_t chunklen) override
void onDisconnected() override
void onConnected() override
void end(bool fatal=false) override
core::socket::stream::SocketConnection * getSocketConnection() const override
std::size_t recv(char *chunk, std::size_t chunklen) override
std::vector< char > buffer
OnReceivedFromPeerEvent onReceivedFromPeerEvent
void onMessageData(const char *chunk, std::size_t chunkLen) override
SubProtocol(web::websocket::SubProtocolContext *subProtocolContext, const std::string &name, iot::mqtt::Mqtt *mqtt)
void onMessageEnd() override
void onMessageStart(int opCode) override
~SubProtocol() override=default
sighandler_t signal(int sig, sighandler_t handler)
std::string sigabbrev_np(int sig)
std::string hexDump(const std::vector< char > &bytes, int prefixLength, bool prefixAtFirstLine)