()
| 524 | |
| 525 | #[test] |
| 526 | fn survives_reopen() { |
| 527 | let dir = tempfile::tempdir().unwrap(); |
| 528 | let dwb_path = dir.path().join("reopen.dwb"); |
| 529 | |
| 530 | { |
| 531 | let mut dwb = open_buffered(&dwb_path); |
| 532 | let record = WalRecord::new( |
| 533 | RecordType::Put as u32, |
| 534 | 7, |
| 535 | 1, |
| 536 | 0, |
| 537 | 0, |
| 538 | b"durable".to_vec(), |
| 539 | None, |
| 540 | None, |
| 541 | ) |
| 542 | .unwrap(); |
| 543 | dwb.write_record(&record).unwrap(); |
| 544 | } |
| 545 | |
| 546 | let mut dwb = open_buffered(&dwb_path); |
| 547 | let recovered = dwb.recover_record(7).unwrap(); |
| 548 | assert!(recovered.is_some()); |
| 549 | assert_eq!(recovered.unwrap().payload, b"durable"); |
| 550 | } |
| 551 | |
| 552 | #[test] |
| 553 | fn batch_deferred_writes_and_flush() { |
nothing calls this directly
no test coverage detected