ref: small fixes

joshLong145 · Oct 17, 2024 · 105f2ab · 105f2ab
1 parent b67de6d
commit 105f2ab
Show file tree

Hide file tree

Showing 3 changed files with 26 additions and 8 deletions.
diff --git a/benchmark/hyperfine/parallel_perf_bench.ts b/benchmark/hyperfine/parallel_perf_bench.ts
@@ -31,7 +31,7 @@ async function parallelKeygenTest(opCount: number, workerCount: number) {
   });
   await wrapper.start();
   // Only measure time of execution. we Init shouldnt count ;)
-  
+
   const promises = [];
   for (let i = 0; i < opCount; i++) {
     promises.push(example.execute("getKeyPair", {}));

diff --git a/benchmark/wasm_instance_start_bench.ts b/benchmark/wasm_instance_start_bench.ts
@@ -25,7 +25,13 @@ Deno.bench("Wasm Worker Start Go Module loading", {
 }, async (_b) => {
   const example = new TestExample();
   const wasmLibPath = path.join(Deno.cwd(), "lib", "wasm_exec_tiny.js");
-  const wasmModulePath = path.join(Deno.cwd(), "examples", "wasm", "tiny-go", "primes-2.wasm");
+  const wasmModulePath = path.join(
+    Deno.cwd(),
+    "examples",
+    "wasm",
+    "tiny-go",
+    "primes-2.wasm",
+  );
 
   const wrapper: InstanceWrapper<TestExample> = new InstanceWrapper<
     TestExample
@@ -37,7 +43,7 @@ Deno.bench("Wasm Worker Start Go Module loading", {
       addons: [
         wasmLibPath,
       ],
-      modulePath: wasmModulePath, 
+      modulePath: wasmModulePath,
       addonLoader: (path: string) => {
         return Deno.readTextFileSync(path);
       },
@@ -61,7 +67,13 @@ Deno.bench("Wasm Worker Start Rust Module loading", {
 }, async (_b) => {
   const example = new TestExample();
   const wasmLibPath = path.join(Deno.cwd(), "lib", "wasm_test.js");
-  const wasmModulePath = path.join(Deno.cwd(), "examples", "wasm", "rust", "wasm_test_bg.wasm");
+  const wasmModulePath = path.join(
+    Deno.cwd(),
+    "examples",
+    "wasm",
+    "rust",
+    "wasm_test_bg.wasm",
+  );
   const wrapper: InstanceWrapper<TestExample> = new InstanceWrapper<
     TestExample
   >(
@@ -70,9 +82,9 @@ Deno.bench("Wasm Worker Start Rust Module loading", {
       outputPath: "output",
       namespace: "asd",
       addons: [
-       wasmLibPath 
+        wasmLibPath,
       ],
-      modulePath: wasmModulePath, 
+      modulePath: wasmModulePath,
       addonLoader: (path: string) => {
         return Deno.readTextFileSync(path);
       },
@@ -95,7 +107,13 @@ Deno.bench("Wasm Worker Start Code Gen Bootstrapping Rust", {
   group: "imported initalization",
 }, async (_b) => {
   const wasmLibPath = path.join(Deno.cwd(), "lib", "wasm_test.js");
-  const wasmModulePath = path.join(Deno.cwd(), "examples", "wasm", "rust", "wasm_test_bg.wasm");
+  const wasmModulePath = path.join(
+    Deno.cwd(),
+    "examples",
+    "wasm",
+    "rust",
+    "wasm_test_bg.wasm",
+  );
   if (!existsSync("./public")) {
     Deno.mkdirSync("./public");
   }

diff --git a/src/Pool.ts b/src/Pool.ts
@@ -37,7 +37,7 @@ export class Pool {
 
   findWorkerForId = (id: string): WorkerHandler | undefined => {
     for (let i = 0; i < this.threads.length; i++) {
-      if (this.threads[i]._executionMap[id]) {
+      if (Object.keys(this.threads[i]._executionMap).indexOf(id) > -1) {
         return this.threads[i];
       }
     }