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 WEB_WEBSOCKET_SOCKETCONTEXTUPGRADEBASE_H
43#define WEB_WEBSOCKET_SOCKETCONTEXTUPGRADEBASE_H
45#include "web/websocket/Receiver.h"
46#include "web/websocket/Transmitter.h"
48namespace core::socket::
stream {
52#ifndef DOXYGEN_SHOULD_SKIP_THIS
72 virtual void sendMessage(uint8_t opCode,
const char* message, std::size_t messageLength) = 0;
73 virtual void sendMessageStart(uint8_t opCode,
const char* message, std::size_t messageLength) = 0;
76 virtual void sendMessageEnd(
const char* message, std::size_t messageLength) = 0;
77 virtual void sendPing(
const char* reason =
nullptr, std::size_t reasonLength = 0) = 0;
78 virtual void sendPong(
const char* reason =
nullptr, std::size_t reasonLength = 0) = 0;
79 virtual void sendClose(uint16_t statusCode = 1000,
const char* reason =
nullptr, std::size_t reasonLength = 0) = 0;
86 virtual void sendClose(
const char* message, std::size_t messageLength) = 0;
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
virtual void sendMessage(uint8_t opCode, const char *message, std::size_t messageLength)=0
virtual void sendPing(const char *reason=nullptr, std::size_t reasonLength=0)=0
virtual void sendMessageFrame(const char *message, std::size_t messageLength)=0
SubProtocolContext & operator=(const SubProtocolContext &)=delete
~SubProtocolContext() override
virtual void sendPong(const char *reason=nullptr, std::size_t reasonLength=0)=0
virtual void sendClose(const char *message, std::size_t messageLength)=0
SubProtocolContext(core::socket::stream::SocketConnection *socketConnection, bool role)
virtual void sendMessageEnd(const char *message, std::size_t messageLength)=0
virtual void sendClose(uint16_t statusCode=1000, const char *reason=nullptr, std::size_t reasonLength=0)=0
virtual void sendMessageStart(uint8_t opCode, const char *message, std::size_t messageLength)=0
virtual core::socket::stream::SocketConnection * getSocketConnection()=0
SubProtocolContext(const SubProtocolContext &)=delete
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)