Lines Matching defs:function
154 function lazyChannels() {
174 function getFlags(ipv6Only) {
178 function createHandle(fd, is_server) {
197 function getNewAsyncId(handle) {
198 return (!handle || typeof handle.getAsyncId !== 'function') ?
203 function isPipeName(s) {
217 function createServer(options, connectionListener) {
224 // let s = net.connect({port: 80, host: 'google.com'}, function() {
234 function connect(...args) {
252 function getDefaultAutoSelectFamily() {
256 function setDefaultAutoSelectFamily(value) {
261 function getDefaultAutoSelectFamilyAttemptTimeout() {
265 function setDefaultAutoSelectFamilyAttemptTimeout(value) {
276 // cb is either a function or null.
285 function normalizeArgs(args) {
311 if (typeof cb !== 'function')
322 function initSocketHandle(self) {
346 function closeSocketHandle(self, isException, isCleanupPending = false) {
366 function Socket(options) {
466 (isUint8Array(onread.buffer) || typeof onread.buffer === 'function') &&
467 typeof onread.callback === 'function') {
468 if (typeof onread.buffer === 'function') {
514 Socket.prototype._unrefTimer = function _unrefTimer() {
524 Socket.prototype._final = function(cb) {
548 function afterShutdown() {
559 function writeAfterFIN(chunk, encoding, cb) {
564 if (typeof encoding === 'function') {
573 if (typeof cb === 'function') {
584 Socket.prototype._onTimeout = function() {
602 Socket.prototype.setNoDelay = function(enable) {
620 Socket.prototype.setKeepAlive = function(enable, initialDelayMsecs) {
649 Socket.prototype.address = function() {
656 get: function() {
672 get: function() {
689 get: function() {
698 get: function() {
704 function tryReadStart(socket) {
714 Socket.prototype._read = function(n) {
730 Socket.prototype.end = function(data, encoding, callback) {
737 Socket.prototype.resetAndDestroy = function() {
753 Socket.prototype.pause = function() {
767 Socket.prototype.resume = function() {
776 Socket.prototype.read = function(n) {
786 function onReadableStreamEnd() {
793 Socket.prototype.destroySoon = function() {
804 Socket.prototype._destroy = function(exception, cb) {
858 Socket.prototype._reset = function() {
864 Socket.prototype._getpeername = function() {
876 function protoGetter(name, callback) {
885 protoGetter('bytesRead', function bytesRead() {
889 protoGetter('remoteAddress', function remoteAddress() {
893 protoGetter('remoteFamily', function remoteFamily() {
897 protoGetter('remotePort', function remotePort() {
902 Socket.prototype._getsockname = function() {
914 protoGetter('localAddress', function localAddress() {
919 protoGetter('localPort', function localPort() {
923 protoGetter('localFamily', function localFamily() {
927 Socket.prototype[kAfterAsyncWrite] = function() {
931 Socket.prototype._writeGeneric = function(writev, data, encoding, cb) {
938 this.once('connect', function connect() {
942 function onClose() {
968 Socket.prototype._writev = function(chunks, cb) {
973 Socket.prototype._write = function(data, encoding, cb) {
980 protoGetter('_bytesDispatched', function _bytesDispatched() {
984 protoGetter('bytesWritten', function bytesWritten() {
1021 function checkBindError(err, port, handle) {
1042 function internalConnect(
1108 function internalConnectMultiple(context, canceled) {
1185 Socket.prototype.connect = function(...args) {
1242 Socket.prototype[kReinitializeHandle] = function reinitializeHandle(handle) {
1251 function socketToDnsFamily(family) {
1262 function lookupAndConnect(self, options) {
1340 defaultTriggerAsyncIdScope(self[async_id_symbol], function() {
1357 defaultTriggerAsyncIdScope(self[async_id_symbol], function() {
1358 lookup(host, dnsopts, function emitLookup(err, ip, addressType) {
1391 function lookupAndConnectMultiple(self, async_id_symbol, lookup, host, options, dnsopts, port, localPort, timeout) {
1392 defaultTriggerAsyncIdScope(self[async_id_symbol], function emitLookup() {
1393 lookup(host, dnsopts, function emitLookup(err, addresses) {
1475 function connectErrorNT(self, err) {
1480 Socket.prototype.ref = function() {
1486 if (typeof this._handle.ref === 'function') {
1494 Socket.prototype.unref = function() {
1500 if (typeof this._handle.unref === 'function') {
1508 function afterConnect(status, handle, req, readable, writable) {
1568 function afterConnectMultiple(context, current, status, handle, req, readable, writable) {
1628 function internalConnectMultipleTimeout(context, req, handle) {
1635 function addAbortSignalOption(self, options) {
1652 function Server(options, connectionListener) {
1658 if (typeof options === 'function') {
1665 if (typeof connectionListener === 'function') {
1709 function toNumber(x) { return (x = Number(x)) >= 0 ? x : false; }
1712 function createServerHandle(address, port, addressType, fd, flags) {
1770 function setupListenHandle(address, port, addressType, backlog, fd, flags) {
1843 function emitErrorNT(self, err) {
1848 function emitListeningNT(self) {
1855 function listenInCluster(server, address, port, addressType,
1881 function listenOnPrimaryHandle(err, handle) {
1898 Server.prototype.listen = function(...args) {
1935 if (args.length === 0 || typeof args[0] === 'function' ||
2007 function lookupAndListen(self, port, address, backlog, exclusive, flags) {
2009 dns.lookup(address, function doListen(err, ip, addressType) {
2022 get: function() {
2029 Server.prototype.address = function() {
2043 function onconnection(err, clientHandle) {
2119 Server.prototype.getConnections = function(cb) {
2122 function end(err, connections) {
2139 function oncount(err, count) {
2157 Server.prototype.close = function(cb) {
2158 if (typeof cb === 'function') {
2160 this.once('close', function close() {
2196 Server.prototype[SymbolAsyncDispose] = async function() {
2203 Server.prototype._emitCloseIfDrained = function() {
2219 function emitCloseNT(self) {
2225 Server.prototype[EventEmitter.captureRejectionSymbol] = function(
2252 Server.prototype._setupWorker = function(socketList) {
2261 Server.prototype.ref = function() {
2270 Server.prototype.unref = function() {
2285 _setSimultaneousAccepts = function(handle) {
2307 _setSimultaneousAccepts = function() {