Lines Matching refs:server
100 const onRequestStartChannel = dc.channel('http.server.request.start');
101 const onResponseFinishChannel = dc.channel('http.server.response.finish');
182 const kConnections = Symbol('http.server.connections');
183 const kConnectionsCheckingInterval = Symbol('http.server.connectionsCheckingInterval');
185 const HTTP_SERVER_TRACE_EVENT_NAME = 'http.server.request';
508 function httpServerPreClose(server) {
509 server.closeIdleConnections();
510 clearInterval(server[kConnectionsCheckingInterval]);
639 function connectionListenerInternal(server, socket) {
642 // Ensure that the server property of the socket is correctly set.
644 socket.server = server;
646 // If the user has added a listener to the server,
649 if (server.timeout && typeof socket.setTimeout === 'function')
650 socket.setTimeout(server.timeout);
655 const lenient = server.insecureHTTPParser === undefined ?
656 isLenient() : server.insecureHTTPParser;
664 server.maxHeaderSize || 0,
666 server[kConnections],
671 // Propagate headers limit from server instance to parser
672 if (typeof server.maxHeadersCount === 'number') {
673 parser.maxHeaderPairs = server.maxHeadersCount << 1;
692 server, socket, parser, state);
694 server, socket, parser, state);
705 server, socket, state);
726 server, socket, parser, state);
730 server, socket);
767 const serverTimeout = this.server.emit('timeout', this);
774 debug('server socket close');
787 function socketOnEnd(server, socket, parser, state) {
794 } else if (!server.httpAllowHalfOpen) {
805 function socketOnData(server, socket, parser, state, d) {
810 onParserExecuteCommon(server, socket, parser, state, ret, d);
818 function onParserExecute(server, socket, parser, state, ret) {
825 onParserExecuteCommon(server, socket, parser, state, ret, undefined);
828 function onParserTimeout(server, socket) {
829 const serverTimeout = server.emit('timeout', socket);
877 if (!this.server.emit('clientError', e, this)) {
906 function onParserExecuteCommon(server, socket, parser, state, ret, d) {
907 resetSocketTimeout(server, socket, state);
933 if (eventName === 'upgrade' || server.listenerCount(eventName) > 0) {
939 server.emit(eventName, req, socket, bodyHead);
969 function resOnFinish(req, res, socket, state, server) {
975 server,
1003 if (server.keepAliveTimeout && typeof socket.setTimeout === 'function') {
1004 socket.setTimeout(server.keepAliveTimeout);
1027 function parserOnIncoming(server, socket, state, req, keepAlive) {
1028 resetSocketTimeout(server, socket, state);
1032 server.listenerCount('upgrade') > 0;
1053 const res = new server[kServerResponse](req,
1056 rejectNonStandardBodyWrites: server.rejectNonStandardBodyWrites,
1058 res._keepAliveTimeout = server.keepAliveTimeout;
1059 res._maxRequestsPerSocket = server.maxRequestsPerSocket;
1064 res[kUniqueHeaders] = server[kUniqueHeaders];
1072 server,
1087 req, res, socket, state, server));
1093 typeof server.maxRequestsPerSocket === 'number' &&
1094 server.maxRequestsPerSocket > 0
1100 server.maxRequestsPerSocket <= state.requestsCount);
1104 (server.maxRequestsPerSocket < state.requestsCount)) {
1106 server.emit('dropRequest', req, socket);
1115 if (server.listenerCount('checkContinue') > 0) {
1116 server.emit('checkContinue', req, res);
1119 server.emit('request', req, res);
1121 } else if (server.listenerCount('checkExpectation') > 0) {
1122 server.emit('checkExpectation', req, res);
1131 server.emit('request', req, res);
1137 function resetSocketTimeout(server, socket, state) {
1141 socket.setTimeout(server.timeout || 0);