From 7df4391b817912653896c2cf856187d1df2b3752 Mon Sep 17 00:00:00 2001
From: Michael Wallner <mike@php.net>
Date: Tue, 11 Jan 2022 00:17:30 +0100
Subject: [PATCH] fix leak reading partial lobs

---
 ion.c             |  4 +---
 tests/LOB/RW.phpt | 48 +++++++++++++++++++++++++++++++++++++++++++++++
 2 files changed, 49 insertions(+), 3 deletions(-)
 create mode 100644 tests/LOB/RW.phpt

diff --git a/ion.c b/ion.c
index 8bf7e0a..fe7a38e 100644
--- a/ion.c
+++ b/ion.c
@@ -1036,9 +1036,7 @@ static void read_part(INTERNAL_FUNCTION_PARAMETERS, read_part_fn fn)
 		RETURN_TRUE;
 	}
 fail:
-	if (zstr != Z_STR_P(ref)) {
-		zend_string_release(zstr);
-	}
+	zend_string_release(zstr);
 	ZVAL_EMPTY_STRING(ref);
 	RETURN_FALSE;
 }
diff --git a/tests/LOB/RW.phpt b/tests/LOB/RW.phpt
new file mode 100644
index 0000000..fa1a576
--- /dev/null
+++ b/tests/LOB/RW.phpt
@@ -0,0 +1,48 @@
+--TEST--
+ion\LOB/RW
+--EXTENSIONS--
+ion
+--FILE--
+TEST
+<?php
+$s = stream_socket_pair(STREAM_PF_UNIX, STREAM_SOCK_STREAM, 0);
+array_map(fn($s)=>stream_set_blocking($s,false), $s);
+
+$w = new ion\Writer\Stream\Writer($s[0]);
+$w->startLob(ion\Type::CLob);
+$w->appendLob(str_repeat("a", 0x1000));
+
+$l = 0;
+$r = new ion\Reader\Stream\Reader($s[1]);
+for ($i = 0; $i < 10; $i++) {
+	$W=$E=[];
+	for ($R=[$s[1]]; stream_select($R, $W, $E, 0); ) {
+		if ($r->getType() != ion\Type::CLob)
+			$r->next();
+		echo "+";
+		$r->readLobPart($b);
+		$l += strlen($b);
+	}
+	echo "-";
+	$w->appendLob(str_repeat("a", 0x1000));
+}
+
+$w->finishLob();
+$w->finish();
+
+while ($r->readLobPart($b)) {
+	echo ".";
+    $l += strlen($b);
+}
+echo "\n";
+
+$r->next();
+var_dump($r->key(), $l);
+?>
+DONE
+--EXPECTF--
+TEST
+%r[-+]+\.+%r
+enum(ion\Type::EOF)
+int(45056)
+DONE
-- 
2.30.2