Skip to content

Commit

Permalink
fs.stat third parameter controlling error creation
Browse files Browse the repository at this point in the history
In some environment (especially when coffescript is involved) module.js
will spend a lot of time looking up nonexisting files. This is caused by the
lengthy error creation. Those errors are then immediately caught.

This change makes the lookup much faster, by avoiding the unnecessary error
creation.

module::statPath now uses the new second parameter of fs.statSync function of the
fs.js. There is a similar change for the fs.stat, adding the third parameter.

Apply suggestions from libuv pull request

Thanks saghul: joyent/libuv#1428

Fix the datastructures for async

Conflicts:
	lib/module.js
	src/node_file.cc
	src/node_file.h
  • Loading branch information
errendir committed Sep 3, 2014
1 parent 912b5e0 commit 0503232
Show file tree
Hide file tree
Showing 4 changed files with 143 additions and 101 deletions.
63 changes: 39 additions & 24 deletions lib/fs.js
Original file line number Diff line number Diff line change
Expand Up @@ -100,14 +100,16 @@ function assertEncoding(encoding) {
}
}

function nullCheck(path, callback) {
function nullCheck(path, callback, throw_safe) {
if (('' + path).indexOf('\u0000') !== -1) {
var er = new Error('Path must be a string without null bytes.');
if (!callback)
throw er;
process.nextTick(function() {
callback(er);
});
if (!throw_safe) {
var er = new Error('Path must be a string without null bytes.');
if (!callback)
throw er;
process.nextTick(function() {
callback(er);
});
}
return false;
}
return true;
Expand Down Expand Up @@ -181,21 +183,25 @@ fs.Stats.prototype.isSocket = function() {
};

fs.exists = function(path, callback) {
if (!nullCheck(path, cb)) return;
binding.stat(pathModule._makeLong(path), cb);
function cb(err, stats) {
if (callback) callback(err ? false : true);
if (!nullCheck(path, undefined, true)) {
cb(true, false);
return;
}
binding.stat(pathModule._makeLong(path), cb, true);
function cb(err, result) {
if (callback) {
if (err) {
callback(false);
} else {
callback(!!result);
}
}
}
};

fs.existsSync = function(path) {
try {
nullCheck(path);
binding.stat(pathModule._makeLong(path));
return true;
} catch (e) {
return false;
}
return (nullCheck(path, undefined, true)) &&
(!!binding.stat(pathModule._makeLong(path), undefined, true));
};

fs.readFile = function(path, options, callback_) {
Expand Down Expand Up @@ -701,10 +707,17 @@ fs.lstat = function(path, callback) {
binding.lstat(pathModule._makeLong(path), callback);
};

fs.stat = function(path, callback) {
fs.stat = function(path, callback, throw_safe) {
callback = makeCallback(callback);
if (!nullCheck(path, callback)) return;
binding.stat(pathModule._makeLong(path), callback);
if (!nullCheck(path, callback, throw_safe)) {
if (throw_safe) {
process.nextTick(function() {
callback(true, false);
});
}
return;
}
binding.stat(pathModule._makeLong(path), callback, throw_safe);
};

fs.fstatSync = function(fd) {
Expand All @@ -716,9 +729,11 @@ fs.lstatSync = function(path) {
return binding.lstat(pathModule._makeLong(path));
};

fs.statSync = function(path) {
nullCheck(path);
return binding.stat(pathModule._makeLong(path));
fs.statSync = function(path, throw_safe) {
if (!nullCheck(path, undefined, throw_safe)) {
return false;
}
return binding.stat(pathModule._makeLong(path), undefined, throw_safe);
};

fs.readlink = function(path, callback) {
Expand Down
7 changes: 3 additions & 4 deletions lib/module.js
Original file line number Diff line number Diff line change
Expand Up @@ -82,10 +82,9 @@ var debug = Module._debug;
// -> a/index.<ext>

function statPath(path) {
try {
return fs.statSync(path);
} catch (ex) {}
return false;
var fs = NativeModule.require('fs');

return fs.statSync(path, true);
}

// check if the directory is a package.json dir
Expand Down
Loading

0 comments on commit 0503232

Please sign in to comment.