@ -41,9 +41,9 @@ function isPipeName(s) {
return typeof s === 'string' && toNumber ( s ) === false ;
}
exports . createServer = function ( options , connectionListener ) {
function createServer ( options , connectionListener ) {
return new Server ( options , connectionListener ) ;
} ;
}
// Target API:
@ -58,7 +58,7 @@ exports.createServer = function(options, connectionListener) {
// connect(port, [host], [cb])
// connect(path, [cb]);
//
exports . connect = exports . createConnection = function ( ) {
function connect ( ) {
const args = new Array ( arguments . length ) ;
for ( var i = 0 ; i < arguments . length ; i ++ )
args [ i ] = arguments [ i ] ;
@ -74,7 +74,7 @@ exports.connect = exports.createConnection = function() {
}
return Socket . prototype . connect . call ( socket , options , cb ) ;
} ;
}
// Returns an array [options, cb], where options is an object,
@ -114,7 +114,6 @@ function normalizeArgs(args) {
else
return [ options , cb ] ;
}
exports . _ normalizeArgs = normalizeArgs ;
// called when creating new Socket, or when re-using a closed Socket
@ -312,9 +311,6 @@ function writeAfterFIN(chunk, encoding, cb) {
}
}
exports . Socket = Socket ;
exports . Stream = Socket ; // Legacy naming.
Socket . prototype . read = function ( n ) {
if ( n === 0 )
return stream . Readable . prototype . read . call ( this , n ) ;
@ -829,7 +825,8 @@ function afterWrite(status, handle, req, err) {
}
function connect ( self , address , port , addressType , localAddress , localPort ) {
function internalConnect (
self , address , port , addressType , localAddress , localPort ) {
// TODO return promise from Socket.prototype.connect which
// wraps _connectReq.
@ -943,7 +940,7 @@ Socket.prototype.connect = function() {
this . writable = true ;
if ( pipe ) {
c onnect( this , options . path ) ;
internalC onnect( this , options . path ) ;
} else {
lookupAndConnect ( this , options ) ;
}
@ -958,7 +955,7 @@ function lookupAndConnect(self, options) {
var localAddress = options . localAddress ;
var localPort = options . localPort ;
if ( localAddress && ! export s. isIP ( localAddress ) )
if ( localAddress && ! care s. isIP ( localAddress ) )
throw new TypeError ( '"localAddress" option must be a valid IP: ' +
localAddress ) ;
@ -975,11 +972,11 @@ function lookupAndConnect(self, options) {
port |= 0 ;
// If host is an IP, skip performing a lookup
var addressType = export s. isIP ( host ) ;
var addressType = care s. isIP ( host ) ;
if ( addressType ) {
process . nextTick ( function ( ) {
if ( self . connecting )
c onnect( self , host , port , addressType , localAddress , localPort ) ;
internalC onnect( self , host , port , addressType , localAddress , localPort ) ;
} ) ;
return ;
}
@ -1019,12 +1016,12 @@ function lookupAndConnect(self, options) {
process . nextTick ( connectErrorNT , self , err ) ;
} else {
self . _ unrefTimer ( ) ;
c onnect( self ,
ip ,
port ,
addressType ,
localAddress ,
localPort ) ;
internalC onnect( self ,
ip ,
port ,
addressType ,
localAddress ,
localPort ) ;
}
} ) ;
}
@ -1155,7 +1152,6 @@ function Server(options, connectionListener) {
this . pauseOnConnect = ! ! options . pauseOnConnect ;
}
util . inherits ( Server , EventEmitter ) ;
exports . Server = Server ;
function toNumber ( x ) { return ( x = Number ( x ) ) >= 0 ? x : false ; }
@ -1222,7 +1218,6 @@ function createServerHandle(address, port, addressType, fd) {
return handle ;
}
exports . _ createServerHandle = createServerHandle ;
Server . prototype . _ listen2 = function ( address , port , addressType , backlog , fd ) {
@ -1595,20 +1590,12 @@ Server.prototype.unref = function() {
return this ;
} ;
exports . isIP = cares . isIP ;
exports . isIPv4 = cares . isIPv4 ;
exports . isIPv6 = cares . isIPv6 ;
var _ setSimultaneousAccepts ;
if ( process . platform === 'win32' ) {
var simultaneousAccepts ;
exports . _ setSimultaneousAccepts = function ( handle ) {
_ setSimultaneousAccepts = function ( handle ) {
if ( handle === undefined ) {
return ;
}
@ -1624,5 +1611,20 @@ if (process.platform === 'win32') {
}
} ;
} else {
exports . _ setSimultaneousAccepts = function ( handle ) { } ;
_ setSimultaneousAccepts = function ( handle ) { } ;
}
module . exports = {
_ createServerHandle : createServerHandle ,
_ normalizeArgs : normalizeArgs ,
_ setSimultaneousAccepts ,
connect ,
createConnection : connect ,
createServer ,
isIP : cares . isIP ,
isIPv4 : cares . isIPv4 ,
isIPv6 : cares . isIPv6 ,
Server ,
Socket ,
Stream : Socket , // Legacy naming
} ;