test/**/node_modules
test/parallel/test-fs-non-number-arguments-throw.js
test/disabled
+test/tmp*/
}
}
-function refreshTmpDir() {
- if (!process.send) { // Not a child process
- try {
- rimrafSync(exports.tmpDir);
- } catch (e) {
- }
+exports.refreshTmpDir = function() {
+ try {
+ rimrafSync(exports.tmpDir);
+ } catch (e) {
+ }
- try {
- fs.mkdirSync(exports.tmpDir);
- } catch (e) {
- }
+ try {
+ fs.mkdirSync(exports.tmpDir);
+ } catch (e) {
}
-}
+};
if (process.env.TEST_THREAD_ID) {
// Distribute ports in parallel tests
}
exports.tmpDir = path.join(exports.testDir, exports.tmpDirName);
-refreshTmpDir();
-
var opensslCli = null;
var inFreeBSDJail = null;
var localhostIPv4 = null;
var common = require('../common');
var net = require('net');
+common.refreshTmpDir();
+
var server = net.createServer().listen(common.PIPE, function() {
console.log('child listening');
process.send('listening');
process.exit();
}
else {
+ common.refreshTmpDir();
try {
fs.unlinkSync(copyPath);
}
var http = require('http');
if (cluster.isMaster) {
+ common.refreshTmpDir();
var ok = false;
var worker = cluster.fork();
worker.on('message', function(msg) {
}
var dirname = common.tmpDir + '/cwd-does-not-exist-' + process.pid;
+common.refreshTmpDir();
fs.mkdirSync(dirname);
process.chdir(dirname);
fs.rmdirSync(dirname);
}
var dirname = common.tmpDir + '/cwd-does-not-exist-' + process.pid;
+common.refreshTmpDir();
fs.mkdirSync(dirname);
process.chdir(dirname);
fs.rmdirSync(dirname);
var path = require('path');
var fs = require('fs');
var fn = path.join(common.tmpDir, 'write.txt');
+common.refreshTmpDir();
var file = fs.createWriteStream(fn, {
highWaterMark: 10
});
}
-removeTestFile();
+common.refreshTmpDir();
// drain at 0, return false at 10.
file = fs.createWriteStream(filepath, {
}
-removeTestFile();
+common.refreshTmpDir();
function run_test_1() {
fs.chmodSync(file, mode);
};
+common.refreshTmpDir();
createFileWithPerms(readOnlyFile, 0o444);
createFileWithPerms(readWriteFile, 0o666);
'历经五代君主。南越国是岭南地区的第一个有记载的政权国家,采用封建制和郡县制并存的制度,' +
'它的建立保证了秦末乱世岭南地区社会秩序的稳定,有效的改善了岭南地区落后的政治、##济现状。\n';
+common.refreshTmpDir();
+
// test that empty file will be created and have content added
var filename = join(common.tmpDir, 'append-sync.txt');
var ncallbacks = 0;
+common.refreshTmpDir();
+
// test that empty file will be created and have content added
fs.appendFile(filename, s, function(e) {
if (e) throw e;
if (fs.lchmod) {
var link = path.join(common.tmpDir, 'symbolic-link');
- try {
- fs.unlinkSync(link);
- } catch (er) {}
+ common.refreshTmpDir();
fs.symlinkSync(file2, link);
fs.lchmod(link, mode_async, function(err) {
var fileName = path.join(common.tmpDir, new Array(fileNameLen + 1).join('x'));
var fullPath = path.resolve(fileName);
-try {
- fs.unlinkSync(fullPath);
-}
-catch (e) {
- // Ignore.
-}
+common.refreshTmpDir();
console.log({
filenameLength: fileName.length,
}
}
+common.refreshTmpDir();
+
(function() {
var ncalls = 0;
var pathname = common.tmpDir + '/test1';
var output = '';
var fd, stream;
+common.refreshTmpDir();
fs.writeFileSync(file, input);
fd = fs.openSync(file, 'r');
var filename = path.join(common.tmpDir, '/readfile_pipe_large_test.txt');
var dataExpected = new Array(1000000).join('a');
+common.refreshTmpDir();
fs.writeFileSync(filename, dataExpected);
if (process.argv[2] === 'child') {
var filename = path.join(common.tmpDir, '/readfilesync_pipe_large_test.txt');
var dataExpected = new Array(1000000).join('a');
+common.refreshTmpDir();
fs.writeFileSync(filename, dataExpected);
if (process.argv[2] === 'child') {
var isWindows = process.platform === 'win32';
var skipSymlinks = false;
+common.refreshTmpDir();
+
var root = '/';
if (isWindows) {
// something like "C:\\"
var tmpDirs = ['cycles', 'cycles/folder'];
tmpDirs.forEach(function(t) {
t = tmp(t);
- var s;
- try { s = fs.statSync(t); } catch (ex) {}
- if (s) return;
fs.mkdirSync(t, 0o700);
});
fs.writeFileSync(tmp('cycles/root.js'), "console.error('roooot!');");
var filename = join(common.tmpDir, 'out.txt');
-try {
- fs.unlinkSync(filename);
-} catch (e) {
- // might not exist, that's okay.
-}
+common.refreshTmpDir();
var fd = fs.openSync(filename, 'w');
var assert = require('assert');
var fs = require('fs');
+common.refreshTmpDir();
+
test1(fs.createReadStream(__filename));
test2(fs.createReadStream(__filename));
test3(fs.createReadStream(__filename));
var linkTarget = path.join(common.fixturesDir);
var linkData = '../fixtures';
-// Prepare.
-try { fs.mkdirSync(common.tmpDir); } catch (e) {}
-try { fs.unlinkSync(linkPath1); } catch (e) {}
-try { fs.unlinkSync(linkPath2); } catch (e) {}
+common.refreshTmpDir();
// Test fs.symlink()
fs.symlink(linkData, linkPath1, 'junction', function(err) {
var linkData = path.join(common.fixturesDir, 'cycles/');
var linkPath = path.join(common.tmpDir, 'cycles_link');
-// Delete previously created link
-try {
- fs.unlinkSync(linkPath);
-} catch (e) {}
+common.refreshTmpDir();
console.log('linkData: ' + linkData);
console.log('linkPath: ' + linkPath);
var is_windows = process.platform === 'win32';
+common.refreshTmpDir();
+
var runtest = function(skip_symlinks) {
if (!skip_symlinks) {
// test creating and reading symbolic link
var linkData = path.join(common.fixturesDir, '/cycles/root.js');
var linkPath = path.join(common.tmpDir, 'symlink1.js');
- // Delete previously created link
- try {
- fs.unlinkSync(linkPath);
- } catch (e) {}
-
fs.symlink(linkData, linkPath, function(err) {
if (err) throw err;
console.log('symlink done');
var srcPath = path.join(common.fixturesDir, 'cycles', 'root.js');
var dstPath = path.join(common.tmpDir, 'link1.js');
- // Delete previously created link
- try {
- fs.unlinkSync(dstPath);
- } catch (e) {}
-
fs.link(srcPath, dstPath, function(err) {
if (err) throw err;
console.log('hard link done');
var filename = common.tmpDir + '/truncate-file.txt';
+common.refreshTmpDir();
+
// Synchronous test.
(function() {
fs.writeFileSync(filename, '0123456789');
var path = require('path');
var fs = require('fs');
var tmp = common.tmpDir;
-if (!fs.existsSync(tmp))
- fs.mkdirSync(tmp);
+common.refreshTmpDir();
var filename = path.resolve(tmp, 'truncate-file.txt');
var success = 0;
var data = new Buffer(1024 * 16);
data.fill('x');
+common.refreshTmpDir();
+
var stat;
// truncateSync
writeCalled = 0;
+common.refreshTmpDir();
+
fs.open(filename, 'w', 0o644, function(err, fd) {
openCalled++;
if (err) throw err;
data = data.join('\n');
+common.refreshTmpDir();
+
var buf = new Buffer(data, 'base64');
fs.writeFileSync(join(common.tmpDir, 'test.jpg'), buf);
mode = 0o755;
}
+common.refreshTmpDir();
+
// Test writeFileSync
var file1 = path.join(common.tmpDir, 'testWriteFileSync.txt');
-removeFile(file1);
fs.writeFileSync(file1, '123', {mode: mode});
assert.equal(mode, fs.statSync(file1).mode & 0o777);
-removeFile(file1);
-
// Test appendFileSync
var file2 = path.join(common.tmpDir, 'testAppendFileSync.txt');
-removeFile(file2);
fs.appendFileSync(file2, 'abc', {mode: mode});
assert.equal(mode, fs.statSync(file2).mode & mode);
-removeFile(file2);
-
// Verify that all opened files were closed.
assert.equal(0, openCount);
-// Removes a file if it exists.
-function removeFile(file) {
- try {
- if (isWindows)
- fs.chmodSync(file, 0o666);
- fs.unlinkSync(file);
- } catch (err) {
- if (err && err.code !== 'ENOENT')
- throw err;
- }
-}
-
function openSync() {
openCount++;
return fs._openSync.apply(fs, arguments);
var fs = require('fs');
var join = require('path').join;
+common.refreshTmpDir();
+
var filename = join(common.tmpDir, 'test.txt');
common.error('writing to ' + filename);
var file = path.join(common.tmpDir, 'write.txt');
+common.refreshTmpDir();
+
var stream = fs.WriteStream(file),
_fs_close = fs.close,
_fs_open = fs.open;
const examplePath = path.join(common.fixturesDir, 'x.txt');
const dummyPath = path.join(common.tmpDir, 'x.txt');
+common.refreshTmpDir();
+
const exampleReadStream = fs.createReadStream(examplePath, {
encoding: firstEncoding
});
var path = require('path');
var fs = require('fs');
+common.refreshTmpDir();
+
(function() {
var file = path.join(common.tmpDir, 'write-end-test0.txt');
var stream = fs.createWriteStream(file);
var assert = require('assert');
var fs = require('fs');
+common.refreshTmpDir();
+
var stream = fs.createWriteStream(common.tmpDir + '/out', {
highWaterMark: 10
});
const example = path.join(common.tmpDir, 'dummy');
+common.refreshTmpDir();
+
assert.doesNotThrow(function() {
fs.createWriteStream(example, undefined);
});
var file = path.join(common.tmpDir, 'write.txt');
+common.refreshTmpDir();
+
(function() {
var stream = fs.WriteStream(file),
_fs_close = fs.close;
var path = require('path');
var Buffer = require('buffer').Buffer;
var fs = require('fs');
+
+common.refreshTmpDir();
+
var fn = path.join(common.tmpDir, 'write-string-coerce.txt');
var data = true;
var expected = data + '';
var fs = require('fs');
var fn = path.join(common.tmpDir, 'write.txt');
+common.refreshTmpDir();
var foo = 'foo';
var fd = fs.openSync(fn, 'w');
var constants = require('constants');
var found, found2;
+common.refreshTmpDir();
+
fs.open(fn, 'w', 0o644, function(err, fd) {
if (err) throw err;
console.log('open done');
}
+common.refreshTmpDir();
+
var ddcmd = common.ddCommand(filename, 10240);
console.log('dd command: ', ddcmd);
var http = require('http');
var fs = require('fs');
+common.refreshTmpDir();
+
var image = fs.readFileSync(common.fixturesDir + '/person.jpg');
console.log('image.length = ' + image.length);
var fs = require('fs');
var path = require('path');
+common.refreshTmpDir();
+
var file = path.join(common.tmpDir, 'http-pipe-fs-test.txt');
var requests = 0;
var fs = require('fs');
var path = require('path');
-var resultFile = path.resolve(common.tmpDir, 'result');
-
var key = fs.readFileSync(common.fixturesDir + '/keys/agent1-key.pem');
var cert = fs.readFileSync(common.fixturesDir + '/keys/agent1-cert.pem');
var path = require('path');
var cp = require('child_process');
+common.refreshTmpDir();
+
var filename = path.join(common.tmpDir || '/tmp', 'big');
var clientReqComplete = false;
var count = 0;
var fs = require('fs');
var common = require('../common');
+common.refreshTmpDir();
+
var repl = require('repl');
// A stream to push an array into a REPL
var zlib = require('zlib');
var path = require('path');
+common.refreshTmpDir();
+
var gunzip = zlib.createGunzip();
var fs = require('fs');
var relativePathOne = path.join('testsubdir', filenameOne);
var filepathOne = path.join(testsubdir, filenameOne);
+ common.refreshTmpDir();
+
process.on('exit', function() {
assert.ok(watchSeenOne > 0);
});
assert.ok(watchSeenThree > 0);
});
-// Clean up stale files (if any) from previous run.
-try { fs.unlinkSync(filepathOne); } catch (e) { }
-try { fs.unlinkSync(filepathTwoAbs); } catch (e) { }
-try { fs.unlinkSync(filepathThree); } catch (e) { }
-try { fs.rmdirSync(testsubdir); } catch (e) { }
+common.refreshTmpDir();
fs.writeFileSync(filepathOne, 'hello');
var path = require('path');
var fs = require('fs');
+common.refreshTmpDir();
+
var dirname = path.dirname(__filename);
var d = path.join(common.tmpDir, 'dir');
var path = require('path');
var fs = require('fs');
+common.refreshTmpDir();
+
var filename = path.join(common.tmpDir, 'watched');
fs.writeFileSync(filename, 'quis custodiet ipsos custodes');
setTimeout(fs.unlinkSync, 100, filename);
var scriptBuffer = path.join(common.fixturesDir, 'print-chars-from-buffer.js');
var tmpFile = path.join(common.tmpDir, 'stdout.txt');
+common.refreshTmpDir();
+
function test(size, useBuffer, cb) {
var cmd = '"' + process.argv[0] + '"' +
' ' +