lukechilds
/
node
mirror of https://github.com/lukechilds/node.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity
Browse Source

Module system moved to the bottom, where only is it needed. 

(this also splits the file into upper "setup" and lower "startup" sections)
v0.7.4-release
Herbert Vojčík 14 years ago
committed by Ryan Dahl
parent
6abbfa09ff
commit
d429033fd7
1 changed files with 211 additions and 210 deletions
Whitespace
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Split View
Diff Options
Show Stats Download Patch File Download Diff File
  1. 421
      src/node.js

421
src/node.js
View File

@ -94,6 +94,217 @@ function requireNative (id) {
}
// Load events module in order to access prototype elements on process like
// process.addListener.
var events = requireNative('events');
// Signal Handlers
(function() {
var signalWatchers = {};
var addListener = process.addListener;
var removeListener = process.removeListener;
function isSignal (event) {
return event.slice(0, 3) === 'SIG' && process.hasOwnProperty(event);
};
// Wrap addListener for the special signal types
process.on = process.addListener = function (type, listener) {
var ret = addListener.apply(this, arguments);
if (isSignal(type)) {
if (!signalWatchers.hasOwnProperty(type)) {
var b = process.binding('signal_watcher'),
w = new b.SignalWatcher(process[type]);
w.callback = function () {
process.emit(type);
}
signalWatchers[type] = w;
w.start();
} else if (this.listeners(type).length === 1) {
signalWatchers[event].start();
}
}
return ret;
}
process.removeListener = function (type, listener) {
var ret = removeListener.apply(this, arguments);
if (isSignal(type)) {
process.assert(signalWatchers.hasOwnProperty(type));
if (this.listeners(type).length === 0) {
signalWatchers[type].stop();
}
}
return ret;
}
})();
// Timers
function addTimerListener (callback) {
var timer = this;
// Special case the no param case to avoid the extra object creation.
if (arguments.length > 2) {
var args = Array.prototype.slice.call(arguments, 2);
timer.callback = function () { callback.apply(timer, args); };
} else {
timer.callback = callback;
}
}
global.setTimeout = function (callback, after) {
var timer = new process.Timer();
addTimerListener.apply(timer, arguments);
timer.start(after, 0);
return timer;
};
global.setInterval = function (callback, repeat) {
var timer = new process.Timer();
addTimerListener.apply(timer, arguments);
timer.start(repeat, repeat ? repeat : 1);
return timer;
};
global.clearTimeout = function (timer) {
if (timer instanceof process.Timer) {
timer.stop();
}
};
global.clearInterval = global.clearTimeout;
var stdout;
process.__defineGetter__('stdout', function () {
if (stdout) return stdout;
var binding = process.binding('stdio'),
net = requireNative('net'),
fs = requireNative('fs'),
fd = binding.stdoutFD;
if (binding.isStdoutBlocking()) {
stdout = new fs.WriteStream(null, {fd: fd});
} else {
stdout = new net.Stream(fd);
// FIXME Should probably have an option in net.Stream to create a stream from
// an existing fd which is writable only. But for now we'll just add
// this hack and set the `readable` member to false.
// Test: ./node test/fixtures/echo.js < /etc/passwd
stdout.readable = false;
}
return stdout;
});
var stdin;
process.openStdin = function () {
if (stdin) return stdin;
var binding = process.binding('stdio'),
net = requireNative('net'),
fs = requireNative('fs'),
fd = binding.openStdin();
if (binding.isStdinBlocking()) {
stdin = new fs.ReadStream(null, {fd: fd});
} else {
stdin = new net.Stream(fd);
stdin.readable = true;
}
stdin.resume();
return stdin;
};
// console object
var formatRegExp = /%[sdj]/g;
function format (f) {
if (typeof f !== 'string') {
var objects = [], sys = requireNative('sys');
for (var i = 0; i < arguments.length; i++) {
objects.push(sys.inspect(arguments[i]));
}
return objects.join(' ');
}
var i = 1;
var args = arguments;
var str = String(f).replace(formatRegExp, function (x) {
switch (x) {
case '%s': return args[i++];
case '%d': return +args[i++];
case '%j': return JSON.stringify(args[i++]);
default:
return x;
}
});
for (var len = args.length; i < len; ++i) {
str += ' ' + args[i];
}
return str;
}
global.console = {};
global.console.log = function () {
process.stdout.write(format.apply(this, arguments) + '\n');
};
global.console.info = global.console.log;
global.console.warn = function () {
writeError(format.apply(this, arguments) + '\n');
};
global.console.error = global.console.warn;
global.console.dir = function(object){
var sys = requireNative('sys');
process.stdout.write(sys.inspect(object) + '\n');
};
var times = {};
global.console.time = function(label){
times[label] = Date.now();
};
global.console.timeEnd = function(label){
var duration = Date.now() - times[label];
global.console.log('%s: %dms', label, duration);
};
global.console.trace = function(label){
// TODO probably can to do this better with V8's debug object once that is
// exposed.
var err = new Error;
err.name = 'Trace';
err.message = label || '';
Error.captureStackTrace(err, arguments.callee);
console.error(err.stack);
};
global.console.assert = function(expression){
if(!expression){
var arr = Array.prototype.slice.call(arguments, 1);
process.assert(false, format.apply(this, arr));
}
}
global.Buffer = requireNative('buffer').Buffer;
process.exit = function (code) {
process.emit("exit");
process.reallyExit(code);
};
// Module System
var module = (function () {
var exports = {};
@ -515,216 +726,6 @@ var module = (function () {
})();
// Load events module in order to access prototype elements on process like
// process.addListener.
var events = requireNative('events');
// Signal Handlers
(function() {
var signalWatchers = {};
var addListener = process.addListener;
var removeListener = process.removeListener;
function isSignal (event) {
return event.slice(0, 3) === 'SIG' && process.hasOwnProperty(event);
};
// Wrap addListener for the special signal types
process.on = process.addListener = function (type, listener) {
var ret = addListener.apply(this, arguments);
if (isSignal(type)) {
if (!signalWatchers.hasOwnProperty(type)) {
var b = process.binding('signal_watcher'),
w = new b.SignalWatcher(process[type]);
w.callback = function () {
process.emit(type);
}
signalWatchers[type] = w;
w.start();
} else if (this.listeners(type).length === 1) {
signalWatchers[event].start();
}
}
return ret;
}
process.removeListener = function (type, listener) {
var ret = removeListener.apply(this, arguments);
if (isSignal(type)) {
process.assert(signalWatchers.hasOwnProperty(type));
if (this.listeners(type).length === 0) {
signalWatchers[type].stop();
}
}
return ret;
}
})();
// Timers
function addTimerListener (callback) {
var timer = this;
// Special case the no param case to avoid the extra object creation.
if (arguments.length > 2) {
var args = Array.prototype.slice.call(arguments, 2);
timer.callback = function () { callback.apply(timer, args); };
} else {
timer.callback = callback;
}
}
global.setTimeout = function (callback, after) {
var timer = new process.Timer();
addTimerListener.apply(timer, arguments);
timer.start(after, 0);
return timer;
};
global.setInterval = function (callback, repeat) {
var timer = new process.Timer();
addTimerListener.apply(timer, arguments);
timer.start(repeat, repeat ? repeat : 1);
return timer;
};
global.clearTimeout = function (timer) {
if (timer instanceof process.Timer) {
timer.stop();
}
};
global.clearInterval = global.clearTimeout;
var stdout;
process.__defineGetter__('stdout', function () {
if (stdout) return stdout;
var binding = process.binding('stdio'),
net = requireNative('net'),
fs = requireNative('fs'),
fd = binding.stdoutFD;
if (binding.isStdoutBlocking()) {
stdout = new fs.WriteStream(null, {fd: fd});
} else {
stdout = new net.Stream(fd);
// FIXME Should probably have an option in net.Stream to create a stream from
// an existing fd which is writable only. But for now we'll just add
// this hack and set the `readable` member to false.
// Test: ./node test/fixtures/echo.js < /etc/passwd
stdout.readable = false;
}
return stdout;
});
var stdin;
process.openStdin = function () {
if (stdin) return stdin;
var binding = process.binding('stdio'),
net = requireNative('net'),
fs = requireNative('fs'),
fd = binding.openStdin();
if (binding.isStdinBlocking()) {
stdin = new fs.ReadStream(null, {fd: fd});
} else {
stdin = new net.Stream(fd);
stdin.readable = true;
}
stdin.resume();
return stdin;
};
// console object
var formatRegExp = /%[sdj]/g;
function format (f) {
if (typeof f !== 'string') {
var objects = [], sys = requireNative('sys');
for (var i = 0; i < arguments.length; i++) {
objects.push(sys.inspect(arguments[i]));
}
return objects.join(' ');
}
var i = 1;
var args = arguments;
var str = String(f).replace(formatRegExp, function (x) {
switch (x) {
case '%s': return args[i++];
case '%d': return +args[i++];
case '%j': return JSON.stringify(args[i++]);
default:
return x;
}
});
for (var len = args.length; i < len; ++i) {
str += ' ' + args[i];
}
return str;
}
global.console = {};
global.console.log = function () {
process.stdout.write(format.apply(this, arguments) + '\n');
};
global.console.info = global.console.log;
global.console.warn = function () {
writeError(format.apply(this, arguments) + '\n');
};
global.console.error = global.console.warn;
global.console.dir = function(object){
var sys = requireNative('sys');
process.stdout.write(sys.inspect(object) + '\n');
};
var times = {};
global.console.time = function(label){
times[label] = Date.now();
};
global.console.timeEnd = function(label){
var duration = Date.now() - times[label];
global.console.log('%s: %dms', label, duration);
};
global.console.trace = function(label){
// TODO probably can to do this better with V8's debug object once that is
// exposed.
var err = new Error;
err.name = 'Trace';
err.message = label || '';
Error.captureStackTrace(err, arguments.callee);
console.error(err.stack);
};
global.console.assert = function(expression){
if(!expression){
var arr = Array.prototype.slice.call(arguments, 1);
process.assert(false, format.apply(this, arr));
}
}
global.Buffer = requireNative('buffer').Buffer;
process.exit = function (code) {
process.emit("exit");
process.reallyExit(code);
};
var cwd = process.cwd();
var path = requireNative('path');

Write Preview
Loading…
Cancel
Save