Gecko [ c.stage.kornherr.net ]

Linux v69820.1blu.de 4.15.0 #1 SMP Mon Sep 30 15:36:27 MSK 2024 x86_64
Apache/2.4.58
Server IP : 195.90.215.149 & Your IP : 216.73.217.80
Domains : Cant Read [ /etc/named.conf ]
User : www-data

Name	Size	Permission	Date
proxies	[ DIR ]	drwxr-xr-x	2023-12-23 20:12
utils	[ DIR ]	drwxr-xr-x	2023-12-23 20:12
agent.js	21.39 KB	-rw-r--r--	2023-01-15 03:21
auto.js	5.26 KB	-rw-r--r--	2023-01-15 03:21
client-request.js	12.82 KB	-rw-r--r--	2023-01-15 03:21
incoming-message.js	1.16 KB	-rw-r--r--	2023-01-15 03:21
index.js	1.12 KB	-rw-r--r--	2023-01-15 03:21

Rename

'use strict';
const {Readable} = require('stream');

class IncomingMessage extends Readable {
	constructor(socket, highWaterMark) {
		super({
			emitClose: false,
			autoDestroy: true,
			highWaterMark
		});

this.statusCode = null;
		this.statusMessage = '';
		this.httpVersion = '2.0';
		this.httpVersionMajor = 2;
		this.httpVersionMinor = 0;
		this.headers = {};
		this.trailers = {};
		this.req = null;

this.aborted = false;
		this.complete = false;
		this.upgrade = null;

this.rawHeaders = [];
		this.rawTrailers = [];

this.socket = socket;

this._dumped = false;
	}

get connection() {
		return this.socket;
	}

set connection(value) {
		this.socket = value;
	}

_destroy(error, callback) {
		if (!this.readableEnded) {
			this.aborted = true;
		}

// See https://github.com/nodejs/node/issues/35303
		callback();

this.req._request.destroy(error);
	}

setTimeout(ms, callback) {
		this.req.setTimeout(ms, callback);
		return this;
	}

_dump() {
		if (!this._dumped) {
			this._dumped = true;

this.removeAllListeners('data');
			this.resume();
		}
	}

_read() {
		if (this.req) {
			this.req._request.resume();
		}
	}
}

module.exports = IncomingMessage;