// This class is the repl-enabled debugger interface which is invoked on
// "node debug"
function Interface(stdin, stdout, args) {
- var self = this,
- child;
+ var self = this;
this.stdin = stdin;
this.stdout = stdout;
};
}
- var host = options.host;
- var port = options.port;
- var localAddress = options.localAddress;
-
var name = this.getName(options);
if (!this.sockets[name]) {
this.sockets[name] = [];
var OutgoingMessage = require('_http_outgoing').OutgoingMessage;
var agent = require('_http_agent');
-var Agent = agent.Agent;
var globalAgent = agent.globalAgent;
// client
function parserOnIncomingClient(res, shouldKeepAlive) {
- var parser = this;
var socket = this.socket;
var req = socket._httpMessage;
var CRLF = common.CRLF;
var chunkExpression = common.chunkExpression;
-var continueExpression = common.continueExpression;
var debug = common.debug;
};
var field, value;
- var self = this;
if (headers) {
var keys = Object.keys(headers);
};
-var zero_chunk_buf = new Buffer('\r\n0\r\n');
var crlf_buf = new Buffer('\r\n');
function pipeOnDrain(src) {
return function() {
- var dest = this;
var state = src._readableState;
debug('pipeOnDrain', state.awaitDrain);
if (state.awaitDrain)
Duplex.call(this, options);
- var ts = this._transformState = new TransformState(options, this);
+ this._transformState = new TransformState(options, this);
// when the writable side finishes, then flush out anything remaining.
var stream = this;
// if there's nothing in the write buffer, then that means
// that nothing more will ever be provided
var ws = stream._writableState;
- var rs = stream._readableState;
var ts = stream._transformState;
if (ws.length)
Writable.WritableState = WritableState;
var util = require('util');
-var assert = require('assert');
var Stream = require('stream');
util.inherits(Writable, Stream);
var assert = require('assert');
var constants = require('constants');
var crypto = require('crypto');
-var events = require('events');
var net = require('net');
var tls = require('tls');
var util = require('util');
writable: socket.writable
});
- var self = this;
-
this._tlsOptions = options;
this._secureEstablished = false;
this._controlReleased = false;
var buffer = process.binding('buffer');
var smalloc = process.binding('smalloc');
-var assert = require('assert');
var util = require('util');
var alloc = smalloc.alloc;
var sliceOnto = smalloc.sliceOnto;
},
got: function(message, handle, emit) {
- var self = this;
-
var server = new net.Server();
server.listen(handle, function() {
emit(server);
function SocketListSend(slave, key) {
EventEmitter.call(this);
- var self = this;
-
this.key = key;
this.slave = slave;
}
exports.execFile = function(file /* args, options, callback */) {
- var args, optionArg, callback;
+ var args, callback;
var options = {
encoding: 'utf8',
timeout: 0,
// lazily loaded
var cluster = null;
var dns = null;
-var net = null;
var errnoException = util._errnoException;
-function isIP(address) {
- if (!net)
- net = require('net');
-
- return net.isIP(address);
-}
-
-
function lookup(address, family, callback) {
if (!dns)
dns = require('dns');
}
};
-// Realpath
-// Not using realpath(2) because it's bad.
-// See: http://insanecoding.blogspot.com/2007/11/pathmax-simply-isnt.html
-
-var normalize = pathModule.normalize;
-
// Regexp that finds the next partion of a (partial) path
// result is [base_with_slash, base], e.g. ['somedir/', 'somedir']
if (isWindows) {
var common = require('_http_common');
-var parsers = exports.parsers = common.parsers;
+exports.parsers = common.parsers;
var outgoing = require('_http_outgoing');
return globalAgent.get(options, cb);
};
-var httpSocketSetup = common.httpSocketSetup;
-
exports._connectionListener = server._connectionListener;
var Server = exports.Server = server.Server;
var tls = require('tls');
var http = require('http');
var util = require('util');
-var url = require('url');
var inherits = require('util').inherits;
var debug = util.debuglog('https');
function afterWrite(status, handle, req) {
var self = handle.owner;
- var state = self._writableState;
if (self !== process.stderr && self !== process.stdout)
debug('afterWrite', status);
k,
digit,
t,
- length,
/** Cached calculation results */
baseMinusT;
// * http://www.3waylabs.com/nw/WWW/products/wizcon/vt220.html
var kHistorySize = 30;
-var kBufSize = 10 * 1024;
var util = require('util');
var inherits = require('util').inherits;
Interface.prototype._refreshLine = function() {
- var columns = this.columns;
-
// line length
var line = this._prompt + this.line;
var dispPos = this._getDisplayPos(line);
// list of completion lists, one for each inheritance "level"
var completionGroups = [];
- var completeOn, match, filter, i, j, group, c;
+ var completeOn, match, filter, i, group, c;
// REPL commands (e.g. ".break").
var match = null;
// OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE
// USE OR OTHER DEALINGS IN THE SOFTWARE.
-var assert = require('assert');
var inherits = require('util').inherits;
var net = require('net');
var TTY = process.binding('tty_wrap').TTY;