(PHP 4 >= 4.3.0, PHP 5, PHP 7, PHP 8)
stream_set_write_buffer — Belirtilen akımda dosya yazma tamponunu ayarlar
$akım, int $boyut): int
akım üzerinde yazma işlemleri için
boyut baytlık tamponu etkin kılar.
akımDosya tanıtıcısı.
boyut
Tamponun bayt sayısı. 0 belirtilirse yazma işlemleri
tamponsuz yapılır. Böylece, çıktı akımına dığer süreçlerin yazmasına
izin vermeden önce fwrite() ile yapılan tüm yazma
işlemlerinin tamamlanması sağlanır.
Başarı durumunda 0, istek yerine getirilememişse
sıfırdan farklı bir değer döner.
Örnek 1 - stream_set_write_buffer() örneği
Aşağıdaki örnekte stream_set_write_buffer() işlevinin bir tamponsuz akım oluşturmak için kullanımı gösterilmiştir.
<?php
$dt = fopen($file, "w");
if ($dt) {
if (stream_set_write_buffer($fp, 0) !== 0) {
// tampon ayarlanamadı
}
fwrite($dt, $output);
fclose($dt);
}
?>
Trying to use stream_set_write_buffer on a local file will always fail according to this note from 2003.
http://grokbase.com/t/php/php-internals/0351gp6xtn/stream-set-write-buffer-does-not-work
Example:
$fp = fopen("localfile.txt", "w");
if (stream_set_write_buffer($fp, 0) !== 0) {
// changing the buffering failed is always true on local files
}
The stream_set_write_buffer() function has been broken since PHP 4.3.0. As a workaround, I would suggest using a php_user_filter as an output buffer. By using the following class I have measured over 50% performance improvements with scripts that generate large text files by writing them one line at a time:
class my_output_buffer extends php_user_filter
{
protected static $BUFFER_SIZE = 4096;
function onCreate( ) {
$this->bff = [];
$this->len = 0;
return true;
}
public function filter($in, $out, &$consumed, $closing)
{
$rv = PSFS_FEED_ME; /* assume no output */
/* process input */
while ($bucket = stream_bucket_make_writeable($in)) {
/* bucket is too big for the buffer? */
$space = static::$BUFFER_SIZE - $this->len;
if ($bucket->datalen >= $space) {
/* consume data by placing it into internal buffers */
$this->bff[] = substr($bucket->data, 0, $space);
$this->len += $space;
$overflow = substr($bucket->data, $space);
$ovfl_len = $bucket->datalen - $space;
$consumed += $bucket->datalen;
assert($this->len == static::$BUFFER_SIZE);
/* make one big bucket */
$bucket->data = implode('', $this->bff);
$bucket->datalen = static::$BUFFER_SIZE;
stream_bucket_append($out, $bucket);
$rv = PSFS_PASS_ON; /* we have output! */
/* handle overflow */
$this->bff = [$overflow];
$this->len = $ovfl_len;
}
else {
/* consume data by placing it into internal buffers */
$this->bff[] = $bucket->data;
$this->len += $bucket->datalen;
$consumed += $bucket->datalen;
}
}
/* stream is closing and we have data? */
if ($closing && $this->len > 0) {
/* make one last bucket */
$data = implode('', $this->bff);
$bucket = stream_bucket_new($this->stream, $data);
stream_bucket_append($out, $bucket);
$rv = PSFS_PASS_ON; /* we have output! */
/* clear internal buffer */
$this->bff = [];
$this->len = 0;
}
return $rv;
}
}
$fp = fopen('foobar.txt', 'w');
/* enable filtering */
stream_filter_register('output.buffer', 'my_output_buffer');
stream_filter_append($fp, 'output.buffer');
/* a lot of small writes */
for ($i = 0; $i < 10000; $i++) {
fwrite($fp, 'x');
}
fclose($fp);
