Mirrors/cloudcmd
1
0
Fork 0
mirror of https://github.com/coderaiser/cloudcmd.git synced 2026-07-18 08:56:20 +00:00
Code Issues Projects Releases Wiki Activity

refactor(size) get

Browse source
This commit is contained in:
coderaiser 2014-06-23 06:23:35 -04:00
parent 7b29c5a9d8
commit 950dd5651a
1 changed files with 30 additions and 24 deletions
Download patch file Download diff file Expand all files Collapse all files

54
lib/server/size.js
View file

@ -26,10 +26,9 @@
if (!callback)
callback = type;
function calcSize(stat) {
var size = stat && stat.size || 0;
total += size;
function calcSize(error, size) {
if (!error)
total += size;
}
processDir(dir, calcSize, function(error) {
@ -45,26 +44,38 @@
};
function processDir(dir, func, callback) {
var asyncRunning = 0,
fileCounter = 1;
function getDirInfo(dir) {
stat(dir, Util.exec.with(getStat, dir));
}
var asyncRunning = 0,
fileCounter = 1,
execCallBack = function () {
if (!fileCounter && !asyncRunning)
Util.exec(callback);
},
getDirInfo = function(dir) {
stat(dir, Util.exec.with(getStat, dir));
};
getDirInfo(dir);
function getStat(dir, error, stat) {
var isFile, isDir;
--fileCounter;
if (error)
if (error) {
callback(error);
else
if (stat.isFile())
Util.exec(func, stat);
else if (stat.isDirectory()) {
} else {
isFile = stat.isFile(),
isDir = stat.isDirectory();
if (isFile)
func(null, stat.size);
else if (isDir) {
++asyncRunning;
fs.readdir(dir, function(error, files) {
var dirPath, file, n, i;
var getInfo, dirPath, file, n, i;
asyncRunning--;
@ -75,8 +86,9 @@
for (i = 0; i < n; i++) {
file = files[i];
dirPath = path.join(dir, file);
getInfo = Util.exec.with(getDirInfo, dirPath);
process.nextTick(getDirInfo.bind(null, dirPath));
process.nextTick(getInfo);
}
}
@ -84,16 +96,10 @@
execCallBack();
});
}
}
execCallBack();
}
function execCallBack() {
if (!fileCounter && !asyncRunning)
Util.exec(callback);
}
getDirInfo(dir);
}
})();