aboutsummaryrefslogtreecommitdiff
path: root/src/stream.c
diff options
context:
space:
mode:
authorOskari Timperi <oskari.timperi@iki.fi>2017-03-06 21:31:07 +0200
committerOskari Timperi <oskari.timperi@iki.fi>2017-03-06 21:31:07 +0200
commita062d934aef40829d9559a8ca83147ea4c44108e (patch)
tree6ee1f9eb3208bea65365e63d039ad27c40111c6f /src/stream.c
parente9958e8a0f5aa5fbe0a4a03be42b8bf640add6f7 (diff)
downloadmqtt-a062d934aef40829d9559a8ca83147ea4c44108e.tar.gz
mqtt-a062d934aef40829d9559a8ca83147ea4c44108e.zip
Massive refactoring of the internals
Diffstat (limited to 'src/stream.c')
-rw-r--r--src/stream.c10
1 files changed, 10 insertions, 0 deletions
diff --git a/src/stream.c b/src/stream.c
index fd154a1..1c46668 100644
--- a/src/stream.c
+++ b/src/stream.c
@@ -47,6 +47,11 @@ int64_t StreamReadUint16Be(uint16_t *v, Stream *stream)
return 2;
}
+int64_t StreamReadByte(unsigned char *byte, Stream *stream)
+{
+ return StreamRead(byte, sizeof(*byte), stream);
+}
+
int64_t StreamWrite(const void *ptr, size_t size, Stream *stream)
{
STREAM_CHECK_OP(stream, write);
@@ -65,6 +70,11 @@ int64_t StreamWriteUint16Be(uint16_t v, Stream *stream)
return StreamWrite(data, sizeof(data), stream);
}
+int64_t StreamWriteByte(unsigned char byte, Stream *stream)
+{
+ return StreamWrite(&byte, sizeof(byte), stream);
+}
+
int StreamSeek(Stream *stream, int64_t offset, int whence)
{
STREAM_CHECK_OP(stream, seek);