1 files changed, 325 insertions, 0 deletions
diff --git a/ext/standard/tests/file/userstreams.phpt b/ext/standard/tests/file/userstreams.phpt
new file mode 100644
index 0000000..b5a9707
--- /dev/null
+++ b/ext/standard/tests/file/userstreams.phpt
@@ -0,0 +1,325 @@
+--TEST--
+User-space streams
+--FILE--
+<?php
+# vim600:syn=php:
+
+/* This is a fairly aggressive test that looks at
+ * user streams and also gives the seek/gets/buffer
+ * layer of streams a thorough testing */
+
+$lyrics = <<<EOD
+...and the road becomes my bride
+I have stripped of all but pride
+so in her I do confide
+and she keeps me satisfied
+gives me all I need
+...and with dust in throat I crave
+to the game you stay a slave
+rover  wanderer
+nomad  vagabond
+call me what you will
+   But Ill take my time anywhere
+   Free to speak my mind anywhere
+   and Ill redefine anywhere
+      Anywhere I roam
+	  Where I lay my head is home
+...and the earth becomes my throne
+I adapt to the unknown
+under wandering stars Ive grown
+by myself but not alone
+I ask no one
+...and my ties are severed clean
+the less I have the more I gain
+off the beaten path I reign
+rover  wanderer
+nomad  vagabond
+call me what you will
+   But Ill take my time anywhere
+   Free to speak my mind anywhere
+   and Ill never mind anywhere
+      Anywhere I roam
+	  Where I lay my head is home
+   But Ill take my time anywhere
+   Free to speak my mind anywhere
+   and Ill take my find anywhere
+      Anywhere I roam
+	  Where I lay my head is home
+   carved upon my stone
+   my body lie but still I roam
+      Wherever I may roam.
+
+Wherever I May Roam
+
+EOD;
+
+/* repeat the data a few times so that it grows larger than
+ * the default cache chunk size and that we have something
+ * to seek around... */
+$DATA = "";
+for ($i = 0; $i < 30; $i++) {
+	if ($i % 2 == 0)
+		$DATA .= str_rot13($lyrics);
+	else
+		$DATA .= $lyrics;
+}
+
+/* store the data in a regular file so that we can compare
+ * the results */
+$tf = tmpfile();
+fwrite($tf, (binary)$DATA);
+$n = ftell($tf);
+rewind($tf) or die("failed to rewind tmp file!");
+if (ftell($tf) != 0)
+	die("tmpfile is not at start!");
+$DATALEN = strlen($DATA);
+if ($n != $DATALEN)
+	die("tmpfile stored $n bytes; should be $DATALEN!");
+
+class uselessstream 
+{
+}
+
+class mystream 
+{
+	public $path;
+	public $mode;
+	public $options;
+
+	public $position;
+	public $varname;
+
+	function stream_open($path, $mode, $options, &$opened_path)
+	{
+		$this->path = $path;
+		$this->mode = $mode;
+		$this->options = $options;
+
+		$split = parse_url($path);
+		$this->varname = $split["host"];
+
+		if (strchr($mode, 'a'))
+			$this->position = strlen($GLOBALS[$this->varname]);
+		else
+			$this->position = 0;
+		
+		return true;
+	}
+
+	function stream_read($count)
+	{
+		$ret = substr($GLOBALS[$this->varname], $this->position, $count);
+		$this->position += strlen($ret);
+		return $ret;
+	}
+
+	function stream_tell()
+	{
+		return $this->position;
+	}
+
+	function stream_eof()
+	{
+		return $this->position >= strlen($GLOBALS[$this->varname]);
+	}
+
+	function stream_seek($offset, $whence)
+	{
+		switch($whence) {
+			case SEEK_SET:
+				if ($offset < strlen($GLOBALS[$this->varname]) && $offset >= 0) {
+					$this->position = $offset;
+					return true;
+				} else {
+					return false;
+				}
+				break;
+			case SEEK_CUR:
+				if ($offset >= 0) {
+					$this->position += $offset;
+					return true;
+				} else {
+					return false;
+				}
+				break;
+			case SEEK_END:
+				if (strlen($GLOBALS[$this->varname]) + $offset >= 0) {
+					$this->position = strlen($GLOBALS[$this->varname]) + $offset;
+					return true;
+				} else {
+					return false;
+				}
+				break;
+			default:
+				return false;
+		}
+	}
+
+}
+
+if (@stream_wrapper_register("bogus", "class_not_exist")) {
+	die("Registered a non-existant class!!!???");
+}
+echo "Not Registered\n";
+
+if (!stream_wrapper_register("test", "mystream")) {
+	die("test wrapper registration failed");
+}
+echo "Registered\n";
+
+if (!stream_wrapper_register("bogon", "uselessstream")) {
+	die("bogon wrapper registration failed");
+}
+echo "Registered\n";
+
+$b = @fopen("bogon://url", "rb");
+if (is_resource($b)) {
+	die("Opened a bogon??");
+}
+
+$fp = fopen("test://DATA", "rb");
+if (!$fp || !is_resource($fp)) {
+	die("Failed to open resource");
+}
+
+/* some default seeks that will cause buffer/cache misses */
+$seeks = array(
+	array(SEEK_SET, 0, 0),
+	array(SEEK_CUR, 8450, 8450),
+	array(SEEK_CUR, -7904, 546),
+	array(SEEK_CUR, 12456, 13002),
+
+	/* end up at BOF so that randomly generated seek offsets
+	 * below will know where they are supposed to be */
+	array(SEEK_SET, 0, 0)
+);
+
+$whence_map = array(
+	SEEK_CUR,
+	SEEK_SET,
+	SEEK_END
+);
+$whence_names = array(
+	SEEK_CUR => "SEEK_CUR",
+	SEEK_SET => "SEEK_SET",
+	SEEK_END => "SEEK_END"
+	);
+
+/* generate some random seek offsets */
+$position = 0;
+for ($i = 0; $i < 256; $i++) {
+	$whence = $whence_map[array_rand($whence_map, 1)];
+	switch($whence) {
+		case SEEK_SET:
+			$offset = rand(0, $DATALEN - 1);
+			$position = $offset;
+			break;
+		case SEEK_END:
+			$offset = -rand(0, $DATALEN - 1);
+			$position = $DATALEN + $offset;
+			break;
+		case SEEK_CUR:
+			$offset = rand(0, $DATALEN - 1);
+			$offset -= $position;
+			$position += $offset;
+			break;
+	}
+
+	$seeks[] = array($whence, $offset, $position);
+}
+
+/* we compare the results of fgets using differing line lengths to 
+ * test the fgets layer also */
+$line_lengths = array(1024, 256, 64, 16);
+$fail_count = 0;
+
+ob_start();
+foreach($line_lengths as $line_length) {
+	/* now compare the real stream with the user stream */
+	$j = 0;
+	rewind($tf);
+	rewind($fp);
+	foreach($seeks as $seekdata) {
+		list($whence, $offset, $position) = $seekdata;
+
+		$rpb = ftell($tf);
+		$rr = (int)fseek($tf, $offset, $whence);
+		$rpa = ftell($tf);
+		$rline = fgets($tf, $line_length);
+		(int)fseek($tf, - strlen($rline), SEEK_CUR);
+
+		$upb = ftell($fp);
+		$ur = (int)fseek($fp, $offset, $whence);
+		$upa = ftell($fp);
+		$uline = fgets($fp, $line_length);
+		(int)fseek($fp, - strlen($uline), SEEK_CUR);
+
+		printf("\n--[%d] whence=%s offset=%d line_length=%d position_should_be=%d --\n",
+			$j, $whence_names[$whence], $offset, $line_length, $position);
+		printf("REAL: pos=(%d,%d,%d) ret=%d line[%d]=`%s'\n", $rpb, $rpa, ftell($tf), $rr, strlen($rline), $rline);
+		printf("USER: pos=(%d,%d,%d) ret=%d line[%d]=`%s'\n", $upb, $upa, ftell($fp), $ur, strlen($uline), $uline);
+
+		if ($rr != $ur || $rline != $uline || $rpa != $position || $upa != $position) {
+			$fail_count++;
+			echo "###################################### FAIL!\n";
+			$dat = stream_get_meta_data($fp);
+			var_dump($dat);
+			break;
+		}
+		
+		$j++;
+	}
+	if ($fail_count)
+		break;
+}
+
+if ($fail_count == 0) {
+	ob_end_clean();
+	echo "SEEK: OK\n";
+} else {
+	echo "SEEK: FAIL\n";
+	ob_end_flush();
+}
+
+$fail_count = 0;
+
+fseek($fp, $DATALEN / 2, SEEK_SET);
+fseek($tf, $DATALEN / 2, SEEK_SET);
+
+if (ftell($fp) != ftell($tf)) {
+	echo "SEEK: positions do not match!\n";
+}
+
+$n = 0;
+while(!feof($fp)) {
+	$uline = fgets($fp, 1024);
+	$rline = fgets($tf, 1024);
+
+	if ($uline != $rline) {
+		echo "FGETS: FAIL\niter=$n user=$uline [pos=" . ftell($fp) . "]\nreal=$rline [pos=" . ftell($tf) . "]\n";
+		$fail_count++;
+		break;
+	}
+}
+
+if ($fail_count == 0) {
+	echo "FGETS: OK\n";
+}
+
+/* One final test to see if the position is respected when opened for append */
+$fp = fopen("test://lyrics", "a+");
+rewind($fp);
+var_dump(ftell($fp));
+$data = fgets($fp);
+fclose($fp);
+echo $data . "\n";
+
+?>
+--EXPECT--
+Not Registered
+Registered
+Registered
+SEEK: OK
+FGETS: OK
+int(0)
+...and the road becomes my bride