mirror of
https://github.com/denoland/deno.git
synced 2024-12-27 01:29:14 -05:00
084eafe508
Max rps without a signal is unchanged, however we can drastically reduce memory usage by not creating the signal until needed, and we can optimize the rps in the case where the signal is created. With a quick memory benchmark, it looks like this helps pretty drastically with # of GCs when benchmarking w/wrk: - 1.42.4: 1763 - canary: 1093 - this patch: 874 This branch: ``` Running 10s test @ http://localhost:8080/ 2 threads and 10 connections Thread Stats Avg Stdev Max +/- Stdev Latency 87.33us 439.95us 20.68ms 99.67% Req/Sec 66.70k 6.39k 74.11k 83.66% 1340255 requests in 10.10s, 191.73MB read Requests/sec: 132696.90 Transfer/sec: 18.98MB cpu: Apple M2 Pro runtime: deno 1.43.0 (aarch64-apple-darwin) file:///Users/matt/Documents/scripts/bench_request.js benchmark time (avg) iter/s (min … max) p75 p99 p995 ----------------------------------------------------------------------------------------------- ----------------------------- newRequest 986.5 ns/iter 1,013,682.6 (878.2 ns … 1.18 µs) 1.01 µs 1.18 µs 1.18 µs newAbortController 18 ns/iter 55,541,104.1 (15.6 ns … 42.62 ns) 17.71 ns 25.05 ns 26.27 ns newAbortControllerSignal 18.66 ns/iter 53,578,966.7 (16.49 ns … 32.16 ns) 18.71 ns 25.67 ns 26.39 ns newAbortControllerSignalOnAbort 106.49 ns/iter 9,390,164.9 (97.87 ns … 120.61 ns) 108.6 ns 114.24 ns 115.89 ns newAbortControllerSignalAddEventListener 86.92 ns/iter 11,504,880.2 (81.88 ns … 103.15 ns) 90 ns 98.28 ns 99.55 ns newAbortControllerSignalOnAbortNoListener 3.01 µs/iter 331,964.4 (2.97 µs … 3.1 µs) 3.06 µs 3.1 µs 3.1 µs newAbortControllerSignalOnAbortAbort 3.26 µs/iter 306,662.6 (3.22 µs … 3.36 µs) 3.27 µs 3.36 µs 3.36 µs ``` Latest canary: ``` Running 10s test @ http://localhost:8080/ 2 threads and 10 connections Thread Stats Avg Stdev Max +/- Stdev Latency 72.86us 71.23us 4.47ms 99.05% Req/Sec 64.66k 5.54k 72.48k 82.18% 1299015 requests in 10.10s, 185.83MB read Requests/sec: 128616.02 Transfer/sec: 18.40MB cpu: Apple M2 Pro runtime: deno 1.43.0+bc4aa5f (aarch64-apple-darwin) file:///Users/matt/Documents/scripts/bench_request.js benchmark time (avg) iter/s (min … max) p75 p99 p995 ----------------------------------------------------------------------------------------------- ----------------------------- newRequest 1.25 µs/iter 800,005.2 (1.01 µs … 4.18 µs) 1.16 µs 4.18 µs 4.18 µs newAbortController 18.56 ns/iter 53,868,204.3 (16.04 ns … 38.73 ns) 18.38 ns 26.1 ns 26.63 ns newAbortControllerSignal 18.72 ns/iter 53,430,746.1 (16.13 ns … 36.71 ns) 18.71 ns 26.19 ns 26.98 ns newAbortControllerSignalOnAbort 193.91 ns/iter 5,156,992.4 (184.25 ns … 211.41 ns) 194.96 ns 207.87 ns 209.4 ns newAbortControllerSignalAddEventListener 171.45 ns/iter 5,832,569.2 (153 ns … 182.03 ns) 176.17 ns 180.75 ns 181.05 ns newAbortControllerSignalOnAbortNoListener 3.07 µs/iter 326,263.3 (2.98 µs … 3.17 µs) 3.08 µs 3.17 µs 3.17 µs newAbortControllerSignalOnAbortAbort 3.32 µs/iter 301,344.6 (3.29 µs … 3.4 µs) 3.33 µs 3.4 µs 3.4 µs ```
100 lines
2.6 KiB
TypeScript
100 lines
2.6 KiB
TypeScript
// Copyright 2018-2024 the Deno authors. All rights reserved. MIT license.
|
|
|
|
// deno-lint-ignore-file no-explicit-any no-var
|
|
|
|
/// <reference no-default-lib="true" />
|
|
/// <reference lib="esnext" />
|
|
|
|
declare var domIterable: {
|
|
DomIterableMixin(base: any, dataSymbol: symbol): any;
|
|
};
|
|
|
|
declare module "ext:deno_fetch/20_headers.js" {
|
|
class Headers {
|
|
}
|
|
type HeaderList = [string, string][];
|
|
function headersFromHeaderList(
|
|
list: HeaderList,
|
|
guard:
|
|
| "immutable"
|
|
| "request"
|
|
| "request-no-cors"
|
|
| "response"
|
|
| "none",
|
|
): Headers;
|
|
function headerListFromHeaders(headers: Headers): HeaderList;
|
|
function fillHeaders(headers: Headers, object: HeadersInit): void;
|
|
function getDecodeSplitHeader(
|
|
list: HeaderList,
|
|
name: string,
|
|
): string[] | null;
|
|
function guardFromHeaders(
|
|
headers: Headers,
|
|
): "immutable" | "request" | "request-no-cors" | "response" | "none";
|
|
}
|
|
|
|
declare module "ext:deno_fetch/21_formdata.js" {
|
|
type FormData = typeof FormData;
|
|
function formDataToBlob(
|
|
formData: FormData,
|
|
): Blob;
|
|
function parseFormData(
|
|
body: Uint8Array,
|
|
boundary: string | undefined,
|
|
): FormData;
|
|
function formDataFromEntries(entries: FormDataEntry[]): FormData;
|
|
}
|
|
|
|
declare module "ext:deno_fetch/22_body.js" {
|
|
function mixinBody(
|
|
prototype: any,
|
|
bodySymbol: symbol,
|
|
mimeTypeSymbol: symbol,
|
|
): void;
|
|
class InnerBody {
|
|
constructor(stream?: ReadableStream<Uint8Array>);
|
|
stream: ReadableStream<Uint8Array>;
|
|
source: null | Uint8Array | Blob | FormData;
|
|
length: null | number;
|
|
unusable(): boolean;
|
|
consume(): Promise<Uint8Array>;
|
|
clone(): InnerBody;
|
|
}
|
|
function extractBody(object: BodyInit): {
|
|
body: InnerBody;
|
|
contentType: string | null;
|
|
};
|
|
}
|
|
|
|
declare module "ext:deno_fetch/26_fetch.js" {
|
|
function toInnerRequest(request: Request): InnerRequest;
|
|
function fromInnerRequest(
|
|
inner: InnerRequest,
|
|
guard:
|
|
| "request"
|
|
| "immutable"
|
|
| "request-no-cors"
|
|
| "response"
|
|
| "none",
|
|
skipBody: boolean,
|
|
): Request;
|
|
function redirectStatus(status: number): boolean;
|
|
function nullBodyStatus(status: number): boolean;
|
|
function newInnerRequest(
|
|
method: string,
|
|
url: any,
|
|
headerList?: [string, string][],
|
|
body?: fetchBody.InnerBody,
|
|
): InnerResponse;
|
|
function toInnerResponse(response: Response): InnerResponse;
|
|
function fromInnerResponse(
|
|
inner: InnerResponse,
|
|
guard:
|
|
| "request"
|
|
| "immutable"
|
|
| "request-no-cors"
|
|
| "response"
|
|
| "none",
|
|
): Response;
|
|
function networkError(error: string): InnerResponse;
|
|
}
|