Lines Matching defs:const
24 const {
36 const net = require('net');
37 const EE = require('events');
38 const assert = require('internal/assert');
39 const {
50 const { ConnectionsList } = internalBinding('http_parser');
51 const {
56 const {
64 const {
68 const { IncomingMessage } = require('_http_incoming');
69 const {
73 const {
83 const {
89 const Buffer = require('buffer').Buffer;
90 const {
94 const { setInterval, clearInterval } = require('timers');
99 const dc = require('diagnostics_channel');
100 const onRequestStartChannel = dc.channel('http.server.request.start');
101 const onResponseFinishChannel = dc.channel('http.server.response.finish');
103 const kServerResponse = Symbol('ServerResponse');
104 const kServerResponseStatistics = Symbol('ServerResponseStatistics');
106 const {
112 const STATUS_CODES = {
178 const kOnExecute = HTTPParser.kOnExecute | 0;
179 const kOnTimeout = HTTPParser.kOnTimeout | 0;
180 const kLenientAll = HTTPParser.kLenientAll | 0;
181 const kLenientNone = HTTPParser.kLenientNone | 0;
182 const kConnections = Symbol('http.server.connections');
183 const kConnectionsCheckingInterval = Symbol('http.server.connectionsCheckingInterval');
185 const HTTP_SERVER_TRACE_EVENT_NAME = 'http.server.request';
246 const data = {
266 // const EventEmitter = require('events');
267 // const obj = new EventEmitter();
318 const link = validateLinkHeaderValue(hints.link);
326 for (const key of ObjectKeys(hints)) {
343 const originalStatusCode = statusCode;
376 const keys = ObjectKeys(obj);
397 const statusLine = `HTTP/1.1 ${statusCode} ${this.statusMessage}\r\n`;
432 const maxHeaderSize = options.maxHeaderSize;
437 const insecureHTTPParser = options.insecureHTTPParser;
445 const requestTimeout = options.requestTimeout;
453 const headersTimeout = options.headersTimeout;
465 const keepAliveTimeout = options.keepAliveTimeout;
473 const connectionsCheckingInterval = options.connectionsCheckingInterval;
481 const joinDuplicateHeaders = options.joinDuplicateHeaders;
487 const rejectNonStandardBodyWrites = options.rejectNonStandardBodyWrites;
564 const connections = this[kConnections].all();
576 const connections = this[kConnections].idle();
597 const { 1: res } = args;
600 const names = res.getHeaderNames();
622 const expired = this[kConnections].expired(this.headersTimeout, this.requestTimeout);
625 const socket = expired[i].socket;
653 const parser = parsers.alloc();
655 const lenient = server.insecureHTTPParser === undefined ?
676 const state = {
745 const needPause = state.outgoingData > socket.writableHighWaterMark;
755 const msg = socket._httpMessage;
763 const req = this.parser && this.parser.incoming;
764 const reqTimeout = req && !req.complete && req.emit('timeout', this);
765 const res = this._httpMessage;
766 const resTimeout = res && res.emit('timeout', this);
767 const serverTimeout = this.server.emit('timeout', this);
781 const req = incoming.shift();
788 const ret = parser.finish();
809 const ret = parser.execute(d);
829 const serverTimeout = server.emit('timeout', socket);
835 const noop = () => {};
836 const badRequestResponse = Buffer.from(
840 const requestTimeoutResponse = Buffer.from(
844 const requestHeaderFieldsTooLargeResponse = Buffer.from(
849 const requestChunkExtensionsTooLargeResponse = Buffer.from(
915 const req = parser.incoming;
932 const eventName = req.method === 'CONNECT' ? 'connect' : 'upgrade';
935 const bodyHead = d.slice(ret, d.length);
958 const parser = req.socket && req.socket.parser;
1009 const m = state.outgoing.shift();
1043 const ws = socket._writableState;
1053 const res = new server[kServerResponse](req,
1092 const isRequestsLimitSet = (
1182 const res = net.Socket.prototype[originalFnName].call(this,