mirror of
https://github.com/php/php-src.git
synced 2024-09-24 19:37:26 +00:00
326 lines
7.0 KiB
PHP
326 lines
7.0 KiB
PHP
--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
|