diff --git a/lib/fs.js b/lib/fs.js index 137b95ff0a9..94c4a503f64 100644 --- a/lib/fs.js +++ b/lib/fs.js @@ -38,7 +38,6 @@ var Readable = Stream.Readable; var Writable = Stream.Writable; var kMinPoolSpace = 128; -var kPoolSize = 40 * 1024; var O_APPEND = constants.O_APPEND || 0; var O_CREAT = constants.O_CREAT || 0; @@ -1370,8 +1369,8 @@ fs.realpath = function realpath(p, cache, cb) { var pool; -function allocNewPool() { - pool = new Buffer(kPoolSize); +function allocNewPool(poolSize) { + pool = new Buffer(poolSize); pool.used = 0; } @@ -1468,7 +1467,7 @@ ReadStream.prototype._read = function(n, cb) { // discard the old pool. Can't add to the free list because // users might have refernces to slices on it. pool = null; - allocNewPool(); + allocNewPool(this._readableState.bufferSize); } // Grab another reference to the pool in the case that while we're