diff options
| author | Oskari Timperi <oskari.timperi@iki.fi> | 2017-03-18 09:29:19 +0200 |
|---|---|---|
| committer | Oskari Timperi <oskari.timperi@iki.fi> | 2017-03-18 09:29:19 +0200 |
| commit | 7aeef53b089272f4633cc40512296bfd884a58d4 (patch) | |
| tree | 894753ced0495f725ad8362859f88d5b61e29eb7 /src/stream_mqtt.h | |
| parent | e9958e8a0f5aa5fbe0a4a03be42b8bf640add6f7 (diff) | |
| parent | 2c76b0da9e0aba2211d5b4a8e51c79e47ad9b6c8 (diff) | |
| download | mqtt-0.5.tar.gz mqtt-0.5.zip | |
Merge branch 'the-great-refactor'v0.5
* the-great-refactor:
Add big_message_test
Fix publish message serialization
Modify the code to use nonblocking sockets
Fix indentation
Free userName and password in MqttClientFree()
Add forgotten files
Massive refactoring of the internals
Diffstat (limited to 'src/stream_mqtt.h')
| -rw-r--r-- | src/stream_mqtt.h | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/src/stream_mqtt.h b/src/stream_mqtt.h index 9023430..8c8ccb5 100644 --- a/src/stream_mqtt.h +++ b/src/stream_mqtt.h @@ -2,13 +2,15 @@ #define STREAM_MQTT_H #include "stream.h" +#include "stringstream.h" #include <bstrlib/bstrlib.h> int64_t StreamReadMqttString(bstring *buf, Stream *stream); int64_t StreamWriteMqttString(const_bstring buf, Stream *stream); -int64_t StreamReadRemainingLength(size_t *remainingLength, Stream *stream); -int64_t StreamWriteRemainingLength(size_t remainingLength, Stream *stream); +int64_t StreamReadRemainingLength(size_t *remainingLength, size_t *mul, + Stream *stream); +int64_t StreamWriteRemainingLength(size_t *remainingLength, Stream *stream); #endif |