(dir: &TempDir, flush_threshold: usize)
| 60 | } |
| 61 | |
| 62 | fn open_engine_with_threshold(dir: &TempDir, flush_threshold: usize) -> ArrayEngine { |
| 63 | let mut cfg = ArrayEngineConfig::new(dir.path().to_path_buf()); |
| 64 | cfg.flush_cell_threshold = flush_threshold; |
| 65 | let mut e = ArrayEngine::new(cfg).unwrap(); |
| 66 | e.open_array(aid(), schema(), SCHEMA_HASH).unwrap(); |
| 67 | e |
| 68 | } |
| 69 | |
| 70 | fn put_cell(e: &mut ArrayEngine, x: i64, v: i64, sys: i64, lsn: u64) { |
| 71 | e.put_cells( |
no test coverage detected