@@ -253,13 +253,13 @@ function writeHead(statusCode, reason, obj) {
253253}
254254this . statusCode = statusCode ;
255255
256- var headers ;
256+ let headers ;
257257if ( this [ kOutHeaders ] ) {
258258// Slow-case: when progressive API and header fields are passed.
259- var k ;
259+ let k ;
260260if ( obj ) {
261- var keys = Object . keys ( obj ) ;
262- for ( var i = 0 ; i < keys . length ; i ++ ) {
261+ const keys = Object . keys ( obj ) ;
262+ for ( let i = 0 ; i < keys . length ; i ++ ) {
263263k = keys [ i ] ;
264264if ( k ) this . setHeader ( k , obj [ k ] ) ;
265265}
@@ -487,7 +487,7 @@ function socketOnClose(socket, state) {
487487
488488function abortIncoming ( incoming ) {
489489while ( incoming . length ) {
490- var req = incoming . shift ( ) ;
490+ const req = incoming . shift ( ) ;
491491req . aborted = true ;
492492req . emit ( 'aborted' ) ;
493493req . emit ( 'close' ) ;
@@ -577,8 +577,7 @@ function onParserExecuteCommon(server, socket, parser, state, ret, d) {
577577socketOnError . call ( socket , ret ) ;
578578} else if ( parser . incoming && parser . incoming . upgrade ) {
579579// Upgrade or CONNECT
580- var bytesParsed = ret ;
581- var req = parser . incoming ;
580+ const req = parser . incoming ;
582581debug ( 'SERVER upgrade or connect' , req . method ) ;
583582
584583if ( ! d )
@@ -594,10 +593,10 @@ function onParserExecuteCommon(server, socket, parser, state, ret, d) {
594593freeParser ( parser , req , socket ) ;
595594parser = null ;
596595
597- var eventName = req . method === 'CONNECT' ? 'connect' : 'upgrade' ;
596+ const eventName = req . method === 'CONNECT' ? 'connect' : 'upgrade' ;
598597if ( eventName === 'upgrade' || server . listenerCount ( eventName ) > 0 ) {
599598debug ( 'SERVER have listener for %s' , eventName ) ;
600- var bodyHead = d . slice ( bytesParsed , d . length ) ;
599+ const bodyHead = d . slice ( ret , d . length ) ;
601600
602601socket . readableFlowing = null ;
603602server . emit ( eventName , req , socket , bodyHead ) ;
@@ -659,7 +658,7 @@ function resOnFinish(req, res, socket, state, server) {
659658}
660659} else {
661660// Start sending the next message
662- var m = state . outgoing . shift ( ) ;
661+ const m = state . outgoing . shift ( ) ;
663662if ( m ) {
664663m . assignSocket ( socket ) ;
665664}
@@ -696,7 +695,7 @@ function parserOnIncoming(server, socket, state, req, keepAlive) {
696695// so that we don't become overwhelmed by a flood of
697696// pipelined requests that may never be resolved.
698697if ( ! socket . _paused ) {
699- var ws = socket . _writableState ;
698+ const ws = socket . _writableState ;
700699if ( ws . needDrain || state . outgoingData >= socket . writableHighWaterMark ) {
701700socket . _paused = true ;
702701// We also need to pause the parser, but don't do that until after
0 commit comments