Lines Matching refs:fs
1 var fs = require('fs')
14 gracefulQueue = Symbol.for('graceful-fs.queue')
16 previousSymbol = Symbol.for('graceful-fs.previous')
18 gracefulQueue = '___graceful-fs.queue'
19 previousSymbol = '___graceful-fs.previous'
43 if (!fs[gracefulQueue]) {
46 publishQueue(fs, queue)
48 // Patch fs.close/closeSync to shared queue version, because we need
50 // This is essential when multiple graceful-fs instances are
52 fs.close = (function (fs$close) {
54 return fs$close.call(fs, fd, function (err) {
55 // This function uses the graceful-fs shared queue
66 value: fs$close
69 })(fs.close)
71 fs.closeSync = (function (fs$closeSync) {
73 // This function uses the graceful-fs shared queue
74 fs$closeSync.apply(fs, arguments)
79 value: fs$closeSync
82 })(fs.closeSync)
86 debug(fs[gracefulQueue])
87 require('assert').equal(fs[gracefulQueue].length, 0)
93 publishQueue(global, fs[gracefulQueue]);
96 module.exports = patch(clone(fs))
97 if (process.env.TEST_GRACEFUL_FS_GLOBAL_PATCH && !fs.__patched) {
98 module.exports = patch(fs)
99 fs.__patched = true;
102 function patch (fs) {
104 polyfills(fs)
105 fs.gracefulify = patch
107 fs.createReadStream = createReadStream
108 fs.createWriteStream = createWriteStream
109 var fs$readFile = fs.readFile
110 fs.readFile = readFile
118 return fs$readFile(path, options, function (err) {
129 var fs$writeFile = fs.writeFile
130 fs.writeFile = writeFile
138 return fs$writeFile(path, data, options, function (err) {
149 var fs$appendFile = fs.appendFile
150 if (fs$appendFile)
151 fs.appendFile = appendFile
159 return fs$appendFile(path, data, options, function (err) {
170 var fs$copyFile = fs.copyFile
171 if (fs$copyFile)
172 fs.copyFile = copyFile
181 return fs$copyFile(src, dest, flags, function (err) {
192 var fs$readdir = fs.readdir
193 fs.readdir = readdir
201 return fs$readdir(path, fs$readdirCallback(
206 return fs$readdir(path, options, fs$readdirCallback(
213 function fs$readdirCallback (path, options, cb, startTime) {
235 var legStreams = legacy(fs)
240 var fs$ReadStream = fs.ReadStream
241 if (fs$ReadStream) {
242 ReadStream.prototype = Object.create(fs$ReadStream.prototype)
246 var fs$WriteStream = fs.WriteStream
247 if (fs$WriteStream) {
248 WriteStream.prototype = Object.create(fs$WriteStream.prototype)
252 Object.defineProperty(fs, 'ReadStream', {
262 Object.defineProperty(fs, 'WriteStream', {
275 Object.defineProperty(fs, 'FileReadStream', {
286 Object.defineProperty(fs, 'FileWriteStream', {
299 return fs$ReadStream.apply(this, arguments), this
322 return fs$WriteStream.apply(this, arguments), this
341 return new fs.ReadStream(path, options)
345 return new fs.WriteStream(path, options)
348 var fs$open = fs.open
349 fs.open = open
357 return fs$open(path, flags, mode, function (err, fd) {
368 return fs
373 fs[gracefulQueue].push(elem)
385 for (var i = 0; i < fs[gracefulQueue].length; ++i) {
388 if (fs[gracefulQueue][i].length > 2) {
389 fs[gracefulQueue][i][3] = now // startTime
390 fs[gracefulQueue][i][4] = now // lastTime
402 if (fs[gracefulQueue].length === 0)
405 var elem = fs[gracefulQueue].shift()
408 // these items may be unset if they were added by an older graceful-fs
440 fs[gracefulQueue].push(elem)