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/stream_mqtt.h | |
| parent | d97c786dbd30b4349d22b41c657f69a335f3d77a (diff) | |
| download | mqtt-03f7cae60919a04ff0ebc87baf3b51b9bbb1776f.tar.gz mqtt-03f7cae60919a04ff0ebc87baf3b51b9bbb1776f.zip | |
Modify the code to use nonblocking sockets
Diffstat (limited to 'src/stream_mqtt.h')
| -rw-r--r-- | src/stream_mqtt.h | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/stream_mqtt.h b/src/stream_mqtt.h index a128524..8c8ccb5 100644 --- a/src/stream_mqtt.h +++ b/src/stream_mqtt.h @@ -9,7 +9,8 @@ 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 |