From 6d09f85836097846d4450a27263adca30a8d80c9 Mon Sep 17 00:00:00 2001
From: Aki <please@ignore.pl>
Date: Sat, 21 Aug 2021 22:52:58 +0200
Subject: Fixed buffer handling by stream

---
 buffer.c | 3 ++-
 stream.c | 4 ++--
 2 files changed, 4 insertions(+), 3 deletions(-)

diff --git a/buffer.c b/buffer.c
index 0261522..c1a33a1 100644
--- a/buffer.c
+++ b/buffer.c
@@ -42,8 +42,9 @@ int buffer_prepare_at_least(int fd, struct buffer * in, int minimum_length)
 	if (0 < in->offset)
 	{
 		memmove(in->data, in->data + in->offset, in->length - in->offset);
-		in->offset = 0;
 		in->length -= in->offset;
+		in->next -= in->offset;
+		in->offset = 0;
 	}
 
 	int length = read(fd, in->data + in->length, free_space);
diff --git a/stream.c b/stream.c
index eb1d0ea..c6d5bb2 100644
--- a/stream.c
+++ b/stream.c
@@ -173,8 +173,8 @@ int stream_readk(lua_State * L, int status, lua_KContext ctx)
 		if (-1 != offset)
 		{
 			lua_pushlstring(L, &s->in.data[s->in.offset], offset - s->in.offset);
-			s->in.offset = offset + 1;
-			s->in.next = offset + 1;
+			s->in.offset = offset + pattern_length;
+			s->in.next = offset + pattern_length;
 		}
 		else
 		{
-- 
cgit v1.1