summaryrefslogtreecommitdiff
path: root/lib/_http_server.js
diff options
context:
space:
mode:
authortelenord <nordtelecom.yandex.ru>2019-11-06 13:22:01 +0300
committerRich Trott <rtrott@gmail.com>2019-11-18 19:34:14 -0800
commit422650a4daf9e4c7dd4308d2941d9a05d11f2d75 (patch)
tree52ad4a597c2781644f0ae1e7d73596c0a6bc1237 /lib/_http_server.js
parent0f58bfd0633e357208822a1bc045c5e3bbbb3f6e (diff)
downloadandroid-node-v8-422650a4daf9e4c7dd4308d2941d9a05d11f2d75.tar.gz
android-node-v8-422650a4daf9e4c7dd4308d2941d9a05d11f2d75.tar.bz2
android-node-v8-422650a4daf9e4c7dd4308d2941d9a05d11f2d75.zip
http: revise _http_server.js
* replace var with const * eliminate unnecessary bytesParsed variable http: remove bytesParsed var PR-URL: https://github.com/nodejs/node/pull/30279 Reviewed-By: Ruben Bridgewater <ruben@bridgewater.de> Reviewed-By: Trivikram Kamat <trivikr.dev@gmail.com> Reviewed-By: Yorkie Liu <yorkiefixer@gmail.com> Reviewed-By: Gireesh Punathil <gpunathi@in.ibm.com> Reviewed-By: James M Snell <jasnell@gmail.com>
Diffstat (limited to 'lib/_http_server.js')
-rw-r--r--lib/_http_server.js21
1 files changed, 10 insertions, 11 deletions
diff --git a/lib/_http_server.js b/lib/_http_server.js
index 82f9b91795..bc956a0114 100644
--- a/lib/_http_server.js
+++ b/lib/_http_server.js
@@ -249,13 +249,13 @@ function writeHead(statusCode, reason, obj) {
}
this.statusCode = statusCode;
- var headers;
+ let headers;
if (this[kOutHeaders]) {
// Slow-case: when progressive API and header fields are passed.
- var k;
+ let k;
if (obj) {
- var keys = Object.keys(obj);
- for (var i = 0; i < keys.length; i++) {
+ const keys = Object.keys(obj);
+ for (let i = 0; i < keys.length; i++) {
k = keys[i];
if (k) this.setHeader(k, obj[k]);
}
@@ -483,7 +483,7 @@ function socketOnClose(socket, state) {
function abortIncoming(incoming) {
while (incoming.length) {
- var req = incoming.shift();
+ const req = incoming.shift();
req.aborted = true;
req.emit('aborted');
req.emit('close');
@@ -573,8 +573,7 @@ function onParserExecuteCommon(server, socket, parser, state, ret, d) {
socketOnError.call(socket, ret);
} else if (parser.incoming && parser.incoming.upgrade) {
// Upgrade or CONNECT
- var bytesParsed = ret;
- var req = parser.incoming;
+ const req = parser.incoming;
debug('SERVER upgrade or connect', req.method);
if (!d)
@@ -591,10 +590,10 @@ function onParserExecuteCommon(server, socket, parser, state, ret, d) {
freeParser(parser, req, socket);
parser = null;
- var eventName = req.method === 'CONNECT' ? 'connect' : 'upgrade';
+ const eventName = req.method === 'CONNECT' ? 'connect' : 'upgrade';
if (eventName === 'upgrade' || server.listenerCount(eventName) > 0) {
debug('SERVER have listener for %s', eventName);
- var bodyHead = d.slice(bytesParsed, d.length);
+ const bodyHead = d.slice(ret, d.length);
socket.readableFlowing = null;
server.emit(eventName, req, socket, bodyHead);
@@ -656,7 +655,7 @@ function resOnFinish(req, res, socket, state, server) {
}
} else {
// Start sending the next message
- var m = state.outgoing.shift();
+ const m = state.outgoing.shift();
if (m) {
m.assignSocket(socket);
}
@@ -693,7 +692,7 @@ function parserOnIncoming(server, socket, state, req, keepAlive) {
// so that we don't become overwhelmed by a flood of
// pipelined requests that may never be resolved.
if (!socket._paused) {
- var ws = socket._writableState;
+ const ws = socket._writableState;
if (ws.needDrain || state.outgoingData >= socket.writableHighWaterMark) {
socket._paused = true;
// We also need to pause the parser, but don't do that until after