quic: fixup lint issues

PR-URL: https://github.com/nodejs/node/pull/34160
Reviewed-By: Anna Henningsen <anna@addaleax.net>
This commit is contained in:
James M Snell
2020-07-02 16:24:38 -07:00
parent 7b062ca015
commit 3837d9cf1f
5 changed files with 22 additions and 22 deletions

View File

@@ -12,7 +12,6 @@ assertCrypto();
const {
Array,
BigInt64Array,
Boolean,
Error,
Map,
RegExp,
@@ -30,7 +29,6 @@ const {
setTransportParams,
toggleListeners,
validateNumber,
validateCloseCode,
validateTransportParams,
validateQuicClientSessionOptions,
validateQuicSocketOptions,
@@ -98,7 +96,6 @@ const {
codes: {
ERR_INVALID_ARG_TYPE,
ERR_INVALID_CALLBACK,
ERR_QUIC_ERROR,
ERR_QUICSESSION_DESTROYED,
ERR_QUICSESSION_VERSION_NEGOTIATION,
ERR_QUICSOCKET_DESTROYED,
@@ -1888,7 +1885,7 @@ class QuicSession extends EventEmitter {
this.removeListener('removeListener', onRemoveListener);
const handle = this[kHandle];
this[kHandle] = undefined
this[kHandle] = undefined;
if (handle !== undefined) {
// Copy the stats for use after destruction
state.stats = new BigInt64Array(handle.stats);

View File

@@ -1,6 +1,8 @@
'use strict';
const {
Boolean,
Number,
NumberINFINITY,
NumberNEGATIVE_INFINITY,
} = primordials;
@@ -21,18 +23,15 @@ const {
},
} = require('internal/async_hooks');
const {
kHandle,
} = require('internal/stream_base_commons');
const endianness = require('os').endianness();
const { Readable } = require('stream');
const {
kHandle,
kUpdateTimer,
onStreamRead,
} = require('internal/stream_base_commons');
const endianness = require('os').endianness();
const assert = require('internal/assert');
assert(process.versions.ngtcp2 !== undefined);
@@ -874,26 +873,26 @@ class QuicSessionSharedState {
get maxStreamsBidi() {
return Number(endianness === 'BE' ?
this[kHandle].readBigInt64BE(IDX_QUICSESSION_STATE_MAX_STREAMS_BIDI) :
this[kHandle].readBigInt64LE(IDX_QUICSESSION_STATE_MAX_STREAMS_BIDI));
this[kHandle].readBigInt64BE(IDX_QUICSESSION_STATE_MAX_STREAMS_BIDI) :
this[kHandle].readBigInt64LE(IDX_QUICSESSION_STATE_MAX_STREAMS_BIDI));
}
get maxStreamsUni() {
return Number(endianness === 'BE' ?
this[kHandle].readBigInt64BE(IDX_QUICSESSION_STATE_MAX_STREAMS_UNI) :
this[kHandle].readBigInt64LE(IDX_QUICSESSION_STATE_MAX_STREAMS_UNI));
this[kHandle].readBigInt64BE(IDX_QUICSESSION_STATE_MAX_STREAMS_UNI) :
this[kHandle].readBigInt64LE(IDX_QUICSESSION_STATE_MAX_STREAMS_UNI));
}
get maxDataLeft() {
return Number(endianness === 'BE' ?
this[kHandle].readBigInt64BE(IDX_QUICSESSION_STATE_MAX_DATA_LEFT) :
this[kHandle].readBigInt64LE(IDX_QUICSESSION_STATE_MAX_DATA_LEFT));
this[kHandle].readBigInt64BE(IDX_QUICSESSION_STATE_MAX_DATA_LEFT) :
this[kHandle].readBigInt64LE(IDX_QUICSESSION_STATE_MAX_DATA_LEFT));
}
get bytesInFlight() {
return Number(endianness === 'BE' ?
this[kHandle].readBigInt64BE(IDX_QUICSESSION_STATE_BYTES_IN_FLIGHT) :
this[kHandle].readBigInt64LE(IDX_QUICSESSION_STATE_BYTES_IN_FLIGHT));
this[kHandle].readBigInt64BE(IDX_QUICSESSION_STATE_BYTES_IN_FLIGHT) :
this[kHandle].readBigInt64LE(IDX_QUICSESSION_STATE_BYTES_IN_FLIGHT));
}
}

View File

@@ -837,8 +837,10 @@ class QuicSession : public AsyncWrap,
#define V(id, name) \
bool is_##name() const { return flags_ & (1 << QUICSESSION_FLAG_##id); } \
void set_##name(bool on = true) { \
if (on) flags_ |= (1 << QUICSESSION_FLAG_##id); \
else flags_ &= ~(1 << QUICSESSION_FLAG_##id); \
if (on) \
flags_ |= (1 << QUICSESSION_FLAG_##id); \
else \
flags_ &= ~(1 << QUICSESSION_FLAG_##id); \
}
QUICSESSION_FLAGS(V)
#undef V

View File

@@ -77,8 +77,8 @@ const kALPN = 'zzz';
countdown.dec();
// Shutdown the remaining open sessions.
setImmediate(common.mustCall(() => {
for (const req of sessions)
req.close();
for (const req of sessions)
req.close();
}));
}));

View File

@@ -70,7 +70,9 @@ function gatherQlog(session, id) {
switch (id) {
case 'server':
setupQlog(session.qlog);
break;
case 'client':
session.on('qlog', setupQlog);
break;
}
}