Lines Matching defs:function
95 function lazyLoadCluster() {
104 function Socket(type, listener) {
125 if (typeof listener === 'function')
163 function createSocket(type, listener) {
168 function startListening(socket) {
186 function replaceHandle(self, newHandle) {
190 if (!oldHandle.hasRef() && typeof newHandle.unref === 'function') {
204 function bufferSize(self, size, buffer) {
217 function bindServerHandle(self, options, errCb) {
237 Socket.prototype.bind = function(port_, address_ /* , callback */) {
249 if (typeof cb === 'function') {
250 function removeListeners() {
255 function onListening() {
266 typeof port.recvStart === 'function') {
317 address = typeof address_ === 'function' ? '' : address_;
378 Socket.prototype.connect = function(port, address, callback) {
380 if (typeof address === 'function') {
408 function _connect(port, address, callback) {
425 function doConnect(ex, self, ip, address, port, callback) {
454 Socket.prototype.disconnect = function() {
468 Socket.prototype.sendto = function(buffer,
483 function sliceBuffer(buffer, offset, length) {
509 function fixBufferList(list) {
526 function enqueue(self, toEnqueue) {
540 function onListenSuccess() {
546 function onListenError(err) {
552 function clearQueue() {
577 Socket.prototype.send = function(buffer,
588 if (address || (port && typeof port !== 'function')) {
598 if (typeof port === 'function') {
635 // Normalize callback so it's either a function or undefined but not anything
637 if (typeof callback !== 'function')
640 if (typeof address === 'function') {
678 function doSend(ex, self, ip, list, address, port, callback) {
682 if (typeof callback === 'function') {
723 function afterSend(err, sent) {
733 Socket.prototype.close = function(callback) {
737 if (typeof callback === 'function')
757 Socket.prototype[SymbolAsyncDispose] = async function() {
765 function socketCloseNT(self) {
770 Socket.prototype.address = function() {
782 Socket.prototype.remoteAddress = function() {
798 Socket.prototype.setBroadcast = function(arg) {
806 Socket.prototype.setTTL = function(ttl) {
818 Socket.prototype.setMulticastTTL = function(ttl) {
830 Socket.prototype.setMulticastLoopback = function(arg) {
840 Socket.prototype.setMulticastInterface = function(interfaceAddress) {
850 Socket.prototype.addMembership = function(multicastAddress,
866 Socket.prototype.dropMembership = function(multicastAddress,
881 Socket.prototype.addSourceSpecificMembership = function(sourceAddress,
899 Socket.prototype.dropSourceSpecificMembership = function(sourceAddress,
917 function healthCheck(socket) {
925 function stopReceiving(socket) {
936 function onMessage(nread, handle, buf, rinfo) {
946 function onError(nread, handle, error) {
952 Socket.prototype.ref = function() {
962 Socket.prototype.unref = function() {
972 Socket.prototype.setRecvBufferSize = function(size) {
977 Socket.prototype.setSendBufferSize = function(size) {
982 Socket.prototype.getRecvBufferSize = function() {
987 Socket.prototype.getSendBufferSize = function() {
991 Socket.prototype.getSendQueueSize = function() {
995 Socket.prototype.getSendQueueCount = function() {
1002 get: deprecate(function() {
1005 set: deprecate(function(val) {
1013 get: deprecate(function() {
1016 set: deprecate(function(val) {
1024 get: deprecate(function() {
1027 set: deprecate(function(val) {
1035 get: deprecate(function() {
1038 set: deprecate(function(val) {
1046 get: deprecate(function() {
1049 set: deprecate(function(val) {
1055 Socket.prototype._healthCheck = deprecate(function() {
1060 Socket.prototype._stopReceiving = deprecate(function() {