From 03f7cae60919a04ff0ebc87baf3b51b9bbb1776f Mon Sep 17 00:00:00 2001 From: Oskari Timperi Date: Sat, 18 Mar 2017 09:17:16 +0200 Subject: Modify the code to use nonblocking sockets --- src/stream_mqtt.h | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) (limited to 'src/stream_mqtt.h') 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 -- cgit v1.2.3