From 4a529a0966f5d2c69953549263b14d30a7db75db Mon Sep 17 00:00:00 2001 From: ProgrammerIn-wonderland <3838shah@gmail.com> Date: Wed, 25 Dec 2024 18:09:44 -0500 Subject: [PATCH 1/3] add some logging in crypto --- src/connection/crypto.ts | 12 +++++++++++- 1 file changed, 11 insertions(+), 1 deletion(-) diff --git a/src/connection/crypto.ts b/src/connection/crypto.ts index 564fbb2..56c3154 100644 --- a/src/connection/crypto.ts +++ b/src/connection/crypto.ts @@ -404,7 +404,9 @@ export class Decryptor { seed(iv: Uint8Array) { // this.roundkeys = keygen(iv); // this.feedback = new Uint8Array(iv); + const start = performance.now(); this.aesCfb = new CFBDecryptor(iv, iv, 1); + console.log("Took " + (performance.now() - start) + " to seed Decryptor"); } constructor() { @@ -422,7 +424,9 @@ export class Decryptor { controller.enqueue(chunk); return; } + const start = performance.now(); controller.enqueue(new Buffer(this.aesCfb.decrypt(chunk.inner))); + console.log("Took " + (performance.now() - start) + " to transform chunk of size " + chunk.length + " (Decryption)"); }, }); } @@ -437,7 +441,9 @@ export class Encryptor { seed(iv: Uint8Array) { // this.roundkeys = keygen(iv); // this.feedback = new Uint8Array(iv); + const start = performance.now(); this.aesCfb = new CFBEncryptor(iv, iv, 1); + console.log("Took " + (performance.now() - start) + " to seed Encryptor"); } transform(chunk: Buffer): Buffer { @@ -448,7 +454,11 @@ export class Encryptor { // // return new Buffer(out); if (!this.aesCfb) return chunk; - return new Buffer(this.aesCfb.encrypt(chunk.inner)); + const start = performance.now(); + const retobj = new Buffer(this.aesCfb.encrypt(chunk.inner)); + console.log("Took " + (performance.now() - start) + " to transform chunk of size " + chunk.length + " (Encryption)"); + return retobj; + } } From 2adb2ff5b1e71d186741a2bfd25c0488a5d9b842 Mon Sep 17 00:00:00 2001 From: ProgrammerIn-wonderland <3838shah@gmail.com> Date: Wed, 25 Dec 2024 18:20:57 -0500 Subject: [PATCH 2/3] more log --- src/connection/framer.ts | 1 + 1 file changed, 1 insertion(+) diff --git a/src/connection/framer.ts b/src/connection/framer.ts index c85fc12..6caf602 100644 --- a/src/connection/framer.ts +++ b/src/connection/framer.ts @@ -61,6 +61,7 @@ export function bufferTransformer(): TransformStream { return new TransformStream({ transform(chunk, controller) { controller.enqueue(new Buffer(chunk)); + console.log("Got a packet of size " + chunk.length +" (bufferTransformer)"); }, }); } From aec72bc0dddc077ebf049cdc1a6d8dee7c147bd2 Mon Sep 17 00:00:00 2001 From: ProgrammerIn-wonderland <3838shah@gmail.com> Date: Wed, 25 Dec 2024 18:58:23 -0500 Subject: [PATCH 3/3] more logs --- src/connection/framer.ts | 6 ++++++ src/connection/index.ts | 3 ++- 2 files changed, 8 insertions(+), 1 deletion(-) diff --git a/src/connection/framer.ts b/src/connection/framer.ts index 6caf602..54b9212 100644 --- a/src/connection/framer.ts +++ b/src/connection/framer.ts @@ -77,8 +77,10 @@ export function lengthTransformer(): TransformStream { let currentSize = -1; return new TransformStream({ transform(chunk, controller) { + const start = performance.now(); currentPacket.extend(chunk); while (true) { + if (currentSize === -1) { let size: number; try { @@ -97,7 +99,9 @@ export function lengthTransformer(): TransformStream { const pkt = currentPacket.take(currentSize); controller.enqueue(pkt); currentSize = -1; + } + console.log("Took " + (performance.now() - start) + " to lengthTransform packet"); }, }); } @@ -110,6 +114,7 @@ export class Decompressor { const self = this; this.transform = new TransformStream({ async transform(chunk, controller) { + const start = performance.now(); if (self.compressionThresh === -1) { controller.enqueue(chunk); return; @@ -126,6 +131,7 @@ export class Decompressor { "Decompressor: server sent compressed packet below threshold" ); } + console.log("Took " + (performance.now() - start) + " to decompress packet"); }, }); } diff --git a/src/connection/index.ts b/src/connection/index.ts index 3b01540..9cd4b61 100644 --- a/src/connection/index.ts +++ b/src/connection/index.ts @@ -151,10 +151,11 @@ export class Connection { // setInterval(() => console.log("eagler backlog ", backlog), 1000); while (true) { + const start = performance.now(); const { done, value } = await reader.read(); if (done || !value) return; - await impl.eaglerRead(value); + console.log("Took " + (performance.now() - start) + " to eaglerRead packet"); backlog--; }