Improve perf start/stop recording

dist/indexeddb-backend.js

@@ -829,17 +829,35 @@ class IndexedDBBackend {
 
   async init() {
     let argBuffer = new SharedArrayBuffer(4096 * 9);
-    writer = new Writer(argBuffer, { name: 'args (backend)', debug: false });
+    this.writer = new Writer(argBuffer, {
+      name: 'args (backend)',
+      debug: false
+    });
 
     let resultBuffer = new SharedArrayBuffer(4096 * 9);
-    reader = new Reader(resultBuffer, { name: 'results', debug: false });
+    this.reader = new Reader(resultBuffer, { name: 'results', debug: false });
 
     await startWorker(argBuffer, resultBuffer);
   }
 
   createFile(filename) {
     return new File(filename, this.defaultBlockSize, new FileOps(filename));
   }
+
+  startProfile() {
+    writer.string('profile-start');
+    writer.finalize();
+    reader.int32();
+    reader.done();
+  }
+
+  stopProfile() {
+    end();
+    writer.string('profile-end');
+    writer.finalize();
+    reader.int32();
+    reader.done();
+  }
 }
 
 export default IndexedDBBackend;

package.json

@@ -1,6 +1,6 @@
 {
   "name": "absurd-sql.js-backend",
-  "version": "0.0.10",
+  "version": "0.0.12",
   "main": "./dist/index.js",
   "scripts": {
     "build": "rm -r dist && rollup -c rollup.config.js",

src/blocked-file.js

@@ -333,7 +333,6 @@ export class File {
   }
 
   startStats() {
-    perf.start();
     this.ops.startStats();
   }
 

src/indexeddb/backend.js

@@ -1,5 +1,6 @@
 import { Reader, Writer } from './shared-channel';
 import { File } from '../blocked-file';
+import * as perf from '../perf';
 
 // These are temporarily global, but will be easy to clean up later
 let reader, writer;
@@ -233,15 +234,34 @@ export default class IndexedDBBackend {
 
   async init() {
     let argBuffer = new SharedArrayBuffer(4096 * 9);
-    writer = new Writer(argBuffer, { name: 'args (backend)', debug: false });
+    this.writer = new Writer(argBuffer, {
+      name: 'args (backend)',
+      debug: false
+    });
 
     let resultBuffer = new SharedArrayBuffer(4096 * 9);
-    reader = new Reader(resultBuffer, { name: 'results', debug: false });
+    this.reader = new Reader(resultBuffer, { name: 'results', debug: false });
 
     await startWorker(argBuffer, resultBuffer);
   }
 
   createFile(filename) {
     return new File(filename, this.defaultBlockSize, new FileOps(filename));
   }
+
+  startProfile() {
+    perf.start();
+    writer.string('profile-start');
+    writer.finalize();
+    reader.int32();
+    reader.done();
+  }
+
+  stopProfile() {
+    perf.end();
+    writer.string('profile-end');
+    writer.finalize();
+    reader.int32();
+    reader.done();
+  }
 }

src/indexeddb/main-thread.js

@@ -56,10 +56,12 @@ export function initBackend(worker) {
   listenForPerfData(worker);
 
   worker.addEventListener('message', e => {
-    if (e.data.type === 'spawn-idb-worker') {
-      startWorkerFromMain(e.data.argBuffer, e.data.resultBuffer).then(() => {
-        worker.postMessage({ type: 'worker-ready' });
-      });
+    switch (e.data.type) {
+      case 'spawn-idb-worker':
+        startWorkerFromMain(e.data.argBuffer, e.data.resultBuffer).then(() => {
+          worker.postMessage({ type: 'worker-ready' });
+        });
+        break;
     }
   });
 }

src/indexeddb/worker.js

@@ -348,6 +348,7 @@ async function loadDb(name) {
 function closeDb(name) {
   let openDb = openDbs.get(name);
   if (openDb) {
+    console.log('closing db');
     openDb.close();
     openDbs.delete(name);
   }
@@ -603,7 +604,7 @@ async function listen(reader, writer) {
   let method = reader.string();
 
   switch (method) {
-    case 'stats-start': {
+    case 'profile-start': {
       reader.done();
 
       perf.start();
@@ -614,7 +615,7 @@ async function listen(reader, writer) {
       break;
     }
 
-    case 'stats': {
+    case 'profile-end': {
       reader.done();
 
       await perf.end();