diff options
| author | Oskari Timperi <oskari.timperi@iki.fi> | 2017-03-18 09:17:16 +0200 |
|---|---|---|
| committer | Oskari Timperi <oskari.timperi@iki.fi> | 2017-03-18 09:17:16 +0200 |
| commit | 03f7cae60919a04ff0ebc87baf3b51b9bbb1776f (patch) | |
| tree | 3d0306c4b5f5ddef77e9bcd0ec8cadf3013ba13d /src/packet.h | |
| parent | d97c786dbd30b4349d22b41c657f69a335f3d77a (diff) | |
| download | mqtt-03f7cae60919a04ff0ebc87baf3b51b9bbb1776f.tar.gz mqtt-03f7cae60919a04ff0ebc87baf3b51b9bbb1776f.zip | |
Modify the code to use nonblocking sockets
Diffstat (limited to 'src/packet.h')
| -rw-r--r-- | src/packet.h | 2 |
1 files changed, 2 insertions, 0 deletions
diff --git a/src/packet.h b/src/packet.h index 36dc81f..a5e2ce7 100644 --- a/src/packet.h +++ b/src/packet.h @@ -53,6 +53,8 @@ struct MqttPacket int state; uint16_t id; size_t remainingLength; + size_t remainingLengthMul; + /* TODO: maybe switch to have a StringStream here? */ bstring payload; struct MqttMessage *message; SIMPLEQ_ENTRY(MqttPacket) sendQueue; |