(&mut self, id: &ArrayId)
| 75 | } |
| 76 | |
| 77 | pub(super) fn maybe_flush(&mut self, id: &ArrayId) -> ArrayEngineResult<()> { |
| 78 | let stats = self.store(id)?.memtable.stats(); |
| 79 | if stats.cell_count >= self.cfg.flush_cell_threshold { |
| 80 | // Auto-flush in the threshold path uses an LSN of 0 — the |
| 81 | // caller's WAL-side flush record (if any) carries the real |
| 82 | // watermark; auto-flushes are always followed by another |
| 83 | // explicit Flush from the Control Plane in production. |
| 84 | self.flush(id, 0)?; |
| 85 | } |
| 86 | Ok(()) |
| 87 | } |
| 88 | } |
| 89 | |
| 90 | /// Shared memtable-stamping core for puts. Recovery routes through here |
no test coverage detected