Annotation of embedaddon/php/ext/standard/tests/file/userstreams.phpt, revision 1.1
1.1 ! misho 1: --TEST--
! 2: User-space streams
! 3: --FILE--
! 4: <?php
! 5: # vim600:syn=php:
! 6:
! 7: /* This is a fairly aggressive test that looks at
! 8: * user streams and also gives the seek/gets/buffer
! 9: * layer of streams a thorough testing */
! 10:
! 11: $lyrics = <<<EOD
! 12: ...and the road becomes my bride
! 13: I have stripped of all but pride
! 14: so in her I do confide
! 15: and she keeps me satisfied
! 16: gives me all I need
! 17: ...and with dust in throat I crave
! 18: to the game you stay a slave
! 19: rover wanderer
! 20: nomad vagabond
! 21: call me what you will
! 22: But Ill take my time anywhere
! 23: Free to speak my mind anywhere
! 24: and Ill redefine anywhere
! 25: Anywhere I roam
! 26: Where I lay my head is home
! 27: ...and the earth becomes my throne
! 28: I adapt to the unknown
! 29: under wandering stars Ive grown
! 30: by myself but not alone
! 31: I ask no one
! 32: ...and my ties are severed clean
! 33: the less I have the more I gain
! 34: off the beaten path I reign
! 35: rover wanderer
! 36: nomad vagabond
! 37: call me what you will
! 38: But Ill take my time anywhere
! 39: Free to speak my mind anywhere
! 40: and Ill never mind anywhere
! 41: Anywhere I roam
! 42: Where I lay my head is home
! 43: But Ill take my time anywhere
! 44: Free to speak my mind anywhere
! 45: and Ill take my find anywhere
! 46: Anywhere I roam
! 47: Where I lay my head is home
! 48: carved upon my stone
! 49: my body lie but still I roam
! 50: Wherever I may roam.
! 51:
! 52: Wherever I May Roam
! 53:
! 54: EOD;
! 55:
! 56: /* repeat the data a few times so that it grows larger than
! 57: * the default cache chunk size and that we have something
! 58: * to seek around... */
! 59: $DATA = "";
! 60: for ($i = 0; $i < 30; $i++) {
! 61: if ($i % 2 == 0)
! 62: $DATA .= str_rot13($lyrics);
! 63: else
! 64: $DATA .= $lyrics;
! 65: }
! 66:
! 67: /* store the data in a regular file so that we can compare
! 68: * the results */
! 69: $tf = tmpfile();
! 70: fwrite($tf, (binary)$DATA);
! 71: $n = ftell($tf);
! 72: rewind($tf) or die("failed to rewind tmp file!");
! 73: if (ftell($tf) != 0)
! 74: die("tmpfile is not at start!");
! 75: $DATALEN = strlen($DATA);
! 76: if ($n != $DATALEN)
! 77: die("tmpfile stored $n bytes; should be $DATALEN!");
! 78:
! 79: class uselessstream
! 80: {
! 81: }
! 82:
! 83: class mystream
! 84: {
! 85: public $path;
! 86: public $mode;
! 87: public $options;
! 88:
! 89: public $position;
! 90: public $varname;
! 91:
! 92: function stream_open($path, $mode, $options, &$opened_path)
! 93: {
! 94: $this->path = $path;
! 95: $this->mode = $mode;
! 96: $this->options = $options;
! 97:
! 98: $split = parse_url($path);
! 99: $this->varname = $split["host"];
! 100:
! 101: if (strchr($mode, 'a'))
! 102: $this->position = strlen($GLOBALS[$this->varname]);
! 103: else
! 104: $this->position = 0;
! 105:
! 106: return true;
! 107: }
! 108:
! 109: function stream_read($count)
! 110: {
! 111: $ret = substr($GLOBALS[$this->varname], $this->position, $count);
! 112: $this->position += strlen($ret);
! 113: return $ret;
! 114: }
! 115:
! 116: function stream_tell()
! 117: {
! 118: return $this->position;
! 119: }
! 120:
! 121: function stream_eof()
! 122: {
! 123: return $this->position >= strlen($GLOBALS[$this->varname]);
! 124: }
! 125:
! 126: function stream_seek($offset, $whence)
! 127: {
! 128: switch($whence) {
! 129: case SEEK_SET:
! 130: if ($offset < strlen($GLOBALS[$this->varname]) && $offset >= 0) {
! 131: $this->position = $offset;
! 132: return true;
! 133: } else {
! 134: return false;
! 135: }
! 136: break;
! 137: case SEEK_CUR:
! 138: if ($offset >= 0) {
! 139: $this->position += $offset;
! 140: return true;
! 141: } else {
! 142: return false;
! 143: }
! 144: break;
! 145: case SEEK_END:
! 146: if (strlen($GLOBALS[$this->varname]) + $offset >= 0) {
! 147: $this->position = strlen($GLOBALS[$this->varname]) + $offset;
! 148: return true;
! 149: } else {
! 150: return false;
! 151: }
! 152: break;
! 153: default:
! 154: return false;
! 155: }
! 156: }
! 157:
! 158: }
! 159:
! 160: if (@stream_wrapper_register("bogus", "class_not_exist")) {
! 161: die("Registered a non-existant class!!!???");
! 162: }
! 163: echo "Not Registered\n";
! 164:
! 165: if (!stream_wrapper_register("test", "mystream")) {
! 166: die("test wrapper registration failed");
! 167: }
! 168: echo "Registered\n";
! 169:
! 170: if (!stream_wrapper_register("bogon", "uselessstream")) {
! 171: die("bogon wrapper registration failed");
! 172: }
! 173: echo "Registered\n";
! 174:
! 175: $b = @fopen("bogon://url", "rb");
! 176: if (is_resource($b)) {
! 177: die("Opened a bogon??");
! 178: }
! 179:
! 180: $fp = fopen("test://DATA", "rb");
! 181: if (!$fp || !is_resource($fp)) {
! 182: die("Failed to open resource");
! 183: }
! 184:
! 185: /* some default seeks that will cause buffer/cache misses */
! 186: $seeks = array(
! 187: array(SEEK_SET, 0, 0),
! 188: array(SEEK_CUR, 8450, 8450),
! 189: array(SEEK_CUR, -7904, 546),
! 190: array(SEEK_CUR, 12456, 13002),
! 191:
! 192: /* end up at BOF so that randomly generated seek offsets
! 193: * below will know where they are supposed to be */
! 194: array(SEEK_SET, 0, 0)
! 195: );
! 196:
! 197: $whence_map = array(
! 198: SEEK_CUR,
! 199: SEEK_SET,
! 200: SEEK_END
! 201: );
! 202: $whence_names = array(
! 203: SEEK_CUR => "SEEK_CUR",
! 204: SEEK_SET => "SEEK_SET",
! 205: SEEK_END => "SEEK_END"
! 206: );
! 207:
! 208: /* generate some random seek offsets */
! 209: $position = 0;
! 210: for ($i = 0; $i < 256; $i++) {
! 211: $whence = $whence_map[array_rand($whence_map, 1)];
! 212: switch($whence) {
! 213: case SEEK_SET:
! 214: $offset = rand(0, $DATALEN - 1);
! 215: $position = $offset;
! 216: break;
! 217: case SEEK_END:
! 218: $offset = -rand(0, $DATALEN - 1);
! 219: $position = $DATALEN + $offset;
! 220: break;
! 221: case SEEK_CUR:
! 222: $offset = rand(0, $DATALEN - 1);
! 223: $offset -= $position;
! 224: $position += $offset;
! 225: break;
! 226: }
! 227:
! 228: $seeks[] = array($whence, $offset, $position);
! 229: }
! 230:
! 231: /* we compare the results of fgets using differing line lengths to
! 232: * test the fgets layer also */
! 233: $line_lengths = array(1024, 256, 64, 16);
! 234: $fail_count = 0;
! 235:
! 236: ob_start();
! 237: foreach($line_lengths as $line_length) {
! 238: /* now compare the real stream with the user stream */
! 239: $j = 0;
! 240: rewind($tf);
! 241: rewind($fp);
! 242: foreach($seeks as $seekdata) {
! 243: list($whence, $offset, $position) = $seekdata;
! 244:
! 245: $rpb = ftell($tf);
! 246: $rr = (int)fseek($tf, $offset, $whence);
! 247: $rpa = ftell($tf);
! 248: $rline = fgets($tf, $line_length);
! 249: (int)fseek($tf, - strlen($rline), SEEK_CUR);
! 250:
! 251: $upb = ftell($fp);
! 252: $ur = (int)fseek($fp, $offset, $whence);
! 253: $upa = ftell($fp);
! 254: $uline = fgets($fp, $line_length);
! 255: (int)fseek($fp, - strlen($uline), SEEK_CUR);
! 256:
! 257: printf("\n--[%d] whence=%s offset=%d line_length=%d position_should_be=%d --\n",
! 258: $j, $whence_names[$whence], $offset, $line_length, $position);
! 259: printf("REAL: pos=(%d,%d,%d) ret=%d line[%d]=`%s'\n", $rpb, $rpa, ftell($tf), $rr, strlen($rline), $rline);
! 260: printf("USER: pos=(%d,%d,%d) ret=%d line[%d]=`%s'\n", $upb, $upa, ftell($fp), $ur, strlen($uline), $uline);
! 261:
! 262: if ($rr != $ur || $rline != $uline || $rpa != $position || $upa != $position) {
! 263: $fail_count++;
! 264: echo "###################################### FAIL!\n";
! 265: $dat = stream_get_meta_data($fp);
! 266: var_dump($dat);
! 267: break;
! 268: }
! 269:
! 270: $j++;
! 271: }
! 272: if ($fail_count)
! 273: break;
! 274: }
! 275:
! 276: if ($fail_count == 0) {
! 277: ob_end_clean();
! 278: echo "SEEK: OK\n";
! 279: } else {
! 280: echo "SEEK: FAIL\n";
! 281: ob_end_flush();
! 282: }
! 283:
! 284: $fail_count = 0;
! 285:
! 286: fseek($fp, $DATALEN / 2, SEEK_SET);
! 287: fseek($tf, $DATALEN / 2, SEEK_SET);
! 288:
! 289: if (ftell($fp) != ftell($tf)) {
! 290: echo "SEEK: positions do not match!\n";
! 291: }
! 292:
! 293: $n = 0;
! 294: while(!feof($fp)) {
! 295: $uline = fgets($fp, 1024);
! 296: $rline = fgets($tf, 1024);
! 297:
! 298: if ($uline != $rline) {
! 299: echo "FGETS: FAIL\niter=$n user=$uline [pos=" . ftell($fp) . "]\nreal=$rline [pos=" . ftell($tf) . "]\n";
! 300: $fail_count++;
! 301: break;
! 302: }
! 303: }
! 304:
! 305: if ($fail_count == 0) {
! 306: echo "FGETS: OK\n";
! 307: }
! 308:
! 309: /* One final test to see if the position is respected when opened for append */
! 310: $fp = fopen("test://lyrics", "a+");
! 311: rewind($fp);
! 312: var_dump(ftell($fp));
! 313: $data = fgets($fp);
! 314: fclose($fp);
! 315: echo $data . "\n";
! 316:
! 317: ?>
! 318: --EXPECT--
! 319: Not Registered
! 320: Registered
! 321: Registered
! 322: SEEK: OK
! 323: FGETS: OK
! 324: int(0)
! 325: ...and the road becomes my bride
FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>
![[BACK]](/icons/cvsweb/back.gif){kind=icon}
Return to userstreams.phpt CVS log ![[TXT]](/icons/cvsweb/text.gif){kind=icon}
![[DIR]](/icons/cvsweb/dir.gif){kind=icon}
Up to [ELWIX - Embedded LightWeight unIX -] / embedaddon / php / ext / standard / tests / file