Lots of refactoring and cleanup, especially with how workers are managed

dist/indexeddb-backend.js

@@ -1,3 +1,5 @@
+import * as perf from 'perf-deets';
+
 let FINALIZED = 0xdeadbeef;
 
 let WRITEABLE = 0;
@@ -259,9 +261,6 @@ class Writer {
  }
 }
 
-// Noops in prod
-async function end() {}
-
 function range(start, end, step) {
  let r = [];
  for (let i = start; i <= end; i += step) {
@@ -443,6 +442,8 @@ class File {
  return length;
  }
 
+ perf.record('read');
+
  position = Math.max(position, 0);
  let dataLength = Math.min(length, this.meta.size - position);
 
@@ -465,6 +466,8 @@ class File {
  view[offset + i] = 0;
  }
 
+ perf.endRecording('read');
+
  return length;
  }
 
@@ -586,15 +589,6 @@ class File {
  getattr() {
  return this.meta;
  }
-
- startStats() {
- this.ops.startStats();
- }
-
- stats() {
- end();
- this.ops.stats();
- }
 }
 
 // These are temporarily global, but will be easy to clean up later
@@ -608,22 +602,6 @@ function positionToKey(pos, blockSize) {
 
 function invokeWorker(method, args) {
  switch (method) {
- case 'stats-start': {
- writer.string('stats-start');
- writer.finalize();
- reader.int32();
- reader.done();
- break;
- }
-
- case 'stats': {
- writer.string('stats');
- writer.finalize();
- reader.int32();
- reader.done();
- break;
- }
-
  case 'readBlocks': {
  let { name, positions, blockSize } = args;
 
@@ -737,14 +715,6 @@ class FileOps {
  this.filename = filename;
  }
 
- startStats() {
- return invokeWorker('stats-start');
- }
-
- stats() {
- return invokeWorker('stats');
- }
-
  getStoreName() {
  return this.filename.replace(/\//g, '-');
  }
@@ -808,13 +778,13 @@ function startWorker(argBuffer, resultBuffer) {
  let workerReady = new Promise(resolve => (onReady = resolve));
 
  self.postMessage({
- type: 'spawn-idb-worker',
+ type: '__absurd:spawn-idb-worker',
  argBuffer,
  resultBuffer
  });
 
  self.addEventListener('message', e => {
- if (e.data.type === 'worker-ready') {
+ if (e.data.type === '__absurd:worker-ready') {
  onReady();
  }
  });
@@ -848,14 +818,15 @@ class IndexedDBBackend {
  }
 
  startProfile() {
+ perf.start();
  this.writer.string('profile-start');
  this.writer.finalize();
  reader.int32();
  reader.done();
  }
 
  stopProfile() {
- end();
+ perf.end();
  this.writer.string('profile-end');
  this.writer.finalize();
  reader.int32();

dist/memory-backend.js

@@ -1,5 +1,4 @@
-// Noops in prod
-async function end() {}
+import * as perf from 'perf-deets';
 
 function range(start, end, step) {
  let r = [];
@@ -182,6 +181,8 @@ class File {
  return length;
  }
 
+ perf.record('read');
+
  position = Math.max(position, 0);
  let dataLength = Math.min(length, this.meta.size - position);
 
@@ -204,6 +205,8 @@ class File {
  view[offset + i] = 0;
  }
 
+ perf.endRecording('read');
+
  return length;
  }
 
@@ -325,15 +328,6 @@ class File {
  getattr() {
  return this.meta;
  }
-
- startStats() {
- this.ops.startStats();
- }
-
- stats() {
- end();
- this.ops.stats();
- }
 }
 
 class FileOps {