Lines Matching refs:req
536 const req = new ShutdownWrap();
537 req.oncomplete = afterShutdown;
538 req.handle = this._handle;
539 req.callback = cb;
540 const err = this._handle.shutdown(req);
958 let req;
960 req = writevGeneric(this, data, cb);
962 req = writeGeneric(this, data, encoding, cb);
963 if (req.async)
964 this[kLastWriteQueueSize] = req.bytes;
1073 const req = new TCPConnectWrap();
1074 req.oncomplete = afterConnect;
1075 req.address = address;
1076 req.port = port;
1077 req.localAddress = localAddress;
1078 req.localPort = localPort;
1081 err = self._handle.connect(req, address, port);
1083 err = self._handle.connect6(req, address, port);
1085 const req = new PipeConnectWrap();
1086 req.address = address;
1087 req.oncomplete = afterConnect;
1089 err = self._handle.connect(req, address);
1149 const req = new TCPConnectWrap();
1150 req.oncomplete = FunctionPrototypeBind(afterConnectMultiple, undefined, context, current);
1151 req.address = address;
1152 req.port = port;
1153 req.localAddress = localAddress;
1154 req.localPort = localPort;
1159 err = handle.connect(req, address, port);
1161 err = handle.connect6(req, address, port);
1181 context[kTimeout] = setTimeout(internalConnectMultipleTimeout, context.timeout, context, req, handle);
1508 function afterConnect(status, handle, req, readable, writable) {
1552 if (req.localAddress && req.localPort) {
1553 details = req.localAddress + ':' + req.localPort;
1557 req.address,
1558 req.port,
1561 ex.localAddress = req.localAddress;
1562 ex.localPort = req.localPort;
1568 function afterConnectMultiple(context, current, status, handle, req, readable, writable) {
1574 debug('connect/multiple: ignoring successful but timedout connection to %s:%s', req.address, req.port);
1585 if (req.localAddress && req.localPort) {
1586 details = req.localAddress + ':' + req.localPort;
1590 req.address,
1591 req.port,
1594 ex.localAddress = req.localAddress;
1595 ex.localPort = req.localPort;
1607 debug('connect/multiple: ignoring successful but timedout connection to %s:%s', req.address, req.port);
1621 { type: 'net', name: 'connect', detail: { host: req.address, port: req.port } },
1625 afterConnect(status, handle, req, readable, writable);
1628 function internalConnectMultipleTimeout(context, req, handle) {
1629 debug('connect/multiple: connection to %s:%s timed out', req.address, req.port);
1630 req.oncomplete = undefined;