perf: improve performance by preventing unnecessary head data storage…

… attempts

deno.json

@@ -1,6 +1,6 @@
 {
   "name": "@izure/serializable-bptree",
-  "version": "5.0.0",
+  "version": "5.0.1",
   "description": "Store the B+tree flexibly, not only in-memory.",
   "author": "izure1 <[email protected]>",
   "license": "MIT",

package.json

@@ -1,6 +1,6 @@
 {
   "name": "serializable-bptree",
-  "version": "5.0.0",
+  "version": "5.0.1",
   "description": "Store the B+tree flexibly, not only in-memory.",
   "types": "./dist/types/index.d.ts",
   "main": "./dist/cjs/index.cjs",

src/BPTreeAsync.ts

@@ -164,6 +164,7 @@ export class BPTreeAsync<K, V> extends BPTree<K, V> {
       this.root = await this.getNode(keys[0])
       this.root.parent = null
       this.strategy.head.root = this.root.id
+      this._strategyDirty = true
       this.bufferForNodeUpdate(this.root)
       return
     }
@@ -369,6 +370,7 @@ export class BPTreeAsync<K, V> extends BPTree<K, V> {
       const root = await this._createNode(false, [node.id, pointer.id], [value])
       this.root = root
       this.strategy.head.root = root.id
+      this._strategyDirty = true
       node.parent = root.id
       pointer.parent = root.id
       this.bufferForNodeCreate(root)
@@ -480,6 +482,10 @@ export class BPTreeAsync<K, V> extends BPTree<K, V> {
   }
 
   protected async commitHeadBuffer(): Promise<void> {
+    if (!this._strategyDirty) {
+      return
+    }
+    this._strategyDirty = false
     await this.strategy.writeHead(this.strategy.head)
   }
 
@@ -639,6 +645,7 @@ export class BPTreeAsync<K, V> extends BPTree<K, V> {
 
   public async setHeadData(data: SerializableData): Promise<void> {
     this.strategy.head.data = data
+    this._strategyDirty = true
     await this.commitHeadBuffer()
   }
 

src/BPTreeSync.ts

@@ -164,6 +164,7 @@ export class BPTreeSync<K, V> extends BPTree<K, V> {
       this.root = this.getNode(keys[0])
       this.root.parent = null
       this.strategy.head.root = this.root.id
+      this._strategyDirty = true
       this.bufferForNodeUpdate(this.root)
       return
     }
@@ -369,6 +370,7 @@ export class BPTreeSync<K, V> extends BPTree<K, V> {
       const root = this._createNode(false, [node.id, pointer.id], [value])
       this.root = root
       this.strategy.head.root = root.id
+      this._strategyDirty = true
       node.parent = root.id
       pointer.parent = root.id
       this.bufferForNodeCreate(root)
@@ -480,6 +482,10 @@ export class BPTreeSync<K, V> extends BPTree<K, V> {
   }
 
   protected commitHeadBuffer(): void {
+    if (!this._strategyDirty) {
+      return
+    }
+    this._strategyDirty = false
     this.strategy.writeHead(this.strategy.head)
   }
 
@@ -639,6 +645,7 @@ export class BPTreeSync<K, V> extends BPTree<K, V> {
 
   public setHeadData(data: SerializableData): void {
     this.strategy.head.data = data
+    this._strategyDirty = true
     this.commitHeadBuffer()
   }
 

src/base/BPTree.ts

@@ -55,11 +55,13 @@ export abstract class BPTree<K, V> {
   protected readonly nodes: InvertedWeakMap<string, BPTreeUnknownNode<K, V>>
   protected order!: number
   protected root!: BPTreeUnknownNode<K, V>
-
+
+  protected _strategyDirty: boolean
   protected readonly _nodeCreateBuffer: Map<string, BPTreeUnknownNode<K, V>>
   protected readonly _nodeUpdateBuffer: Map<string, BPTreeUnknownNode<K, V>>
   protected readonly _nodeDeleteBuffer: Map<string, BPTreeUnknownNode<K, V>>
 
+
   protected readonly verifierMap: Record<
     keyof BPTreeCondition<V>,
     (nodeValue: V, value: V) => boolean
@@ -117,6 +119,7 @@ export abstract class BPTree<K, V> {
   }
 
   protected constructor(strategy: SerializeStrategy<K, V>, comparator: ValueComparator<V>) {
+    this._strategyDirty = false
     this._cachedRegexp = new InvertedWeakMap()
     this._nodeCreateBuffer = new Map()
     this._nodeUpdateBuffer = new Map()