Merge pull request #12 from voxoco/seq-check

add padding to sequence check
voxoco · Jan 17, 2023 · 78d5ad4 · 78d5ad4
2 parents 51ecb42 + c91664c
commit 78d5ad4
Showing 1 changed file with 4 additions and 3 deletions.
diff --git a/mod.ts b/mod.ts
@@ -169,10 +169,11 @@ export class Nqlite {
     try {
       const s = await this.jsm.streams.info(this.app);
 
-      // If s.state.last_seq is greater than seq + snapThreshold we are too far behind and we need to die
-      if (s.state.last_seq > seq + this.snapThreshold) {
+      // If s.state.last_seq is greater than seq + snapThreshold * 2 we are too far behind and we need to die
+      const snapDouble = this.snapThreshold * 2;
+      if (s.state.last_seq > seq + snapDouble) {
         console.log(
-          `Too far behind to catch up: ${s.state.last_seq} > ${seq} + ${this.snapThreshold}`,
+          `Too far behind to catch up: ${s.state.last_seq} > ${seq} + ${snapDouble}`,
         );
         Deno.exit(1);
       }